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