实现一个持续监听文件夹变化并将变化记录到数据库的系统，可以通过以下步骤完成： ### 1. 文件系统监控 使用 `watchdog` 库来监控文件系统的变动。该库支持多种操作系统，并能够捕获文件的创建、修改和删除事件。 安装依赖： ```bash pip install watchdog ``` 以下是监控文件夹变化的示例代码： ```python from watchdog.observers import Observer from watchdog.events import FileSystemEventHandler import time class MyHandler(FileSystemEventHandler): def on_modified(self, event): print(f'File {event.src_path} has been modified') def on_created(self, event): print(f'File {event.src_path} has been created') def on_deleted(self, event): print(f'File {event.src_path} has been deleted') if __name__ == "__main__": path = "/path/to/watch" # 替换为需要监控的目录 event_handler = MyHandler() observer = Observer() observer.schedule(event_handler, path, recursive=True) observer.start() try: while True: time.sleep(1) except KeyboardInterrupt: observer.stop() observer.join() ``` ### 2. 数据库存储 将检测到的文件变更信息存储到数据库中，可以使用 Python 的数据库连接库，如 `pymysql` 或 `MySQLdb`（适用于 MySQL）[^3]。 安装 pymysql： ```bash pip install pymysql ``` 以下是将文件名存入数据库的示例代码： ```python import pymysql def insert_file_event(file_path, event_type): conn = pymysql.connect( host='localhost', user='root', password='your_password', database='file_monitor_db', charset='utf8mb4' ) cursor = conn.cursor() sql = "INSERT INTO file_events (file_name, event_type) VALUES (%s, %s)" cursor.execute(sql, (file_path, event_type)) conn.commit() cursor.close() conn.close() # 在事件处理函数中调用插入数据库的方法 class MyHandlerWithDB(FileSystemEventHandler): def on_modified(self, event): insert_file_event(event.src_path, 'modified') def on_created(self, event): insert_file_event(event.src_path, 'created') def on_deleted(self, event): insert_file_event(event.src_path, 'deleted') ``` ### 3. 完整集成代码 将文件监控与数据库操作整合在一起： ```python from watchdog.observers import Observer from watchdog.events import FileSystemEventHandler import pymysql import time def connect_db(): return pymysql.connect( host='localhost', user='root', password='your_password', database='file_monitor_db', charset='utf8mb4' ) def create_table(): conn = connect_db() cursor = conn.cursor() cursor.execute(''' CREATE TABLE IF NOT EXISTS file_events ( id INT AUTO_INCREMENT PRIMARY KEY, file_name VARCHAR(255) NOT NULL, event_type VARCHAR(50) NOT NULL, event_time TIMESTAMP DEFAULT CURRENT_TIMESTAMP ) ''') conn.commit() cursor.close() conn.close() def insert_file_event(file_path, event_type): conn = connect_db() cursor = conn.cursor() sql = "INSERT INTO file_events (file_name, event_type) VALUES (%s, %s)" cursor.execute(sql, (file_path, event_type)) conn.commit() cursor.close() conn.close() class FileMonitorHandler(FileSystemEventHandler): def __init__(self): create_table() def on_modified(self, event): insert_file_event(event.src_path, 'modified') def on_created(self, event): insert_file_event(event.src_path, 'created') def on_deleted(self, event): insert_file_event(event.src_path, 'deleted') if __name__ == "__main__": path_to_watch = "/path/to/watch" # 设置要监控的目录 event_handler = FileMonitorHandler() observer = Observer() observer.schedule(event_handler, path=path_to_watch, recursive=True) observer.start() try: while True: time.sleep(1) except KeyboardInterrupt: observer.stop() observer.join() ``` ### 4. 数据库配置建议 - 创建数据库 `file_monitor_db` - 确保表 `file_events` 存在并包含必要的字段，例如 `file_name`, `event_type`, 和 `event_time` --- ###