当前位置 : 主页 > 编程语言 > python >

python apscheduler 定时任务细节问题

来源:互联网 收集:自由互联 发布时间:2022-07-13
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


上一篇:python 生成time时间戳 (10位和13位)
下一篇:没有了
网友评论