Создание нескольких наблюдателей с помощью сторожевого таймера Python

В приведенном здесь примере кода показана функция с именем start, а не start_new_thread. Вы пробовали это?

https://pypi.python.org/pypi/watchdog

Кроме того, вам, вероятно, следует вызывать start только один раз после цикла for, а не внутри него.

Отличный вопрос. Этот поток старше, но я нашел его, когда искал точную вещь, и я расширил вашу работу и добавил возможность передать файл со списком каталогов для просмотра. По умолчанию я не смотрю рекурсивно, я оставляю это кому-то другому для проверки. Надеюсь, это поможет любому, кто ищет ту же тему. Отличная работа!

Запустите, используя python watcher.py имя файла.

Где watcher.py — это то, что я назвал своим скриптом, а имя файла — это имя файла с моими путями.

Я перечисляю полные пути в файле, и они разделены символами новой строки.

i.e.:

C:\path1
C:\Path2\subpath1
C:\PATH3

watcher.py

import logging
import sys
import time
from watchdog.observers import Observer
from watchdog.events import LoggingEventHandler

# Attach a logging event AKA FileSystemEventHandler
event_handler = LoggingEventHandler()

# Create Observer to watch directories
observer = Observer()

# Take in list of paths. If none given, watch CWD
paths = open(sys.argv[1], 'r') if len(sys.argv) > 1 else '.'

# Empty list of observers
observers = []

# Base logging configuration
logging.basicConfig(level=logging.INFO,
                    format='%(asctime)s - %(message)s',
                    datefmt='%Y-%m-%d %H:%M:%S')

# Iterate through paths and attach observers
for line in paths:

    # Convert line into string and strip newline character
    targetPath = str(line).rstrip()

    # Schedules watching of a given path
    observer.schedule(event_handler, targetPath)

    # Add observable to list of observers
    observers.append(observer)

# Start observer
observer.start()

try:
    while True:

        # Poll every second
        time.sleep(1)

except KeyboardInterrupt:
    for o in observers:
        o.unschedule_all()

        # Stop observer if interrupted
        o.stop()

for o in observers:

    # Wait until the thread terminates before exit
    o.join()

Просто хочу добавить несколько замечаний:

Библиотека потоков и список потоков в коде могут немного сбивать с толку людей, которые только начинают использовать сторожевой таймер (включая меня). Они на самом деле не нужны в решении. Простой способ объяснить это просто:

• создать одного наблюдателя
• запланировать несколько «событий просмотра»
• и запустите наблюдатель.

Вот и все.

Вот код, который я использую для просмотра нескольких каталогов.

import sys
import time
import logging
from watchdog.observers.polling import PollingObserver as Observer
from watchdog.events import LoggingEventHandler

if __name__ == "__main__":
    logging.basicConfig(level=logging.INFO,
                        format='%(asctime)s - %(message)s',
                        datefmt='%Y-%m-%d %H:%M:%S')
    event_handler = LoggingEventHandler()
    observer = Observer()
    if len(sys.argv) > 1:
        for i in range(1, len(sys.argv)):
            observer.schedule(event_handler, sys.argv[i], recursive=True)
    else:
        observer.schedule(event_handler, '.', recursive=True)
    observer.start()
    try:
        while True:
            time.sleep(1)
    except KeyboardInterrupt:
        observer.stop()
    observer.join()