Python持续监听文件变化代码实例
在日常的工作中,有时候会有这样的需求,需要一个常驻任务,持续的监听一个目录下文件的变化,对此作出回应.
pyinotify就是这样的一个python包,使用方式如下:
一旦src.txt有新的内容,程序就可以监控到,然后将内容发送
importsocket
importpyinotify
pos=0
defsend(c):
c_list=[c]
s=socket.socket(socket.AF_INET,socket.SOCK_STREAM)
s.connect(('127.0.0.1',10001))
print(s.recv(1024).decode('utf-8'))
fordatainc_list:
s.send(data)
print(s.recv(1024).decode('utf-8'))
s.send(b'exit')
s.close()
defprintlog():
globalpos
try:
fd=open("src.txt")
ifpos!=0:
fd.seek(pos,0)
whileTrue:
line=fd.readline()
ifline.strip():
send(line.strip().encode('utf8'))
pos=pos+len(line)
ifnotline.strip():
break
fd.close()
exceptExceptionase:
print(str(e))
classMyEventHandler(pyinotify.ProcessEvent):
#当文件被修改时调用函数
defprocess_IN_MODIFY(self,event):
try:
printlog()
exceptExceptionase:
print(str(e))
if__name__=='__main__':
printlog()
#watchmanager
wm=pyinotify.WatchManager()
wm.add_watch('/home/ubuntu/data-sync/s3',pyinotify.ALL_EVENTS,rec=True)
eh=MyEventHandler()
#notifier
notifier=pyinotify.Notifier(wm,eh)
notifier.loop()
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持毛票票。