Python定时任务（下）

Photo from Unsplash

上篇文章，我们了解到有三种办法能实现定时任务，但是都无法做到循环执行定时任务。因此，需要一个能够担当此重任的库。它就是APScheduler。

1 简介

APScheduler的全称是Advanced Python Scheduler。它是一个轻量级的 Python 定时任务调度框架。APScheduler 支持三种调度任务：固定时间间隔，固定时间点（日期），Linux 下的 Crontab 命令。同时，它还支持异步执行、后台执行调度任务。

2 安装

使用 pip 包管理工具安装 APScheduler 是最方便快捷的。

3 使用步骤

APScheduler 使用起来还算是比较简单。运行一个调度任务只需要以下三部曲。

1) 新建一个 schedulers (调度器) 。

2) 添加一个调度任务(job stores)。

3) 运行调度任务。

下面是执行每 2 秒报时的简单示例代码：

4 基础组件

APScheduler 有四种组件，分别是：调度器(scheduler)，作业存储(job store)，触发器(trigger)，执行器(executor)。

schedulers（调度器）

它是任务调度器，属于控制器角色。它配置作业存储器和执行器可以在调度器中完成，例如添加、修改和移除作业。

triggers（触发器）

描述调度任务被触发的条件。不过触发器完全是无状态的。

job stores（作业存储器）

任务持久化仓库，默认保存任务在内存中，也可将任务保存都各种数据库中，任务中的数据序列化后保存到持久化数据库，从数据库加载后又反序列化。

executors（执行器）

负责处理作业的运行，它们通常通过在作业中提交指定的可调用对象到一个线程或者进城池来进行。当作业完成时，执行器将会通知调度器。

4.1 schedulers（调度器）

我个人觉得 APScheduler 非常好用的原因。它提供 7 种调度器，能够满足我们各种场景的需要。例如：后台执行某个操作，异步执行操作等。调度器分别是：

BlockingScheduler ：调度器在当前进程的主线程中运行，也就是会阻塞当前线程。

BackgroundScheduler ：调度器在后台线程中运行，不会阻塞当前线程。

AsyncIOScheduler ：结合asyncio模块（一个异步框架）一起使用。

GeventScheduler ： 程序中使用gevent（高性能的Python并发框架）作为 IO 模型，和GeventExecutor配合使用。

TornadoScheduler ：程序中使用Tornado（一个web框架）的IO模型，用ioloop.add_timeout完成定时唤醒。

TwistedScheduler ： 配合TwistedExecutor，用reactor.callLater完成定时唤醒。

QtScheduler ： 你的应用是一个 Qt 应用，需使用 QTimer 完成定时唤醒。

4.2 triggers（触发器）

APScheduler 有三种内建的 trigger:

1）date 触发器

date 是最基本的一种调度，作业任务只会执行一次。它表示特定的时间点触发。它的参数如下：

date 触发器使用示例如下：

2）interval 触发器

固定时间间隔触发。interval 间隔调度，参数如下：

interval 触发器使用示例如下：

3）cron 触发器

在特定时间周期性地触发，和Linux crontab格式兼容。它是功能最强大的触发器。

我们先了解 cron 参数：

这些参数是支持表算数达式，取值格式有如下：

cron 触发器使用示例如下：

4.3 作业存储(job store)

该组件是对调度任务的管理。

1）添加 job

有两种添加方法，其中一种上述代码用到的add_job()， 另一种则是scheduled_job()修饰器来修饰函数。

这个两种办法的区别是：第一种方法返回一个 apscheduler.job.Job 的实例，可以用来改变或者移除 job。第二种方法只适用于应用运行期间不会改变的 job。

第二种添加任务方式的例子：

2）移除 job

移除 job 也有两种方法：remove_job()和job.remove()。

remove_job() 是根据 job 的 id 来移除，所以要在 job 创建的时候指定一个 id。

job.remove() 则是对 job 执行 remove 方法即可。

3）获取 job 列表

通过scheduler.get_jobs()方法能够获取当前调度器中的所有 job 的列表

4) 修改 job

如果你因计划改变要对 job 进行修改，可以使用job.modify()或者modify_job()方法来修改 job 的属性。但是值得注意的是，job 的 id 是无法被修改的。

5）关闭 job

默认情况下调度器会等待所有正在运行的作业完成后，关闭所有的调度器和作业存储。如果你不想等待，可以将 wait 选项设置为 False。

4.4 执行器(executor)

执行器顾名思义是执行调度任务的模块。最常用的 executor 有两种：ProcessPoolExecutor和ThreadPoolExecutor

下面是显式设置 job store(使用mongo存储)和 executor 的代码的示例。

注：本代码来源于网络。

END

作者：猴哥

公众号：极客猴

爱好读书，喜欢钻研技术，梦想成为文艺青年的 boy。