InputWatchdogAction.py 文件源码

def on_init(self):
        super().on_init()

        self.path = self.configuration["input"]
        self.recursive_flag = (
            str.lower(self.configuration["option"]) == "recursive")
        self.trigger = self.configuration["monitor"]

        if "patterns" in self.configuration:
            self.patterns = self.configuration["patterns"].split(" ")

        if "ignore_patterns" in self.configuration:
            self.ignore_patterns = self.configuration[
                "ignore_patterns"].split(" ")

        if "ignore_directories" in self.configuration:
            self.ignore_directories = True

        if "case_sensitive" in self.configuration:
            self.case_sensitive = True

        my_event_handler = DannyFileSystemEventHandler(self.patterns,
                                                       self.ignore_patterns,
                                                       self.ignore_directories,
                                                       self.case_sensitive)
        my_event_handler.delegates.append(self)

        if "timeout" in self.configuration:
            self.timeout = int(self.configuration["timeout"])

        self.observer = Observer(self.timeout)

        self.observer.schedule(my_event_handler, self.path,
                               recursive=self.recursive_flag)
        self.observer.start()