python3的第三方模块-watchdog文件系统监控的使用（python3经典编程案例）

冷不防 2022-09-08 11:51 237阅读 0赞

原理是通过操作系统的时间触发的，不需要循环，也不需要等待。

如监控test文件夹下的动态：

from watchdog.observers import Observer
    from watchdog.events import *
    import time
    
    
    class FileEventHandler(FileSystemEventHandler):
    
        def __init__(self):
            FileSystemEventHandler.__init__(self)
    
        def on_moved(self, event):
            super(FileEventHandler, self).on_moved(event)
            now = time.strftime("%Y-%m-%d %H:%M:%S", time.localtime())
            if event.is_directory:
                print(f"{ now } 文件夹由 { event.src_path } 移动至 { event.dest_path }")
            else:
                print(f"{ now } 文件由 { event.src_path } 移动至 { event.dest_path }")
    
        def on_created(self, event):
            super(FileEventHandler, self).on_created(event)
            now = time.strftime("%Y-%m-%d %H:%M:%S", time.localtime())
            if event.is_directory:
                print(f"{ now } 文件夹 { event.src_path } 创建")
            else:
                print(f"{ now } 文件 { event.src_path } 创建")
    
        def on_deleted(self, event):
            super(FileEventHandler, self).on_deleted(event)
            now = time.strftime("%Y-%m-%d %H:%M:%S", time.localtime())
            if event.is_directory:
                print(f"{ now } 文件夹 { event.src_path } 删除")
            else:
                print(f"{ now } 文件 { event.src_path } 删除")
    
        def on_modified(self, event):
            super(FileEventHandler, self).on_modified(event)
            now = time.strftime("%Y-%m-%d %H:%M:%S", time.localtime())
            if event.is_directory:
                print(f"{ now } 文件夹 { event.src_path } 修改")
            else:
                print(f"{ now } 文件 { event.src_path } 修改")
    
    
    if __name__ == "__main__":
        observer = Observer()
        path = r"test/"
        event_handler = FileEventHandler()
        observer.schedule(event_handler, path, True)
        print(f"监控目录 { path}")
        observer.start()
        observer.join()