监控文件是否停止在 python 中写入

Question

我有一个程序每秒都在写入文件。文件写入发生在与 UI 平行的线程中。由于某些硬件问题，它有时会停止写入一天。我想检查文件是否停止写入，如果没有更新则重新启动程序。我想检查文件的时间戳，看看它是否没有更新（并且不想进入看门狗等，因为如果文件停止写入，我只需要。）

try:
    if time.time()>(os.stat(filename).st_mtime+2):
        raise ValueError("Yikes! Spike")
except ValueError:
    with open('errors.log','a') as log:
        log.write('Spike occured at '+ time.strftime(
        "%H:%M:%S")+' on '+datetime.date.today().strftime('%d/%m/%Y')+'\n')
        log.close()
    restart_program()

这个块每秒运行一次。但这适得其反，当应用程序关闭以重新启动时，它每秒都会关闭并且不会再次启动。我每秒都会记录一次异常消息。我尝试增加时差，但没有帮助。

接下来我尝试了

ftimestamp = os.stat(filename).st_mtime
try:
    if os.stat(filename).st_mtime>=ftimestamp:
        ftimestamp = time.time()
        print "ftimestamp updated and all is well"
    else:
        ftimestamp = os.stat(filename).st_mtime
        raise ValueError("Yikes! Spike!")
        print "file time is behind"
except ValueError:
    with open('errors.log','a') as log:
        log.write('Spike occured at '+ time.strftime(
        "%H:%M:%S")+' on '+datetime.date.today().strftime('%d/%m/%Y')+'\n')
        log.close()
    restart_program()

我尝试将变量“ftimestamp”更新为当前时间“time.time()”，因为下一次比较仅在一秒后发生，并且我希望文件时间高于上一次比较。 （该块通过 wx.CallLater 函数每秒运行一次）。

我的程序仍然失败......而且我无法理解我哪里出错了......请有人帮忙！或者有没有办法简单地检查文件是否停止写入？

Answer 1

我们可以尝试通过执行以下操作来检查文件大小的变化作为可能的解决方案：

import os
from time import sleep
# other imports

while True:
    file1 = os.stat('file.txt') # initial file size
    file1_size = file1.st_size
 
    # your script here that collects and writes data (increase file size)
    sleep(1)
    file2 = os.stat('file.txt') # updated file size
    file2_size = file2.st_size
    comp = file2_size - file1_size # compares sizes
    if comp == 0:
        restart_program()
    else:
        sleep(5)

您可能需要相应地调整sleep() 函数，这些只是我正在使用的估计值，因为我无法测试您的实际代码。最后，这是一个无限循环，只要您希望脚本继续编写，它就会一直运行。

另一种解决方案是将您的代码更新为：

import os
import sys
from time import sleep
# other imports

while True:
    file1 = os.stat('file.txt') # initial file size
    file1_size = file1.st_size
 
    # your script here that collects and writes data (increase file size)
    sleep(1)
    file2 = os.stat('file.txt') # updated file size
    file2_size = file2.st_size
    comp = file2_size - file1_size # compares sizes
    if comp == 0:
        sys.exit
    else:
        sleep(5)

然后使用辅助程序来运行您的脚本：

import os
from time import sleep, strftime

while True:
    print(strftime("%H:%M:%S"), "Starting"))
    system('main.py') # this is another infinite loop that will keep your script running
    print(strftime("%H:%M:%S"), "Crashed"))
    sleep(5)

Answer 2

要确定文件是否在 GUI 程序中按时更改，您可以使用事件循环的标准工具，每隔间隔秒运行一个函数，例如，tkinter 中的操作方法如下：

#!/usr/bin/env python3
import logging
import os
import sys
import tkinter
from datetime import datetime
from time import monotonic as timer, localtime

path = sys.argv[1]
interval = 120 # check every 2 minutes

def check(last=[None]):
    mtime = os.path.getmtime(path) # or os.path.getsize(path)
    logging.debug("mtime %s", datetime.fromtimestamp(mtime))
    if last[0] == mtime: #NOTE: it is always False on the first run
        logging.error("file metadata hasn't been updated, exiting..")
        root.destroy() # exit GUI
    else: # schedule the next run
        last[0] = mtime
        root.after(round(1000 * (interval - timer() % interval)), check)


logging.basicConfig(level=logging.DEBUG,
                    filename=os.path.splitext(__file__)[0] + ".log",
                    format="%(asctime)-15s %(message)s", datefmt="%F %T")
root = tkinter.Tk()
root.withdraw() # hide GUI
root.after(round(1000 * (interval - timer() % interval)), check) # start on boundary
root.mainloop()

您可以使用 supervisord、systemd 或 upstart 等来自动重生您的脚本。

见How to run a function periodically in python。

Answer 3

最后，在修改了基于时间戳的选项之后，以下似乎对我有用。

try:
    if time.time()-os.stat(filename).st_mtime>6:
        touch(filename)
        raise ValueError("Yikes! Spike")
except ValueError:
    with open('errors.log','a') as log:
        log.write('Spike/App restarting occured at '+ time.strftime(
                "%H:%M:%S")+' on '+datetime.date.today().strftime('%d/%m/%Y')+'\n')
        log.close()
    restart_program()

之前的问题是它会检测到文件在给定的时间间隔内停止写入并继续满足相同的要求。

time.time()-os.stat(filename).st_mtime>6 

但是一旦满足这个条件，除非文件时间戳被更新，否则它会继续满足这个条件并且会不断重启程序。现在在我的解决方案中，我“触摸”了一次文件 (touch used from here)，条件得到满足，现在它可以按预期工作了。

感谢大家的投入。