Python定时任务apscheduler的详细使用教程

什么是apscheduler

apscheduler是一个Python的任务调度库，可以用来执行定时任务和周期任务，支持多种任务触发器（如日期、时间间隔、文件修改、网络地址等），可以很好的满足各种任务调度的需求。

怎么安装apscheduler

可以使用pip进行安装。

pip install apscheduler

也可以从GitHub仓库下载源码进行安装。

git clone https://github.com/agronholm/apscheduler.git
cd apscheduler
python setup.py install

怎么使用apscheduler

定时任务的基本使用

定时任务最基本的使用方式是定义一个任务函数，然后使用apscheduler中的Scheduler进行定时触发。以下是一个简单的示例：

from apscheduler.schedulers.blocking import BlockingScheduler

def job_function():
    print("Hello World")

if __name__ == '__main__':
    scheduler = BlockingScheduler()
    # 每隔5秒执行一次job_function
    scheduler.add_job(job_function, 'interval', seconds=5)
    scheduler.start()

在上述示例中，我们定义了一个job_function函数，该函数会输出“Hello World”，然后使用BlockingScheduler创建了一个scheduler对象，并在scheduler对象中添加了一个任务。该任务使用interval触发器，每隔5秒执行一次job_function函数。

APSeduler还支持其他的触发器，例如：

date：只在指定的时间点执行一次任务
cron：类似于Unix Cron表达式
interval：基于时间间隔执行任务
...等等

详细的触发器使用方式可以在官方文档中查阅。

任务的持久化

调用APSeduler的shutdown()方法会用当前正在运行的调度程序终止所有调度程序并清除所有未来的计划。如果你不想这样做，而是在下次启动时恢复计划，可以使用持久化作业存储区。以下是一个简单的使用SQLite作为存储区的示例：

from apscheduler.schedulers.blocking import BlockingScheduler
from apscheduler.jobstores.sqlalchemy import SQLAlchemyJobStore

def job_function():
    print("Hello World")

if __name__ == '__main__':
    # 创建持久化存储区
    jobstore = SQLAlchemyJobStore(url="sqlite:///jobs.sqlite")
    scheduler = BlockingScheduler(jobstores={"default": jobstore})
    # 每隔5秒执行一次job_function
    scheduler.add_job(job_function, 'interval', seconds=5)
    scheduler.start()

在上述示例中，我们创建了一个SQLAlchemyJobStore作为存储区，并将其传递给BlockingScheduler。每个作业存储区必须有一个唯一的名称，这里我们将其命名为“default”。