Python - 将多个文件添加到文件夹但只运行一次事件

问题描述

我正在尝试让看门狗监听文件夹更改（添加/删除）文件。

我的问题是，每次我从这个文件夹（及其子文件夹）复制-创建/删除几个文件时，事件链都会为每个文件一个一个地开始。

如何使 on_event() 方法在创建/删除多个文件后只调用一次？

假设我要将两个图像复制到此文件夹中。

我希望事件处理程序在文件传输完成后只调用一次，不要两次 - 每个图像一次 - 因为它目前有效。

谢谢！

代码在带有 python 3.7 的 raspBerry pi 3 上运行。

代码如下：

    import os
    import time
    import psutil
    from watchdog.observers import Observer
    from watchdog.events import FileSystemEventHandler
    
    i = 0
    
    
def show_stats():
    global i
    read = "read #" + str(i) + ":"
    mem = "\nmemory in use: " + str(psutil.virtual_memory().percent)+"%"
    cpu = "\ncpu load: " + str(psutil.cpu_percent())+"%"
    temp = "\ncurrent " + \
        os.popen("vcgencmd measure_temp").readline().replace(
            "=",": ").replace("'C"," C°")
    end = "\n=================="
    i += 1
    stats = read + mem + cpu + temp + end
    return stats
    
    
    class Watcher:
        DIRECTORY_TO_WATCH = r'/home/pi/Desktop/jsSlider/images'
    
        def __init__(self):
            self.observer = Observer()
            print("watching ",self.DIRECTORY_TO_WATCH,"...")
    
        def run(self):
            event_handler = Handler()
            self.observer.schedule(
                event_handler,recursive=True)
            self.observer.start()
            try:
                while True:
                    time.sleep(5)
                    print(show_stats())
            except Exception as e:
                self.observer.stop()
                print(e)
            self.observer.join()
    
    
    class Handler(FileSystemEventHandler):
        @staticmethod
        def on_event(event):
            wait = 1
            elif event.event_type == 'created' or event.event_type == 'deleted':
                print("Received event - %s. " %event.src_path,str(event.event_type))
                time.sleep(wait) #i found that its best to give some timeout between commands because it overwhelmed the pi for some reason (one second seems to be enough)...
                os.system('python /home/pi/Desktop/Slider/scripts/arr_edit.py') #recreate the JS array
                time.sleep(wait)
                os.system('cp -r /home/pi/Desktop/jsSlider/scripts/imgArr.js /home/pi/Desktop/jsSlider/themes/1') #copy the newly created JS array to its place
                time.sleep(wait)
                os.system('sudo pkill chromium') #"refresh" the page -the kiosk mode reactivates the process...
                # os.system('cls')
                print('done!')
    
    
    if __name__ == '__main__':
        w = Watcher()
        w.run()

编辑我

某些诊所的电视连接到电视的 rpi3 很差，在 kiosk 模式下工作以显示来自本地 html 文件的图像（使用一些 js 代码 - 使用现有 JS 脚本运行幻灯片 - 如果需要，我可以上传所有内容| 图像也在 pi 上）。

我想要实现的是自动：

重新构建 JS 数组（使用可运行的 Python 脚本 - 下面的代码 (arr_edit.py)）。
将新数组复制到所需位置。 (shell 命令)
并使用“pkill Chromium”重新启动chrome。 (shell 命令)

现在，我不能允许每次有人复制/删除多个图像时，命令每次都会运行 - 这意味着：

每当添加 2 个以上的图像时，我都无法“重新启动”信息亭 (sudo pkill Chromium) 每次创建文件时。

每次复制多个文件（在这种情况下为图像）时，对于在文件夹中创建的每个单独的图像，都会调用一个完全单独的 event.created，因此对于 5 个图像，将有是 5 个不同的 event.created 事件，它们将依次触发 on_event() 方法，使信息亭连续重启 5 次。（现在想想如果发生 50 个文件传输会发生什么 - pi 会崩溃）

因此，我需要一种方法来在文件传输完成后仅调用该命令 1 次，不管文件夹中更改/创建/删除了多少个文件。

arr_edit.py（不完全是我的代码）：

import os
dir_path = r'/home/pi/Desktop/jsSlider/images'
file_path = r'/home/pi/Desktop/jsSlider/scripts/imgArr.js'

directory = os.fsencode(dir_path)
arr_name = 'images=[\n'
start_str = '{"img":"./images/'
end_str = '"},\n'
images = ''


def writer(array,imagesList):
    str_to_write = array + imagesList + ']'
    f = open(file_path,'w')
    f.write(str_to_write)
    f.close


file_list = os.listdir(directory)
for file in file_list:
    filename = os.fsdecode(file)
    if filename.endswith(".jpg") or filename.endswith(".jpeg") or filename.endswith(".webp") or filename.endswith(".webp"):
        if file == file_list[len(file_list)-1]:
            end_str = '"}\n'
        images += start_str + filename + end_str
        continue
    else:
        continue

writer(arr_name,images)

输出 JS 数组（来自 imgArr.js 中的示例）：

images=[
{"img":"./images/246.jpg"},{"img":"./images/128.jpg"},{"img":"./images/238.webp"},{"img":"./images/198.jpg"},{"img":"./images/247.webp"}
]

解决方法

正如马克在评论中建议的那样，
我添加了一个检查以查看过去 5 分钟内 js 文件是否已更改。
如果文件改变了，
再等 5 分钟，然后重新启动 Cange（如果文件夹中添加了更多文件），这样新的、更大的文件也将在这次运行中显示。
就像魅力一样！
非常感谢！！
这是最后的 watchdog.py

import os
import time
import psutil
from watchdog.observers import Observer
from watchdog.events import FileSystemEventHandler

i = 0


def show_stats():
    global i
    read = "read #" + str(i) + ":"
    mem = "\nmemory in use: " + str(psutil.virtual_memory().percent)+"%"
    cpu = "\ncpu load: " + str(psutil.cpu_percent())+"%"
    temp = "\ncurrent " + \
        os.popen("vcgencmd measure_temp").readline().replace(
            "=",": ").replace("'C"," C°")
    end = "\n=================="
    i += 1
    stats = read + mem + cpu + temp + end
    return stats


def wait_for_file(file):
    time.sleep(300)
    if age(file) >= 5:
        modify()


def modify():
    os.system('python /home/pi/Desktop/jsSlider/scripts/arr_edit.py')
    os.system(
        'cp -r /home/pi/Desktop/jsSlider/scripts/imgArr.js /home/pi/Desktop/jsSlider/themes/1')
    time.sleep(1)
    os.system('sudo pkill chromium')
    # os.system('cls')
    print("done!\nwatching...")


def age(filename):
    return ((time.time() - os.path.getmtime(filename))//60)


class Watcher:
    DIRECTORY_TO_WATCH = r'/home/pi/Desktop/jsSlider/images'

    def __init__(self):
        self.observer = Observer()
        print("watching ",self.DIRECTORY_TO_WATCH,"...")

    def run(self):
        event_handler = Handler()
        self.observer.schedule(
            event_handler,recursive=True)
        self.observer.start()
        try:
            while True:
                time.sleep(5)
                print(show_stats())
        except Exception as e:
            self.observer.stop()
            print(e)
        self.observer.join()


class Handler(FileSystemEventHandler):
    @ staticmethod
    def on_any_event(event):
        file = r'/home/pi/Desktop/jsSlider/scripts/imgArr.js'
        if event.event_type == 'created' or event.event_type == 'deleted':
            print("Received event - %s. " %
                  event.src_path,str(event.event_type))
            time.sleep(5)
            if age(file) < 5:
                wait_for_file(file)
            else:
                modify()


if __name__ == '__main__':
    w = Watcher()
    w.run()

event-handling events python python-watchdog raspberry-pi