当前位置: 首页 > news >正文

flask-apscheduler实现定时任务

秋风阁-北溪入江流
flask-apscheduler是一个支持apscheduler的flask插件,通过flask-apscheduler可以很方便的定义定时任务。

安装flask-apscheduler

pip install flask-apscheduler

flask-apscheduler组件

apscheduler库包含有组件:

  • triggers(触发器)
  • job stores(作业存储)
  • executors(执行者)
  • schedulers(调度程序)

triggers触发器

在apscheduler中将一个定时任务称为job作业,在设置job时,需要为其选择特点的触发器。
触发器:确定作业运行时计算日期/时间的逻辑。
在apscheduler中具有以下三种内置的触发器类型:

  • date: 期望在某个时间点运行一次作业时使用该触发器
    • run_date: 运行作业的日期/时间,为空则使用当前时间
    • timezone: 时区
  • interval: 期望以固定的时间间隔运行作业时使用该触发器
    • weeks: 间隔的周数
    • days: 间隔的天数
    • hours: 间隔的小时数
    • minutes: 间隔的分钟数
    • seconds: 间隔的秒数
    • start_date: 间隔计算的起点。若指定则成指定时间开始,否则以当前时间开始。
    • end_date: 最晚可能触发的日期/时间
    • timezone: 时区
    • jitter: 最多延迟几秒执行
  • cron: 当想在特定时间定期运行作业时使用该触发器
    • year: 4位数年份
    • month: 月
    • day: 一个月中的某一天天
    • week: ISO周(1~31)
    • day_of_week: 工作日的数字或者名称(0~6或mon, tue, wed, thu, fri, sat, sun)
    • hour: 小时
    • minute: 分钟
    • second: 秒
    • start_date: 最早可能的触发时间。若指定则成指定时间开始,否则以当前时间开始。
    • end_date: 最晚可能触发的日期/时间
    • timezone: 时区
    • jitter: 最多延迟几秒执行

flask-apscheduler的使用

参数配置

特定于flask-apscheduler的配置选项

# 是否开启api查看定时任务的配置
# 设置为True后,可以通过SCHEDULER_API_PREFIX接口访问定时任务配置界面
SCHEDULER_API_ENABLED: bool (default: False)
# 设置访问查看定时任务配置的api接口
SCHEDULER_API_PREFIX: str (default: "/scheduler")
# 调度程序endpoint前缀
SCHEDULER_ENDPOINT_PREFIX: str (default: "scheduler.")
# 允许访问调度器的主机
SCHEDULER_ALLOWED_HOSTS: list (default: ["*"])

在测试定时任务时,建议将SCHEDULER_API_ENABLED设置为True,方便前端查看定时任务。
若开启api后访问接口后端报错KeyError: 'JSONIFY_PRETTYPRINT_REGULAR',可在配置中添加布尔类型的JSONIFY_PRETTYPRINT_REGULAR,值设置为TrueFalse都可以,设置为True仅会在前端界面以更美观的方式显示内容。

适用于apscheduler的配置选项

# 持久化配置
SCHEDULER_JOBSTORES: dict
# 执行器,线程池配置
SCHEDULER_EXECUTORS: dict
# 作业默认值配置
SCHEDULER_JOB_DEFAULTS: dict
# 时区设置
SCHEDULER_TIMEZONE: dict

定时任务设置方法

配置项设置定时任务

flask-apscheduler的定时任务在配置项中设置,通过字典保存作业的相关信息,多个作业时,在列表中进行作业的存储。

class SchedulerConfig:JSONIFY_PRETTYPRINT_REGULAR = TrueSCHEDULER_API_ENABLED = TrueJOBS = [{'id': 'job1',# func通过`模块名:方法名`的方式进行设置'func': 'run:add','args': (1, 2),'trigger': 'interval','seconds': 3}]

配置项设置的优点是配置麻烦,不直观,但是方便对定时任务进行统一管理

装饰器设置定时任务

在装饰器中设置定时任务,简单方便。

@scheduler.task('interval', id='job1', args=(1, 2), seconds=3)
def add(a, b):print(a + b)

完整示例与定时任务的启动

定时任务的执行需要先初始化一个执行程序,添加好配置和作业后,通过start()方法启动定时任务。

完整示例(以装饰器的方式为例)

import timefrom flask import Flask
from flask_apscheduler import APSchedulerapp = Flask(__name__)scheduler = APScheduler()start = time.time()@scheduler.task('interval', id='job1', seconds=3)
def print_interval():global startprint(f"间隔时间:{round(time.time() - start)}")start = time.time()class Config:JSONIFY_PRETTYPRINT_REGULAR = TrueSCHEDULER_API_ENABLED = Trueapp.config.from_object(Config)scheduler.init_app(app)print(scheduler.api_enabled)
scheduler.start()if __name__ == '__main__':app.run()

示例的执行结果如下所示:

间隔时间:3
间隔时间:3
间隔时间:3
...

可以看到每3秒进行了一次打印操作,完美的执行了期望的要求。

api查看

访问${SCHEDULER_API_PREFIX}/jobs接口:

[{"id": "job1","name": "print_interval","func": "__main__:print_interval","args": [],"kwargs": {},"trigger": "interval","start_date": "2023-07-11T12:09:49.057865+08:00","seconds": 3,"misfire_grace_time": 1,"max_instances": 1,"next_run_time": "2023-07-11T12:11:31.057865+08:00"}
]
http://www.lryc.cn/news/94689.html

相关文章:

  • FPGA纯verilog实现UDP协议栈,sgmii接口SFP光口收发,提供工程源码和技术支持
  • 【Python入门系列】第十五篇:Python数据可视化和图表绘制
  • isBlank函数和isEmpty函数的区别
  • 「SQL面试题库」 No_121 The Most Recent Three Orders
  • 【计算机视觉 | 目标检测 | 图像分割】arxiv 计算机视觉关于目标检测和图像分割的学术速递(7 月 7 日论文合集)
  • 直流运算放大器-----仪表放大器(三)
  • 【Zookeeper】终端操作常用命令
  • leetcode 1110. 删点成林
  • 华为Harmony应用开发初探
  • 电脑应用程序发生异常怎么办?
  • 【JAVA】准备工作------Java开发环境搭建,IDEA的基础设置与操作
  • 操作系统真象还原——第5章 保护模式进阶,向内核迈进
  • 设计一款助听器可能需要用到以下音频算法
  • 【端午节】用Vue3写粽子——从零开始
  • 大象机器人人工智能套装2023版深度学习协作机器人、先进机器视觉与应用场景
  • Cesium Token申请
  • ubuntu系统自带的Text Editor编辑器不高亮解决办法
  • Docker NGINX 加载Geoip模板
  • springboot基于协同过滤算法商品推荐系统
  • 基于机器学习算法:朴素贝叶斯和SVM 分类-垃圾邮件识别分类系统(含Python工程全源码)
  • 在Linux下将PNG和JPG批量互转的四种方法
  • Scala中使用 break 和 continue
  • 【全栈开发指南】打包sentinel-dashboard镜像推送到Docker Hub镜像仓库
  • 【数据可视化】SVG(一)
  • linux 系统errno 对应参考及代码
  • PowerShell快速ssh
  • 从php5.6到golang1.19-文库App性能跃迁之路
  • 成功解决 AttributeError: ‘Field‘ object has no attribute ‘vocab‘
  • ikbc键盘2.4G接收器丢失,重新对码
  • STM32 Proteus仿真医用仓库环境控制系统紫外线消毒RS232上传CO2 -0066