这是我参加11月更文挑战的第5天，活动概况查看：2021终究一次更文挑战

咱们好，我是米洛，正在打造一个能用版测验渠道。求点赞!求重视!求分享！

项目地址: pity.readthedocs.io/

重视公众号: 米洛的测开日记，让咱们进一步交流。

回忆

上一节咱们调研了一下市面上的守时使命方案，终究确定为APScheduler，但据说在uvicorn下还有一些坑。

没关系，笔者也是在探索阶段。假如有遇到问题，解决了也能够给咱们参阅。

这篇主要给咱们介绍一下APScheduler的根本信息和运用办法。

四个名词

测试平台系列(72) 了解ApScheduler基本用法

  • 触发器: 守时使命什么时分触发
  • 作业商店: 守时使命存在哪里，内存？MySQL?Redis?
  • 履行器: 履行使命的程序
  • 调度程序: 不同使命之间的调度管理程序，还包含使命的增加和修正等

存储介质

在上一节咱们提到了守时使命耐久化。

那么在APScheduler中支撑哪些存储介质呢？看一张图:

测试平台系列(72) 了解ApScheduler基本用法

能够看到，它支撑多种介质，包含咱们最不愿意用的memory(内存)。因为假如服务重启，数据就都没了，所以咱们不考虑运用这个。

  • SQLAlchemy

    这是咱们常用的办法，通过它能够写入到mysql，在不引进其他组件的状况下完全能够考虑。

  • MongoDB

    NoSQL的一种，比较方便，咱们秉着不额定增加组件的信仰，暂不考虑。

  • Redis

    redis后续咱们自身服务也需要用到，但把它作为一个”数据库“来运用，还得考虑redis备份等状况，当然长处便是会比mysql更快。

    至于其他的zk，rethinkdb，因为咱们暂时也不会引用，所以不分析了。

    综合而言，还是用SQLAlchemy价值最小，本钱最低。

运行形式

在运行demo的过程中，发现APScheduler很强壮，能够支撑各种并发形式。

测试平台系列(72) 了解ApScheduler基本用法

因为咱们是异步Asycio，所以咱们挑选第三种履行器。其他的包含Gevent等也是Flask/Django等框架的好挑选。

了解根本API

  • 装备scheduler
from apscheduler.jobstores.sqlalchemy import SQLAlchemyJobStore
from apscheduler.schedulers.asyncio import AsyncIOScheduler
# 挑选job存储介质为sqlalchemy
job_store = {
    'default': SQLAlchemyJobStore(url=Config.SQLALCHEMY_DATABASE_URI)
}
# 挑选调度程序为AsyncIOScheduler
scheduler = AsyncIOScheduler()
# 装备好对应的程序
scheduler.configure(jobstores=job_store)
# 发动
scheduler.start()
  • 增加job
# 把办法: myfunc增加到守时使命，每2分钟履行一次
scheduler.add_job(myfunc, 'interval', minutes=2, id='my_job_id')

与pity结合

在FastApi中，有个startup的钩子办法，意味着当服务发动的时分会主动履行该办法。咱们来看看怎样用的:

测试平台系列(72) 了解ApScheduler基本用法

@pity.on_event意思是监听事情，后边的参数: “startup”代表pity服务发动。

也便是说，当pity发动的时分，则初始化Scheduler。

这儿我封装了一个Scheduler类，后边会给咱们介绍里边的具体办法。

下一节咱们编写测验计划相关接口，并与APScheduler结合起来，完结一整套守时使命功用。