python- 进阶 与flask的搭配使用---定时任务框架APScheduler学习详解

APScheduler简介

在平常的工作中几乎有一半的功能模块都需要定时任务来推动,例如项目中有一个定时统计程序,定时爬出网站的URL程序,定时检测钓鱼网站的程序等等,都涉及到了关于定时任务的问题,第一时间想到的是利用time模块的time.sleep()方法使程序休眠来达到定时任务的目的,虽然这样也可以,但是总觉得不是那么的专业,^_^所以就找到了python的定时任务模块APScheduler:

APScheduler基于Quartz的一个Python定时任务框架,实现了Quartz的所有功能,使用起来十分方便。提供了基于日期、固定时间间隔以crontab类型的任务,并且可以持久化任务。基于这些功能,我们可以很方便的实现一个python定时任务系统

安装

1、利用pip进行安装

1

$ pip install apscheduler

2、源码安装(https://pypi.python.org/pypi/APScheduler/)

1

$ python setup.py install

APScheduler有四种组成部分:

触发器(trigger)包含调度逻辑,每一个作业有它自己的触发器,用于决定接下来哪一个作业会运行。除了他们自己初始配置意外,触发器完全是无状态的。

作业存储(job store)存储被调度的作业,默认的作业存储是简单地把作业保存在内存中,其他的作业存储是将作业保存在数据库中。一个作业的数据讲在保存在持久化作业存储时被序列化,并在加载时被反序列化。调度器不能分享同一个作业存储。

执行器(executor)处理作业的运行,他们通常通过在作业中提交制定的可调用对象到一个线程或者进城池来进行。当作业完成时,执行器将会通知调度器。

调度器(scheduler)是其他的组成部分。你通常在应用只有一个调度器,应用的开发者通常不会直接处理作业存储、调度器和触发器,相反,调度器提供了处理这些的合适的接口。配置作业存储和执行器可以在调度器中完成,例如添加、修改和移除作业。 

简单应用:

1

2

3

4

5

6

7

8

9

import time

from apscheduler.schedulers.blocking import BlockingScheduler

 

def my_job():

    print time.strftime('%Y-%m-%d %H:%M:%S', time.localtime(time.time()))

 

sched = BlockingScheduler()

sched.add_job(my_job, 'interval', seconds=5)

sched.start()

上面的例子表示每隔5s执行一次my_job函数,输出当前时间信息

操作作业

1. 添加作业

上面是通过add_job()来添加作业,另外还有一种方式是通过scheduled_job()修饰器来修饰函数

1

2

3

4

5

6

7

8

9

10

import time

from apscheduler.schedulers.blocking import BlockingScheduler

 

sched = BlockingScheduler()

 

@sched.scheduled_job('interval', seconds=5)

def my_job():

    print time.strftime('%Y-%m-%d %H:%M:%S', time.localtime(time.time()))

 

sched.start()

2. 移除作业

1

2

3

4

5

job = scheduler.add_job(myfunc, 'interval', minutes=2)

job.remove()

#如果有多个任务序列的话可以给每个任务设置ID号,可以根据ID号选择清除对象,且remove放到start前才有效

sched.add_job(myfunc, 'interval', minutes=2id='my_job_id')

sched.remove_job('my_job_id')

3. 暂停和恢复作业

 暂停作业:

1

2

apsched.job.Job.pause()

apsched.schedulers.base.BaseScheduler.pause_job()

 恢复作业:

1

2

apsched.job.Job.resume()

apsched.schedulers.base.BaseScheduler.resume_job()

4. 获得job列表

 获得调度作业的列表,可以使用get_jobs()来完成,它会返回所有的job实例。或者使用print_jobs()来输出所有格式化的作业列表。也可以利用get_job(任务ID)获取指定任务的作业列表

1

2

3

job = sched.add_job(my_job, 'interval', seconds=2 ,id='123')

print sched.get_job(job_id='123')

print sched.get_jobs()

5. 关闭调度器

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

1

2

sched.shutdown()

sched.shutdown(wait=False)

 作业运行的控制(trigger)

add_job的第二个参数是trigger,它管理着作业的调度方式。它可以为date, interval或者cron。对于不同的trigger,对应的参数也相同。

(1). cron定时调度(某一定时时刻执行)

1

2

3

4

5

6

7

8

9

10

11

12

13

14

(int|str) 表示参数既可以是int类型,也可以是str类型

(datetime | str) 表示参数既可以是datetime类型,也可以是str类型

 

year (int|str) – 4-digit year -(表示四位数的年份,如2008年)

month (int|str) – month (1-12-(表示取值范围为1-12月)

day (int|str) – day of the (1-31-(表示取值范围为1-31日)

week (int|str) – ISO week (1-53-(格里历20061231日可以写成2006-W52-7(扩展形式)或2006W527(紧凑形式))

day_of_week (int|str) – number or name of weekday (0-6 or mon,tue,wed,thu,fri,sat,sun) - (表示一周中的第几天,既可以用0-6表示也可以用其英语缩写表示)

hour (int|str) – hour (0-23- (表示取值范围为0-23时)

minute (int|str) – minute (0-59- (表示取值范围为0-59分)

second (int|str) – second (0-59- (表示取值范围为0-59秒)

start_date (datetime|str) – earliest possible date/time to trigger on (inclusive) - (表示开始时间)

end_date (datetime|str) – latest possible date/time to trigger on (inclusive) - (表示结束时间)

timezone (datetime.tzinfo|str) – time zone to use for the date/time calculations (defaults to scheduler timezone) -(表示时区取值)

参数的取值格式:

例子:

1

2

3

4

5

6

7

8

9

10

11

#表示2017年3月22日17时19分07秒执行该程序

sched.add_job(my_job, 'cron', year=2017,month = 03,day = 22,hour = 17,minute = 19,second = 07)

 

#表示任务在6,7,8,11,12月份的第三个星期五的00:00,01:00,02:00,03:00 执行该程序

sched.add_job(my_job, 'cron', month='6-8,11-12', day='3rd fri', hour='0-3')

 

#表示从星期一到星期五5:30(AM)直到2014-05-30 00:00:00

sched.add_job(my_job(), 'cron', day_of_week='mon-fri', hour=5, minute=30,end_date='2014-05-30')

 

#表示每5秒执行该程序一次,相当于interval 间隔调度中seconds = 5

sched.add_job(my_job, 'cron',second = '*/5')

(2). interval 间隔调度(每隔多久执行)

1

2

3

4

5

6

7

8

weeks (int) – number of weeks to wait

days (int) – number of days to wait

hours (int) – number of hours to wait

minutes (int) – number of minutes to wait

seconds (int) – number of seconds to wait

start_date (datetime|str) – starting point for the interval calculation

end_date (datetime|str) – latest possible date/time to trigger on

timezone (datetime.tzinfo|str) – time zone to use for the date/time calculations

例子:

1

2

#表示每隔3天17时19分07秒执行一次任务

sched.add_job(my_job, 'interval',days  = 03,hours = 17,minutes = 19,seconds = 07)

(3). date 定时调度(作业只会执行一次)

1

2

run_date (datetime|str) – the date/time to run the job at  -(任务开始的时间)

timezone (datetime.tzinfo|str) – time zone for run_date if it doesn’t have one already

例子:

1

2

3

4

# The job will be executed on November 6th, 2009

sched.add_job(my_job, 'date', run_date=date(2009116), args=['text'])

# The job will be executed on November 6th, 2009 at 16:30:05

sched.add_job(my_job, 'date', run_date=datetime(200911616305), args=['text'])

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/273950.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

Mingw下g++编译执行顺序错误

今天写一个简单的线性表时,用Mingw中的g编译、调试、运行时发现一个奇怪的现象:程序的执行顺序与实际编写顺序不一致。 编译环境:代码编写 win7下 editplus Mingw 4.3.3 g 代码片段如下: 1 //function: create a list 2 //ti…

python系统学习1-程序设计的基本方法

一、程序设计基本方法 计算机与程序设计 编译和解释 程序的基本编写方法 计算机编程 1、计算机与程序设计 (1)、计算机是根据指令操作数据的设备 功能性:对数据的操作、表现为数据计算、输出输入处理和结果存储。 可编程性:…

python 系统学习实例1.1 - 华氏度与摄氏度的转换

# C ( F - 32 ) / 1.8‪‬‪‬‪‬‪‬‪‬‮‬‫‬‭‬‪‬‪‬‪‬‪‬‪‬‮‬‫‬‮‬‪‬‪‬‪‬‪‬‪‬‮‬‪‬‮‬‪‬‪‬‪‬‪‬‪‬‮‬‫‬‪‬‪‬‪‬‪‬‪‬‪‬‮‬‫‬‫‬ # F C * 1.8 32‪‬‪‬‪‬‪‬‪‬‮‬‫‬‭‬‪‬‪‬‪‬‪‬‪‬‮‬‫…

EMS问题

如果EMS启动后在运行时报出 JMS error: "Not allowed to create destination这个错误,可能就是你启动方式的问题了进入到EMS的安装目录的bin目录下,运行tibemsca.bat那个文件就好使了。转载于:https://www.cnblogs.com/xiaotianyu/p/3421737.html

python 系统学习实例1.2 - 人民币与美元的转换

# RMB USD / 6.78‪‬‪‬‪‬‪‬‪‬‮‬‫‬‭‬‪‬‪‬‪‬‪‬‪‬‮‬‫‬‮‬‪‬‪‬‪‬‪‬‪‬‮‬‪‬‮‬‪‬‪‬‪‬‪‬‪‬‮‬‫‬‪‬‪‬‪‬‪‬‪‬‪‬‮‬‫‬‫‬ # USD RMB* 6.78 def tempConvert(): t input("请输入数值:") …

HDTV(1920x1080)码率和视频质量关系的研究 2 (实验结果)

上一篇文章中介绍了实验的准备工作, HDTV(1920x1080)码率和视频质量关系的研究 1 (前期准备) 本文介绍一下实验的结果。 首先来看一下主观评价的试验结果: 从实验结果来看,可以得出以下结论&…

python爬虫--如何爬取翻页url不变的网站

参考 https://blog.csdn.net/c350577169/article/details/80410133

POJ 1745 Divisibility DP

POJ:http://poj.org/problem?id1745 A完这题去买福鼎肉片,和舍友去买滴~舍友感慨“这一天可以卖好几百份,每份就算赚一块钱。。那么一个月。。一年。。。” 我说“那我们以后去卖这个吧,饿了还能自己煮着吃” 哈哈,一群天真的少…

NGUI如何创建自己的精灵图集

说实话其实很简单,但是在不知道的情况下真的不好弄啊. 1. 选择你要制作精灵图集的图片,可以选择多张 2. 提倡使用快捷键Alt Shift M 会有如下窗口弹出,也可以NGUI --> Open-->Atlas Maker打开 我们看到在Sprites里面就是我们选择的要制作图集的图片 当在Replace后面的输…

C++ - 进阶 1002

This time, you are supposed to find AB where A and B are two polynomials. Input Specification: Each input file contains one test case. Each case occupies 2 lines, and each line contains the information of a polynomial: K N​1​​ a​N​1​​​​ N​2​​…

修改6S Fortran77 代码,建立查找表

逐像元大气校正,常预先计算查找表(LUT,LookUp Tabel),6S大气辐射传输模式也可以用来计算LUT。但6S源程序输出信息多,且浮点数输出精度低,不利于提取关键信息生成LUT,本文描述了怎样修…

c++ 实例

#include "stdafx.h" #include <iostream> using namespace std; int main() { int a; a 4; cout<<a<<endl; return 0; }

VMware虚拟机与宿主无法复制的解决办法

由于工作需要&#xff0c;上网机器使用虚拟机&#xff0c;因此需要经常来回的拷贝文件&#xff0c;而vmware从6.5一直走来到10.0.1&#xff0c;总是有一个问题很让人苦恼---共享粘贴板总是会无故失效。经常实验&#xff0c;发现可以经过以下方法临时解决一下&#xff0c;虽然不…

c++ pat 乙级 --1001 害死人不偿命的(3n+1)猜想

1001 害死人不偿命的(3n1)猜想 &#xff08;15 分&#xff09; 卡拉兹(Callatz)猜想&#xff1a; 对任何一个正整数 n&#xff0c;如果它是偶数&#xff0c;那么把它砍掉一半&#xff1b;如果它是奇数&#xff0c;那么把 (3n1) 砍掉一半。这样一直反复砍下去&#xff0c;最后…

【开源项目之路】jquery的build问题

在刚开始clone了jquery到本地build的时候&#xff0c;就遇到了问题。 “ENORESTARGET No tag found that was able to satisfy ...” 提示为bower install失败&#xff0c;反复查找原因&#xff0c;最后在这儿看到同样类似的问题&#xff0c;貌似是git协议的连接问题&#xff0…

适配ios7

if ([self respondsToSelector:selector(edgesForExtendedLayout)]){self.edgesForExtendedLayout UIRectEdgeNone;self.extendedLayoutIncludesOpaqueBars NO;self.modalPresentationCapturesStatusBarAppearance NO;} 转载于:https://www.cnblogs.com/jiackyan/p/3441378.…

c++ pat 乙级 -------1002 读入一个正整数 n,计算其各位数字之和,用汉语拼音写出和的每一位数字。

1002 写出这个数 &#xff08;20 分&#xff09; 读入一个正整数 n&#xff0c;计算其各位数字之和&#xff0c;用汉语拼音写出和的每一位数字。 输入格式&#xff1a; 每个测试输入包含 1 个测试用例&#xff0c;即给出自然数 n 的值。这里保证 n 小于 10​100​​。 输出…

USACO SEC.1.3 No.1 Mixing Milk

题意&#xff1a;需要收购总数为N的牛奶&#xff0c;现在有M个牛奶供应商&#xff08;总量足够&#xff09;&#xff0c;给出总数和单价&#xff0c;求最小的花销。 核心&#xff1a;基本的贪心解法&#xff0c;按单价排序逐个选取。 目的在于熟悉基本的贪心法的基本方法和思路…

c++ 获取数组的长度

//获得数组的长度 template<typename T> int count(T& x) { int s1 sizeof(x); int s2 sizeof(x[0]); int result s1 / s2; return result; }

[WPF疑难] 继承自定义窗口

[WPF疑难] 继承自定义窗口 原文 [WPF疑难] 继承自定义窗口 [WPF疑难] 继承自定义窗口 周银辉 项目中有不少的弹出窗口&#xff0c;按照美工的设计其外边框&#xff08;包括最大化&#xff0c;最小化&#xff0c;关闭等按钮&#xff09;自然不同于Window自身的&#xff0c;但每个…