如何让调度程序进行硬刷新？

Question

我有一个从 SQL 数据库中检索记录的调度程序。查询是 100% 正确的，输出中的结果是 100% 特定的。但是问题是，当我更新或删除数据库中的某些记录时，它的输出与第一次运行时一样！我如何让调度程序像我停止它并再次运行它一样进行硬刷新？

此代码将运行调度程序并每 20 秒重复一次。当我在接下来的 20 秒内删除一条记录时，我需要它像第一次运行一样显示更新的输出。

@staticmethod
def add_scheduler_job():
    scheduler.app.apscheduler.add_job(
        func=StreamMonitor.report,
        trigger='interval',
        next_run_time=datetime.now(),
        seconds=20,
        max_instances=1000000,
        misfire_grace_time=1,
    )

我试图改变 misfire_grace_time 和 misfire_grace_time 但我没有得到任何改变:(

Answer 1

让调度程序只运行一次。在方法 StreamMonitor.report 中，添加一个在 20 秒后仅运行一次的新作业。这样每次运行都会像第一次运行一样。