apscheduler 的基本介绍和使用

  • Post author:
  • Post category:其他


APScheduler有四大组件:

1、触发器 triggers :

触发器包含调度逻辑。每个作业都有自己的触发器,用于确定下一个任务何时运行。除了初始配置之外,触发器是完全无状态的。

有三种内建的trigger:

(1)date: 特定的时间点触发

(2)interval: 固定时间间隔触发

(3)cron: 在特定时间周期性地触发

2、任务储存器 job stores:用于存放任务,把任务存放在内存(为默认MemoryJobStore)或数据库中。

3、执行器 executors: 执行器是将任务提交到线程池或进程池中运行,当任务完成时,执行器通知调度器触发相应的事件。

4、调度器 schedulers: 把上方三个组件作为参数,通过创建调度器实例来运行

根据开发需求选择相应的组件,下面是不同的调度器组件:

BlockingScheduler 阻塞式调度器:适用于只跑调度器的程序。

BackgroundScheduler 后台调度器:适用于非阻塞的情况,调度器会在后台独立运行。

AsyncIOScheduler AsyncIO调度器,适用于应用使用AsnycIO的情况。

GeventScheduler Gevent调度器,适用于应用通过Gevent的情况。

TornadoScheduler Tornado调度器,适用于构建Tornado应用。

TwistedScheduler Twisted调度器,适用于构建Twisted应用。

QtScheduler Qt调度器,适用于构建Qt应用。

做一个小练习:

(date 特定一个时间叫他来触发)

from datetime import datetime

from datetime import date

from apscheduler.schedulers.blocking import BlockingScheduler

def job(text):

print(text)

scheduler = BlockingScheduler(timezone=’Asia/Shanghai’)

# 在 2023-3-5 运行一次 job 方法

scheduler.add_job(job, ‘date’, run_date=date(2023, 3, 5, ), args=[‘text1’])

# 在 2023-3-5 19:22:15 运行一次 job 方法

scheduler.add_job(job, ‘date’, run_date=datetime(2023,3,5 ,19,22,15), args=[‘text2’])

scheduler.start()



版权声明:本文为sdsdvsdvs原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。