我有一个日志文件正在写的另一个进程，我想观察变化。每次发生更改时，我都希望将新数据读入并对其进行一些处理。
最好的方法是什么?我希望在PyWin32库中有某种钩子。我找到了win32文件。函数FindNextChangeNotification，但不知道如何要求它监视特定的文件。
如果有人做过类似的事情，我真的很感激能听到…
[编辑]我应该提到我追求的是一种不需要轮询的解决方案。
[编辑]诅咒!这似乎不能在映射的网络驱动器上工作。我猜windows不会像在本地磁盘上那样“听到”任何对文件的更新。
当前回答
似乎没有人张贴fswatch。它是一个跨平台的文件系统监视器。只要安装它，运行它，并按照提示。
我在python和golang程序中使用过它，它只是工作。
其他回答
正如您在Tim Golden的文章(由Horst Gutmann指出)中看到的，WIN32相对复杂，它监视目录，而不是单个文件。
我建议你研究一下IronPython，它是一个。net python实现。 在IronPython中，你可以使用所有的。net功能——包括
System.IO.FileSystemWatcher
它用一个简单的Event接口处理单个文件。
如果您正在使用窗口，请创建此POLL。CMD文件
@echo off
:top
xcopy /m /y %1 %2 | find /v "File(s) copied"
timeout /T 1 > nul
goto :top
然后您可以输入“poll dir1 dir2”，它将从dir1复制所有文件到dir2，并每秒检查一次更新。
“find”是可选的，只是为了减少控制台的噪音。
这不是递归的。也许你可以在xcopy中使用/e使它成为递归。
看看我对类似问题的回答。您可以在Python中尝试相同的循环。本页建议:
import time
while 1:
where = file.tell()
line = file.readline()
if not line:
time.sleep(1)
file.seek(where)
else:
print line, # already has newline
还可以使用Python查看文件中的问题tail()。
为了用轮询和最小依赖来观察单个文件，下面是一个完整的例子，基于Deestan的回答(上面):
import os
import sys
import time
class Watcher(object):
running = True
refresh_delay_secs = 1
# Constructor
def __init__(self, watch_file, call_func_on_change=None, *args, **kwargs):
self._cached_stamp = 0
self.filename = watch_file
self.call_func_on_change = call_func_on_change
self.args = args
self.kwargs = kwargs
# Look for changes
def look(self):
stamp = os.stat(self.filename).st_mtime
if stamp != self._cached_stamp:
self._cached_stamp = stamp
# File has changed, so do something...
print('File changed')
if self.call_func_on_change is not None:
self.call_func_on_change(*self.args, **self.kwargs)
# Keep watching in a loop
def watch(self):
while self.running:
try:
# Look for changes
time.sleep(self.refresh_delay_secs)
self.look()
except KeyboardInterrupt:
print('\nDone')
break
except FileNotFoundError:
# Action on file not found
pass
except:
print('Unhandled error: %s' % sys.exc_info()[0])
# Call this function each time a change happens
def custom_action(text):
print(text)
watch_file = 'my_file.txt'
# watcher = Watcher(watch_file) # simple
watcher = Watcher(watch_file, custom_action, text='yes, changed') # also call custom action function
watcher.watch() # start the watch going
好吧，因为你在使用Python，你可以打开一个文件，并继续从它读取行。
f = open('file.log')
如果读取的行不是空的，则处理它。
line = f.readline()
if line:
// Do what you want with the line
您可能忽略了在EOF中继续调用readline是可以的。在这种情况下，它会一直返回空字符串。当将某些内容追加到日志文件时，将根据需要从它停止的地方继续读取。
如果您正在寻找使用事件或特定库的解决方案，请在您的问题中指定。否则，我认为这个解决方案就可以了。
