python中定时任务apscheduler库用法详解

时间:2022-10-17 19:48:33 作者:快盘下载人气:

1、APScheduler简介

APScheduler是Python的一个定时任务框架;用于执行周期或者定时任务;该框架不仅可以添加、删除定时任务;还可以将任务存储到数据库中;实现任务的持久化;使用起来非常方便。

APscheduler全称Advanced Python Scheduler;作用为在指定的时间规则执行指定的作业;其是基于Quartz的一个Python定时任务框架;实现了Quartz的所有功能;使用起来十分方便。提供了基于日期、固定时间间隔以及crontab类型的任务;并且可以持久化任务。

2、APScheduler库安装

首先安装apscheduler库;

pip install apscheduler

 
 
3、APScheduler组成 
触发器(trigger);包含调度逻辑;每一个作业有它自己的触发器;用于决定接下来哪一个作业会运行。除了他们自己初始配置以外;触发器完全是无状态的。
作业存储(job store);存储被调度的作业;默认的作业存储是简单地把作业保存在内存中;其他的作业存储是将作业保存在数据库中。一个作业的数据将在保存在持久化作业存储时被序列化;并在加载时被反序列化。调度器不能分享同一个作业存储。
执行器(executor);处理作业的运行;他们通常通过在作业中提交制定的可调用对象到一个线程或者进城池来进行。当作业完成时;执行器将会通知调度器。
调度器(scheduler);其他的组成部分。通常在应用只有一个调度器;应用的开发者通常不会直接处理作业存储、调度器和触发器;相反;调度器提供了处理这些的合适的接口。配置作业存储和执行器可以在调度器中完成;例如添加、修改和移除作业。
3.1 触发器(trigger) 
未完待续。。。 
示例代码; 
from datetime import datetime
from apscheduler.schedulers.blocking import BlockingScheduler


def task():
    now = datetime.now()
    ts = now.strftime(%Y-%m-%d %H:%M:%S;)
    print(ts)


def task2():
    now = datetime.now()
    ts = now.strftime(%Y-%m-%d %H:%M:%S;)
    print(ts ; ;666!;)


def func():
    # 创建调度器BlockingScheduler()
    scheduler = BlockingScheduler()
    scheduler.add_job(task, ;interval;, seconds=3, id=;test_job1;)
    # 添加任务;时间间隔为5秒
    scheduler.add_job(task2, ;interval;, seconds=5, id=;test_job2;)
    scheduler.start()


func()
 
运行结果; 
 
参考博文; Python定时任务框架APScheduler详解_Yunlord的博客-CSDN博客_apscheduler


  
  加载全部内容