一文详解Python定时任务触发
作者:处女座_三月 发布时间:2021-05-13 14:27:02
APScheduler
APScheduler 四个组件分别为:
调度器(scheduler)、触发器(trigger),作业存储(job store),执行器(executor)
安装命令:
pip install setuptools
pip install --ignore-installed apscheduler
1.新建调度器schedulers
BlockingScheduler : 调度器在当前进程的主线程中运行,也就是会阻塞当前线程
BackgroundScheduler : 调度器在后台线程中运行,不会阻塞当前线程
import datetime as dt
from apscheduler.schedulers.blocking import BlockingScheduler
scheduler = BlockingScheduler()
2.添加调度任务trigger
① date 触发器:(指定时间点触发),参数如下:
run_date(datetime或str):任务运行的日期或时间
timezone(datetime.tzinfo或str):指定时区
# 例1:在 2020-9-24 时刻运行一次 func 方法
scheduler.add_job(func, 'date', run_date = dt.date(2020, 9, 24))
# 例2: 在 2020-9-24 15:10:00 时刻运行一次 func 方法
scheduler.add_job(func, 'date', run_date = dt.datetime(2020, 9, 24, 15, 10, 0))
# 例3: 在 2020-9-24 15:11:00 时刻运行一次 func 方法
scheduler.add_job(func, 'date', run_date = '2020-9-24 15:11:00')
② interval 触发器: (固定时间间隔触发),参数如下:
weeks(int):间隔几周
days(int):间隔几天
hours(int):间隔几小时
minutes(int):间隔几分钟
seconds(int):间隔几秒钟
start_date(datetime或str):开始时间
end_date(datetime或str):结束时间
timezone(datetime.tzinfo或str):时区
# 例1:每隔两分钟执行一次 func 方法
scheduler.add_job(func, 'interval', minutes = 2)
# 例2:在 2020-9-24 15:15:00 ~ 2020-9-24 15:20:00 之间, 每隔两分钟执行一次 func 方法
scheduler.add_job(func, 'interval', minutes = 2, start_date = '2020-9-24 15:15:00' ,
end_date = '2020-9-24 15:20:00')
③ cron 触发器:(在指定时间周期性地触发),参数如下:
year(int 或 str):年
month(int 或 str):月
day(int 或 str):日
week(int 或 str):周(1-53)
day_of_week(int 或 str):星期几(0-6)
hour(int 或 str):时
minute(int 或 str):分
second(int 或 str):秒
start_date(datetime或str):最早开始时间(包含)
end_date(datetime或str):最晚结束时间(包含)
timezone(datetime.tzinfo或str):指定时区
字符 :
1. * 每一(每一分)
2. ? 表示不关心,任意
3. - 范围 (小时:1-12,1到12点运行)
4. , 标示多个值 (小时 1,2,3 1点2点3点运行)
5. / 递增触发(0/15,从0开始每15秒运行一次)
6. L 最后(日L,当月最后一天,周L周六)
7. W 指定日期最近的工作日(周一到周五)
8. # 序号(表示每月的第几个周几)
# 例:在每年 1-3、7-9 月份中的每个星期一、二中的 00:00, 01:00, 02:00 和 03:00 执行 func 任务
scheduler.add_job(func, 'cron', month = '1-3,7-9',day='0, tue', hour='0-3')
3.运行调度任务
scheduler.start()
3.1 测试时间
def forecast_adjust():
now_temp = datetime.now()
print('执行方案一', now_temp, '时间间隔: ', now_temp-t0)
def for2():
now_temp = datetime.now()
print('执行方案二', now_temp, '时间间隔: ', now_temp-t0)
def fortime3():
now_temp = datetime.now()
print('执行方案三', now_temp, '时间间隔: ', now_temp-t0)
return '9999999999999'
def a__():
b = scheduler.add_job(fortime3, 'cron', hour='15', minute = '18')
c = scheduler.add_job(fortime3, 'cron', hour='15', minute = '30')
d = scheduler.add_job(fortime3, 'cron', hour='15', minute = '45')
print(b)
print(c)
print(c)
return 'kkkqq'
t0 = datetime.now()
scheduler = BlockingScheduler() # 采用阻塞的方式
scheduler.add_job(func=forecast_adjust,
trigger=CronTrigger(minute="*/1", second=20,
timezone=tz_now), args=[])
scheduler.add_job(func=for2,
trigger=CronTrigger(minute="*/5", second=10,
timezone=tz_now), args=[])
k = a__()
print(k)
scheduler.start()
4.特点,其他操作
APScheduler 定点、定时:
四个组件分别为:触发器(trigger),作业存储器(job store),执行器(executor),调度器(scheduler)
(1)job stores:对调度任务的管理:
① 添加job:
# add_job():可以改变或者移除 job
scheduler.add_job(func, 'interval', minutes = 2)
# scheduled_job():只适用于应用运行期间不会改变的 job
scheduler.scheduled_job(func, 'interval', minutes = 2)
②移除job:
# remove_job() :根据 job 的 id 来移除,所以要在 job 创建的时候指定一个 id
scheduler.add_job(func, 'interval', minutes = 2, id = 'job_one')
scheduler.remove_job(job_one)
# job.remove() :对 job 执行 remove 方法
job = add_job(func, 'interval', minutes = 2, id = 'job_one')
job.remvoe()
③ 暂停job:
apscheduler.job.Job.pause()
apscheduler.schedulers.base.BaseScheduler.pause_job()
④ 恢复job:
apscheduler.job.Job.resume()
apscheduler.schedulers.base.BaseScheduler.resume_job()
⑤ 修改job:
# modify_job()
scheduler.modify_job('job_one', minutes = 5)
# job.modify()
job = scheduler.add_job(func, 'interval', minutes = 2)
job.modify(minutes = 5)
⑥ 关闭job:
scheduler.shutdown()
scheduler.shutdown(wait=false)
(2)executors:执行调度任务的模块,常用的 executor 有两种:
ProcessPoolExecutor
ThreadPoolExecutor
来源:https://blog.csdn.net/March_A/article/details/129826330
猜你喜欢
- 0.引言利用Dlib官方训练好的模型“shape_predictor_68_face_landmarks.dat”进行68点标定,利用Ope
- 本文实例讲述了Python实现将HTML转换成doc格式文件的方法。分享给大家供大家参考,具体如下:网页上的一些文章,因为有格式的原因,它们
- 去空格及特殊符号s.strip().lstrip().rstrip(',')Python strip() 方法用于移除字符串
- 一、概述前提:已安装 Python,如下图所示:1.1 检查是否已配置成功(选)1. 打开运行窗口 (1) 快捷键  
- QueryCache(下面简称QC)是根据SQL语句来cache的。一个SQL查询如果以select开头,那么MySQL服务器将尝试对其使
- 本文实例讲述了Python基于TCP实现会聊天的小机器人功能。分享给大家供大家参考,具体如下:一 代码1、服务端程序import socke
- 一、前言假设现在有一个应用场景,需要对文件系统进行监控,发生变化时产生日志,对新增的文件做一些相应的操作。比如说应用到我们之前的音乐高潮提取
- 现在很多朋友都不止一个账户,不止一个密码。忘记账户名、密码,或账户名、密码输入错误也就难免啦。每当这个时候,你是否和我一样会有小小的焦虑产生
- 本文实例为大家分享了python实现图书管理系统的具体代码,供大家参考,具体内容如下题目:写一个简单的图书借阅系统
- 首先要解释一下:“极致之美”不是说月儿的这篇文章,因为本人还没有自大到这种程度:P,它形容的是Lisp和javascript结合的优美形态。
- 本章所讲内容: 1、钉钉报警设置
- python 迭代器与生成器,装饰器迭代器对象从集合的第一个元素开始访问,直到所有的元素被访问完结束。迭代器有两个基本的方法:iter()
- 前言python下的setuptools带有一个easy_install的工具,在安装python的每三方模块、工具时很有用,也很方便。安装
- 研究了几天Adodb.stream和XMLHTTP的应用,找了不少很有趣的教程,下面的代码是将一个远程的页面,图片地址保存到本地的实例。将代
- django-mdeditorGithub地址:https://github.com/pylixm/django-mdeditor 欢迎试用
- 本篇文章通过调用opencv里的函数简单的实现了对图像里特定颜色提取与定位,以此为基础,我们可以实现对特定颜色物体的前景分割与定位,或者特定
- 概述全链接层 (Fully Connected Layer) 会把一个特质空间线性变换到另一个特质空间, 在整个网络中起到分类器的作用.ke
- 生活中有很多需要用到关联图的地方,至少我认为的是这样的图:https://www.echartsjs.com/examples/zh/edi
- wxPython是Python语言的一套优秀的GUI图形库。允许Python程序员很方便的创建完整的、功能键全的GUI用户界面。wxPyth
- 浏览器:IE ,不支持firefoxfilter视觉滤镜的种类:Alpha(透明度) Blur(模糊) Chroma(指定颜色透明) Dro