1. 定义全局变量scheduler # 全局 import apscheduler . scheduler . background import BackgroundScheduler scheduler = BackgroundScheduler () scheduler . start () 2. 问题 2.1 在定时任务正常执行过程中,如果服务挂掉了,
1. 定义全局变量scheduler
# 全局import apscheduler.scheduler.background import BackgroundScheduler
scheduler = BackgroundScheduler()
scheduler.start()
2. 问题
2.1 在定时任务正常执行过程中,如果服务挂掉了,下次再次启动时,前面next_run_time时间点执行的任务不会被执行了,更新next_run_time为当前最新执行的时间
def scheduler_task():param = {"trigger": "cron", "hour": "11", "minute": "30,31,32,34,35,36"}
scheduler.add_job(id="abcdefg", func=run_test, **param)
def run_test():
print(111)
当我在启动服务后,在31分关掉服务,35分再次启动服务,结果为:
Run time of job "run_test" (trigger: cron[hour='1', minute='30,31,32,34,35,36']), next run at : 2021-05-19 11:32:00 was missed by 0:01:52.544810# 在2021-05-19 11:36:00的时候,才执行
print(111)
2.2 当定时任务设置了start_date和end_date时,服务器挂掉了,现在时间超过了end_date,再次启动时,会把定时任务remove
def scheduler_task():param = {"trigger": "cron", "hour": "11", "minute": "30,31,32,34,35,36", "start_date": "2021-05-19 11:00:00", "end_date": "2021-05-19 11:40:00"}
scheduler.add_job(id="abcdefg", func=run_test, **param)
def run_test():
print(111)
当我正常启动服务,在11:35的时候停掉服务,在11:50的时候开启服务,则会出现:
会把已经需要结束的定时任务移除remove abcdefg