17

我目前有一个基本功能脚本，用于监视单个目录和下面的所有子目录的更改并将输出传递给 LoggingEventHandler。

我现在想扩展我的脚本来监控 3 个不同的位置，但我根本无法掌握如何生成多个观察者来观察我指定的每个路径。

我尝试了以下内容：

import time
import thread
import threading
from watchdog.observers import Observer
from watchdog.events import LoggingEventHandler

event_handler = LoggingEventHandler()
observer = Observer()

paths = ["C:\dir1", "C:\dir2", "C:\dir3"]

for i in paths:
    targetPath = str(i)
    observer.schedule(event_handler, targetPath, recursive=True)
    observer.start_new_thread()

不幸的是，我收到一个错误，表明观察者没有属性“start_new_thread”

文档中没有显示多个观察者监视目录的示例。我没有处理线程的经验，我什至不确定我是否走在正确的轨道上。

我应该为每个路径创建一个观察者类的新实例吗？或者是否有某种方法可以提供 Observer 类的单个实例、多个路径？

抱歉，如果有一个明显的答案。我确信现在这一切都错了，我太累了，无法理解。

额外的：

感谢@FogleBird，我已经更正了线程启动问题，但我仍然只停留在一个实例上，而不是三个单独的观察者观察不同的路径。我修改后的代码现在看起来像：

threads = []

for i in paths:
    targetPath = str(i)
    observer.schedule(event_handler, targetPath, recursive=True)
    threads.append(observer)

observer.start()
print threads

这将返回三个 ObservedWatch 对象，但它们都具有相同的详细信息：

[<Observer(Thread-1, started daemon 1548)>, <Observer(Thread-1, started daemon 1548)>, <Observer(Thread-1, started daemon 1548)>]

看起来仍然完全错误，任何更多的帮助都会很棒。我正在努力掌握这个概念。

附加2：

我一直在处理代码，现在我有了一些似乎可以正常工作的东西：

event_handler = LoggingEventHandler()
N2watch = Observer()
threads = []

for i in paths:
    targetPath = str(i)
    N2watch.schedule(event_handler, targetPath, recursive=True)
    threads.append(N2watch)

N2watch.start()

try:
    while True:
            time.sleep(1)
except KeyboardInterrupt:
    N2watch.stop()
N2watch.join()

从我从初始运行中收集到的信息来看，输出似乎显示了列表中指定的所有三个路径名的变化，但我需要编写一些测试代码来检查。

我仍然不确定这是如何表现的，所以任何进一步的评论都会很棒。

干杯。

附加 3：

我将 FogleBird 的答案标记为最佳答案，因为它只是唯一一个，并且确实突出了我最初代码的问题。

我之前的编辑包括用于监控多个位置的完整工作代码，并且目前似乎运行正常。

4

4 回答 4

9

好问题。该线程较旧，但我在查找确切内容时发现了它，并且我扩展了您的工作并添加了传递带有要观看的目录列表的文件的功能。默认情况下，我不递归查看，我将其留给其他人进行测试。希望这可以帮助任何查找相同主题的人。做得好！

使用 pythonwatcher.py文件名运行。

watcher.py我称之为脚本的地方在哪里，文件名是带有我的路径的文件的名称。

我列出了文件中的完整路径，这些路径用换行符分隔。

IE：

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()
于 2016-09-07T15:27:18.633 回答
6

此处的示例代码显示了一个名为 的函数start，而不是start_new_thread。你试过吗？

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

此外，您可能应该start只在 for 循环之后调用一次，而不是在其中调用一次。

于 2013-11-15T01:46:56.177 回答
5

只是想添加一些注释：

对于刚开始使用看门狗的人（包括我自己）来说，代码中的线程库和线程列表可能会有些混乱。它们实际上在解决方案中不是必需的。一个简单的解释方法就是：

  • 创建一个观察者
  • 安排多个“观看活动”
  • 并启动观察者。

而已。

于 2016-10-12T22:43:31.473 回答
1

这是我用来监视多个目录的代码。

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()
于 2019-03-13T23:22:48.443 回答