python apscheduler一次只有一个job_Python使用APScheduler实现定时任务过程解析
前言
APScheduler是基于Quartz的一个Python定时任务框架。提供了基于日期、固定时间间隔以及crontab类型的任务,并且可以持久化任务。
一、安装APScheduler
pip install apscheduler
二、基本概念
APScheduler有四大组件:
1、触发器 triggers :
触发器包含调度逻辑。每个作业都有自己的触发器,用于确定下一个任务何时运行。除了初始配置之外,触发器是完全无状态的。
有三种内建的trigger:
(1)date: 特定的时间点触发
(2)interval: 固定时间间隔触发
(3)cron: 在特定时间周期性地触发
2、任务储存器 job stores:用于存放任务,把任务存放在内存(为默认MemoryJobStore)或数据库中。
3、执行器 executors: 执行器是将任务提交到线程池或进程池中运行,当任务完成时,执行器通知调度器触发相应的事件。
4、调度器 schedulers: 把上方三个组件作为参数,通过创建调度器实例来运行
根据开发需求选择相应的组件,下面是不同的调度器组件:
BlockingScheduler 阻塞式调度器:适用于只跑调度器的程序。
BackgroundScheduler 后台调度器:适用于非阻塞的情况,调度器会在后台独立运行。
AsyncIOScheduler AsyncIO调度器,适用于应用使用AsnycIO的情况。
GeventScheduler Gevent调度器,适用于应用通过Gevent的情况。
TornadoScheduler Tornado调度器,适用于构建Tornado应用。
TwistedScheduler Twisted调度器,适用于构建Twisted应用。
QtScheduler Qt调度器,适用于构建Qt应用。
三、使用步骤
1、新建一个调度器schedulers
2、添加调度任务
3、运行调度任务
四、使用实例
1、触发器date
特定的时间点触发,只执行一次。参数如下:
参数
说明
run_date (datetime 或 str)
作业的运行日期或时间
timezone (datetime.tzinfo 或 str)
指定时区
使用例子:
from datetime import datetime
from datetime import date
from apscheduler.schedulers.blocking import BlockingScheduler
def job(text):
print(text)
scheduler = BlockingScheduler()
# 在 2019-8-30 运行一次 job 方法
scheduler.add_job(job, 'date', run_date=date(2019, 8, 30), args=['text1'])
# 在 2019-8-30 01:00:00 运行一次 job 方法
scheduler.add_job(job, 'date', run_date=datetime(2019, 8, 30, 1, 0, 0), args=['text2'])
# 在 2019-8-30 01:00:01 运行一次 job 方法
scheduler.add_job(job, 'date', run_date='2019-8-30 01:00:00', args=['text3'])
scheduler.start()
2、触发器interval
固定时间间隔触发。参数如下:
参数
说明
weeks (int)
间隔几周
days (int)
间隔几天
hours (int)
间隔几小时
minutes (int)
间隔几分钟
seconds (int)
间隔多少秒
start_date (datetime 或 str)
开始日期
end_date (datetime 或 str)
结束日期
timezone (datetime.tzinfo 或str)
使用例子:
import time
from apscheduler.schedulers.blocking import BlockingScheduler
def job(text):
t = time.strftime('%Y-%m-%d %H:%M:%S', time.localtime(time.time()))
print('{} --- {}'.format(text, t))
scheduler = BlockingScheduler()
# 每隔 1分钟 运行一次 job 方法
scheduler.add_job(job, 'interval', minutes=1, args=['job1'])
# 在 2019-08-29 22:15:00至2019-08-29 22:17:00期间,每隔1分30秒 运行一次 job 方法
scheduler.add_job(job, 'interval', minutes=1, seconds = 30, start_date='2019-08-29 22:15:00', end_date='2019-08-29 22:17:00', args=['job2'])
scheduler.start()
'''
运行结果:
job2 --- 2019-08-29 22:15:00
job1 --- 2019-08-29 22:15:46
job2 --- 2019-08-29 22:16:30
job1 --- 2019-08-29 22:16:46
job1 --- 2019-08-29 22:17:46
...余下省略...
'''
3、触发器cron
在特定时间周期性地触发。参数如下:
参数
说明
year (int 或 str)
年,4位数字
month (int 或 str)
月 (范围1-12)
day (int 或 str)
日 (范围1-31)
week (int 或 str)
周 (范围1-53)
day_of_week (int 或 str)
周内第几天或者星期几 (范围0-6 或者 mon,tue,wed,thu,fri,sat,sun)
hour (int 或 str)
时 (范围0-23)
minute (int 或 str)
分 (范围0-59)
second (int 或 str)
秒 (范围0-59)
start_date (datetime 或 str)
最早开始日期(包含)
end_date (datetime 或 str)
最晚结束时间(包含)
timezone (datetime.tzinfo 或str)
指定时区
这些参数支持算数表达式,取值格式有如下:
使用例子:
import time
from apscheduler.schedulers.blocking import BlockingScheduler
def job(text):
t = time.strftime('%Y-%m-%d %H:%M:%S', time.localtime(time.time()))
print('{} --- {}'.format(text, t))
scheduler = BlockingScheduler()
# 在每天22点,每隔 1分钟 运行一次 job 方法
scheduler.add_job(job, 'cron', hour=22, minute='*/1', args=['job1'])
# 在每天22和23点的25分,运行一次 job 方法
scheduler.add_job(job, 'cron', hour='22-23', minute='25', args=['job2'])
scheduler.start()
'''
运行结果:
job1 --- 2019-08-29 22:25:00
job2 --- 2019-08-29 22:25:00
job1 --- 2019-08-29 22:26:00
job1 --- 2019-08-29 22:27:00
...余下省略...
'''
4、通过装饰器scheduled_job()添加方法
添加任务的方法有两种:
(1)通过调用add_job()---见上面1至3代码
(2)通过装饰器scheduled_job():
第一种方法是最常用的方法。第二种方法主要是方便地声明在应用程序运行时不会更改的任务。该 add_job()方法返回一个apscheduler.job.Job实例,可以使用该实例稍后修改或删除该任务。
import time
from apscheduler.schedulers.blocking import BlockingScheduler
scheduler = BlockingScheduler()
@scheduler.scheduled_job('interval', seconds=5)
def job1():
t = time.strftime('%Y-%m-%d %H:%M:%S', time.localtime(time.time()))
print('job1 --- {}'.format(t))
@scheduler.scheduled_job('cron', second='*/7')
def job2():
t = time.strftime('%Y-%m-%d %H:%M:%S', time.localtime(time.time()))
print('job2 --- {}'.format(t))
scheduler.start()
'''
运行结果:
job2 --- 2019-08-29 22:36:35
job1 --- 2019-08-29 22:36:37
job2 --- 2019-08-29 22:36:42
job1 --- 2019-08-29 22:36:42
job1 --- 2019-08-29 22:36:47
job2 --- 2019-08-29 22:36:49
...余下省略...
'''
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持脚本之家。
python apscheduler一次只有一个job_Python使用APScheduler实现定时任务过程解析相关推荐
- python图片相似度计算_python Opencv计算图像相似度过程解析
这篇文章主要介绍了python Opencv计算图像相似度过程解析,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下 一.相关概念 一般我们人区分谁是谁 ...
- python爬虫教程:爬取破解无线网络wifi密码过程解析
这篇文章主要介绍了Python爬取破解无线网络密码过程解析,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下 前言 今天从WiFi连接的原理,再结合代码 ...
- python爬取bilibili弹幕_Python爬虫爬取Bilibili弹幕过程解析
先来思考一个问题,B站一个视频的弹幕最多会有多少? 比较多的会有2000条吧,这么多数据,B站肯定是不会直接把弹幕和这个视频绑在一起的. 也就是说,有一个视频地址为https://www.bilibi ...
- python 文字转语音 带情感_python文字转语音实现过程解析
这篇文章主要介绍了python文字转语音实现过程解析,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下 使用百度接口 接口地址https://ai.ba ...
- python读取文件名写入excel_Python实现读取并写入Excel文件过程解析
需求是有两个Excel文件:1.xlsx,2.xlsx,比较2.xlsx中的A,B列和1.xlsx中的A,B列:查找1.xlsx中存在,2.xlsx中不存在的行数据,输出到result.xlsx文件中 ...
- 汉诺塔python执行流程_hannoi塔(汉诺塔)移动过程解析
来源 汉诺塔是来源于印度的一种古老的益智游戏.它总共有三根柱子,分别为A,B,C.初始状态下,A柱中有N个盘子,这N个盘子有大有小,大的在下面,小的在上面.游戏的最终目标就是将A柱上的所有盘子移到C柱 ...
- python怎么切换中文键盘_python模拟键盘输入 切换键盘布局过程解析
PostMessage() def keyHwnd(hwndEx, char): """ 向指定控件输入值 :param hwndEx: 控件句柄 :param char ...
- python编程读取写入excel_Python实现读取并写入Excel文件过程解析
需求是有两个Excel文件:1.xlsx,2.xlsx,比较2.xlsx中的A,B列和1.xlsx中的A,B列:查找1.xlsx中存在,2.xlsx中不存在的行数据,输出到result.xlsx文件中 ...
- python 删除list 里面的一个空集合
python 删除list 里面的一个空集合 与 删除list 里面的一个空元素方法一样 我们可以把空集合当成一个空元素具体操作如下 list_a = [["1", "2 ...
最新文章
- 花5分钟过一遍jar包和war包的区别,以后都不会再迷茫
- 2019黑龙江省赛总结
- 重新安装mysql5.7.21_linux 安装mysql 5.7.21详解以及安装过程中所遇问题解决
- sts 创建webservice项目_常用的RPC架构---WebService
- 大数据将如何重构汽车产业的商业模式?
- 关于计算机优点缺点的英语作文,跪求一篇英语作文 题目:论计算机的优缺点...
- cad画圆如何确定圆心_CAD如何利用对象捕捉追踪功能来确定小圆圆心以及矩形的角点位置...
- 美国电脑富农:Frank Soltis
- 放弃VMware改投VirtualBox的五个理由
- 解决问题:cv::Exception,位于内存位置 0x000000D2956FE120 处
- C#取得DataTable最大值、最小值
- SSM+人才交流平台 毕业设计-附源码221022
- 微信小程序组件、web-view、h5之间交互
- TIPTOP 4GL——自定义按钮前加图标
- Python NumPy 基础:数组和向量计算
- windows下qemu的安装与设置环境变量
- python表情怎么打出来_python 获取搜狗输入法里面所有的表情图片
- 耀耀学院task1-task3练习总结
- Future 用法详解
- javaScript设计模式-创建型设计模式