Сторожевой таймер питона запускается более одного раза

Question

Я пытаюсь выучить Python-Watchdog, но я в некотором замешательстве, почему задание, которое я создал, выполняется не раз. Итак, вот мои настройки:

#handler.py
import os
from watchdog.events import FileSystemEventHandler
from actions import run_something

def getext(filename):
    return os.path.splitext(filename)[-1].lower()

class ChangeHandler(FileSystemEventHandler):

    def on_any_event(self, event):

        if event.is_directory:
            return
        if getext(event.src_path) == '.done':
            run_something()
        else: 
            print "event not directory.. exiting..."
            pass

наблюдатель настроен так:

#observer.py
import os
import time
from watchdog.observers import Observer
from handler import ChangeHandler

BASEDIR = "/path/to/some/directory/bin"

def main():

    while 1:

        event_handler = ChangeHandler()
        observer = Observer()
        observer.schedule(event_handler, BASEDIR, recursive=True)
        observer.start()
        try:
            while True:
                time.sleep(1)
        except KeyboardInterrupt:
            observer.stop()
        observer.join()

 if __name__ == '__main__':
    main()

и, наконец, такие действия:

#actions.py
import os
import subprocess

def run_something():
    output = subprocess.check_output(['./run.sh'])
    print output
    return None

..где ./run.sh это всего лишь сценарий оболочки, который я хотел бы запустить, когда файл с расширением .done находится на /path/to/some/directory/bin

#run.sh
#!/bin/bash
echo "Job Start: $(date)"
rm -rf /path/to/some/directory/bin/job.done # remove the .done file
echo "Job Done: $(date)"

Тем не менее, когда я выпускаю python observer.py а затем сделать touch job.done на /path/to/some/directory/binЯ вижу что мой скрипт ./run.sh работает три раза, а не один..

Я запутался, почему это происходит трижды, а не только один раз (я удаляю job.done файл на моем скрипте bash)

Answer 1

Для отладки сторожевых сценариев полезно распечатать то, что сторожевой таймер видит как события. Одна команда редактирования файла или команды CLI, например touch, может привести к нескольким сторожевым событиям. Например, если вы вставите оператор печати:

class ChangeHandler(FileSystemEventHandler):

    def on_any_event(self, event):
        print(event)

регистрировать каждое событие, работающее

% touch job.done

генерирует

2014-12-24 13:11:02 - <FileCreatedEvent: src_path='/home/unutbu/tmp/job.done'>
2014-12-24 13:11:02 - <DirModifiedEvent: src_path='/home/unutbu/tmp'>
2014-12-24 13:11:02 - <FileModifiedEvent: src_path='/home/unutbu/tmp/job.done'>

---

Выше было два события с src_path кончающийся на job.done, Таким образом,

    if getext(event.src_path) == '.done':
        run_something()

работает дважды, потому что есть FileCreatedEvent и FileModifiedEvent, Вы могли бы быть лучше только мониторинг FileModifiedEvents.

Answer 2

Я сделал исправление для сторожевого таймера:

      import watchdog.events
import watchdog.observers
import time

osb = None

class Handler(watchdog.events.PatternMatchingEventHandler):
    def on_any_event(self, event):
        global osb
        osb = None
        print(f"Watchdog received {event} event - {event.src_path}.")
 
    def on_modified(self, event):
        global osb
        if not osb == event.src_path:
            #Code goes here
        osb = event.src_path
 
 
if __name__ == "__main__":
    src_path = r"C:\\Users\\Administrator\\Desktop\\"
    event_handler = Handler()
    observer = watchdog.observers.Observer()
    observer.schedule(event_handler, path=src_path, recursive=True)
    observer.start()
    try:
        while True:
            time.sleep(0)
    except KeyboardInterrupt:
        observer.stop()
    observer.join()

Нет, объяснять не буду, извините(забыл как это работает и времени разбираться нет).