我从以下网站复制了一个Python看门狗脚本:https://www.michaelcho.me/article/using-pythons-watchdog-to-monitor-changes-to-a-directory
import time
from watchdog.observers import Observer
from watchdog.events import FileSystemEventHandler
class Watcher:
DIRECTORY_TO_WATCH = "/path/to/my/directory"
def __init__(self):
self.observer = Observer()
def run(self):
event_handler = Handler()
self.observer.schedule(event_handler, self.DIRECTORY_TO_WATCH, recursive=True)
self.observer.start()
try:
while True:
time.sleep(5)
except:
self.observer.stop()
print "Error"
self.observer.join()
class Handler(FileSystemEventHandler):
@staticmethod
def on_any_event(event):
if event.is_directory:
return None
elif event.event_type == 'created':
# Take any action here when a file is first created.
print "Received created event - %s." % event.src_path
# Build up queue of subtasks here and let another thread/process
# take care of it so that main process can continue.
elif event.event_type == 'modified':
# Taken any action here when a file is modified.
print "Received modified event - %s." % event.src_path
if __name__ == '__main__':
w = Watcher()
w.run()
这个脚本非常适合我,但是我还有一些额外的要求。在
我不想打印文本,而是想启动一个额外的进程(Python脚本),这可能需要几分钟的时间。主脚本不应该等待此进程完成,而是继续检查新的或更改的文件。
启动的二级进程不允许互相超越,因此必须将它们放入某种需要串行处理的队列中。
解决这些需求的好方法是什么?我简要介绍了多处理和异步,但不确定是否正确实现。
我的总体想法是,应该针对一个事件类型启动一个单独的进程/线程,该进程/线程检查队列并逐个执行。理想情况下,当主进程关闭时,这个辅助线程/进程完成剩余的队列。在
我用这个模板作为看门狗。
on_any_event
对我来说有点敏感。在回答1:你可以用任何东西代替
print
。函数、方法、循环等Watcher
将继续运行,并在事件发生时调用Handler()
。在您认为您需要详细说明在调用
on_any_event
之后要做什么。在相关问题 更多 >
编程相关推荐