Python定时任务APScheduler安装及使用解析
1、简介
APScheduler是一个Python定时任务框架,使用起来十分方便。提供了基于日期、固定时间间隔以及crontab类型的任务,并且可以持久化任务、并以daemon方式运行应用。
2、APScheduler四个组件
APScheduler四个组件分别为:触发器(trigger),作业存储(jobstore),执行器(executor),调度器(scheduler)。
触发器(trigger)
包含调度逻辑,每一个作业有它自己的触发器,用于决定接下来哪一个作业会运行。除了他们自己初始配置意外,触发器完全是无状态的
APScheduler有三种内建的trigger:
- date:特定的时间点触发
- interval:固定时间间隔触发
- cron:在特定时间周期性地触发
作业存储(jobstore)
存储被调度的作业,默认的作业存储是简单地把作业保存在内存中,其他的作业存储是将作业保存在数据库中。一个作业的数据讲在保存在持久化作业存储时被序列化,并在加载时被反序列化。调度器不能分享同一个作业存储。
APScheduler默认使用MemoryJobStore,可以修改使用DB存储方案
执行器(executor)
处理作业的运行,他们通常通过在作业中提交制定的可调用对象到一个线程或者进城池来进行。当作业完成时,执行器将会通知调度器。
最常用的executor有两种:
- ProcessPoolExecutor
- ThreadPoolExecutor
调度器(scheduler)
通常在应用中只有一个调度器,应用的开发者通常不会直接处理作业存储、调度器和触发器,相反,调度器提供了处理这些的合适的接口。配置作业存储和执行器可以在调度器中完成,例如添加、修改和移除作业
2、安装
$pipinstallapscheduler
接下来我们看下简单的几个示例:
===============interval:固定时间间隔触发=============== fromapscheduler.schedulers.blockingimportBlockingScheduler fromdatetimeimportdatetime defjob(): print(datetime.now().strftime("%Y-%m-%d%H:%M:%S")) #定义BlockingScheduler sched=BlockingScheduler() sched.add_job(job,'interval',seconds=5) sched.start()
===============cron:特定时间周期性地触发=============== importtime fromapscheduler.schedulers.blockingimportBlockingScheduler defjob(text): t=time.strftime('%Y-%m-%d%H:%M:%S',time.localtime(time.time())) print('{}---{}'.format(text,t)) scheduler=BlockingScheduler() #在每天22点,每隔1分钟运行一次job方法 scheduler.add_job(job,'cron',hour=17,minute='*/1',args=['job1']) #在每天22和23点的25分,运行一次job方法 scheduler.add_job(job,'cron',hour='22-23',minute='25',args=['job2']) scheduler.start()
通过装饰器scheduled_job()添加方法
importtime fromapscheduler.schedulers.blockingimportBlockingScheduler scheduler=BlockingScheduler() @scheduler.scheduled_job('interval',seconds=5) defjob1(): t=time.strftime('%Y-%m-%d%H:%M:%S',time.localtime(time.time())) print('job1---{}'.format(t)) @scheduler.scheduled_job('cron',second='*/7') defjob2(): t=time.strftime('%Y-%m-%d%H:%M:%S',time.localtime(time.time())) print('job2---{}'.format(t)) scheduler.start()
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持毛票票。