电脑知识|欧美黑人一区二区三区|软件|欧美黑人一级爽快片淫片高清|系统|欧美黑人狂野猛交老妇|数据库|服务器|编程开发|网络运营|知识问答|技术教程文章 - 好吧啦网

您的位置:首頁(yè)技術(shù)文章
文章詳情頁(yè)

Python定時(shí)任務(wù)框架APScheduler原理及常用代碼

瀏覽:14日期:2022-07-09 09:56:30

APScheduler簡(jiǎn)介

在平常的工作中幾乎有一半的功能模塊都需要定時(shí)任務(wù)來(lái)推動(dòng),例如項(xiàng)目中有一個(gè)定時(shí)統(tǒng)計(jì)程序,定時(shí)爬出網(wǎng)站的URL程序,定時(shí)檢測(cè)釣魚網(wǎng)站的程序等等,都涉及到了關(guān)于定時(shí)任務(wù)的問題,第一時(shí)間想到的是利用time模塊的time.sleep()方法使程序休眠來(lái)達(dá)到定時(shí)任務(wù)的目的,雖然這樣也可以,但是總覺得不是那么的專業(yè),^_^所以就找到了python的定時(shí)任務(wù)模塊APScheduler:

APScheduler基于Quartz的一個(gè)Python定時(shí)任務(wù)框架,實(shí)現(xiàn)了Quartz的所有功能,使用起來(lái)十分方便。提供了基于日期、固定時(shí)間間隔以及crontab類型的任務(wù),并且可以持久化任務(wù)。基于這些功能,我們可以很方便的實(shí)現(xiàn)一個(gè)python定時(shí)任務(wù)系統(tǒng)。

安裝

1、利用pip進(jìn)行安裝

$ pip install apscheduler

2、源碼安裝(https://pypi.python.org/pypi/APScheduler/)

$ python setup.py install

APScheduler有四種組成部分:

觸發(fā)器(trigger)包含調(diào)度邏輯,每一個(gè)作業(yè)有它自己的觸發(fā)器,用于決定接下來(lái)哪一個(gè)作業(yè)會(huì)運(yùn)行。除了他們自己初始配置意外,觸發(fā)器完全是無(wú)狀態(tài)的。

作業(yè)存儲(chǔ)(job store)存儲(chǔ)被調(diào)度的作業(yè),默認(rèn)的作業(yè)存儲(chǔ)是簡(jiǎn)單地把作業(yè)保存在內(nèi)存中,其他的作業(yè)存儲(chǔ)是將作業(yè)保存在數(shù)據(jù)庫(kù)中。一個(gè)作業(yè)的數(shù)據(jù)講在保存在持久化作業(yè)存儲(chǔ)時(shí)被序列化,并在加載時(shí)被反序列化。調(diào)度器不能分享同一個(gè)作業(yè)存儲(chǔ)。

執(zhí)行器(executor)處理作業(yè)的運(yùn)行,他們通常通過在作業(yè)中提交制定的可調(diào)用對(duì)象到一個(gè)線程或者進(jìn)城池來(lái)進(jìn)行。當(dāng)作業(yè)完成時(shí),執(zhí)行器將會(huì)通知調(diào)度器。

調(diào)度器(scheduler)是其他的組成部分。你通常在應(yīng)用只有一個(gè)調(diào)度器,應(yīng)用的開發(fā)者通常不會(huì)直接處理作業(yè)存儲(chǔ)、調(diào)度器和觸發(fā)器,相反,調(diào)度器提供了處理這些的合適的接口。配置作業(yè)存儲(chǔ)和執(zhí)行器可以在調(diào)度器中完成,例如添加、修改和移除作業(yè)。 

簡(jiǎn)單應(yīng)用:import timefrom apscheduler.schedulers.blocking import BlockingSchedulerdef 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執(zhí)行一次my_job函數(shù),輸出當(dāng)前時(shí)間信息

操作作業(yè)

1. 添加作業(yè)

上面是通過add_job()來(lái)添加作業(yè),另外還有一種方式是通過scheduled_job()修飾器來(lái)修飾函數(shù)

import timefrom apscheduler.schedulers.blocking import BlockingSchedulersched = 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. 移除作業(yè)

job = scheduler.add_job(myfunc, ’interval’, minutes=2)job.remove()#如果有多個(gè)任務(wù)序列的話可以給每個(gè)任務(wù)設(shè)置ID號(hào),可以根據(jù)ID號(hào)選擇清除對(duì)象,且remove放到start前才有效sched.add_job(myfunc, ’interval’, minutes=2, id=’my_job_id’)sched.remove_job(’my_job_id’)

3. 暫停和恢復(fù)作業(yè)

暫停作業(yè):

apsched.job.Job.pause()apsched.schedulers.base.BaseScheduler.pause_job()

恢復(fù)作業(yè):

apsched.job.Job.resume()apsched.schedulers.base.BaseScheduler.resume_job()

4. 獲得job列表

獲得調(diào)度作業(yè)的列表,可以使用get_jobs()來(lái)完成,它會(huì)返回所有的job實(shí)例。或者使用print_jobs()來(lái)輸出所有格式化的作業(yè)列表。也可以利用get_job(任務(wù)ID)獲取指定任務(wù)的作業(yè)列表

job = sched.add_job(my_job, ’interval’, seconds=2 ,id=’123’)print sched.get_job(job_id=’123’)print sched.get_jobs()

5. 關(guān)閉調(diào)度器

默認(rèn)情況下調(diào)度器會(huì)等待所有正在運(yùn)行的作業(yè)完成后,關(guān)閉所有的調(diào)度器和作業(yè)存儲(chǔ)。如果你不想等待,可以將wait選項(xiàng)設(shè)置為False。

sched.shutdown()sched.shutdown(wait=False)

作業(yè)運(yùn)行的控制(trigger)

add_job的第二個(gè)參數(shù)是trigger,它管理著作業(yè)的調(diào)度方式。它可以為date, interval或者cron。對(duì)于不同的trigger,對(duì)應(yīng)的參數(shù)也相同。

(1). cron定時(shí)調(diào)度(某一定時(shí)時(shí)刻執(zhí)行)

(int|str) 表示參數(shù)既可以是int類型,也可以是str類型(datetime | str) 表示參數(shù)既可以是datetime類型,也可以是str類型year (int|str) ? 4-digit year -(表示四位數(shù)的年份,如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) -(格里歷2006年12月31日可以寫成2006年-W52-7(擴(kuò)展形式)或2006W527(緊湊形式))day_of_week (int|str) ? number or name of weekday (0-6 or mon,tue,wed,thu,fri,sat,sun) - (表示一周中的第幾天,既可以用0-6表示也可以用其英語(yǔ)縮寫表示)hour (int|str) ? hour (0-23) - (表示取值范圍為0-23時(shí))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) - (表示開始時(shí)間)end_date (datetime|str) ? latest possible date/time to trigger on (inclusive) - (表示結(jié)束時(shí)間)timezone (datetime.tzinfo|str) ? time zone to use for the date/time calculations (defaults to scheduler timezone) -(表示時(shí)區(qū)取值)

參數(shù)的取值格式:

Python定時(shí)任務(wù)框架APScheduler原理及常用代碼

例子:

#表示2017年3月22日17時(shí)19分07秒執(zhí)行該程序sched.add_job(my_job, ’cron’, year=2017,month = 03,day = 22,hour = 17,minute = 19,second = 07)#表示任務(wù)在6,7,8,11,12月份的第三個(gè)星期五的00:00,01:00,02:00,03:00 執(zhí)行該程序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:00sched.add_job(my_job(), ’cron’, day_of_week=’mon-fri’, hour=5, minute=30,end_date=’2014-05-30’)#表示每5秒執(zhí)行該程序一次,相當(dāng)于interval 間隔調(diào)度中seconds = 5sched.add_job(my_job, ’cron’,second = ’*/5’)

(2). interval 間隔調(diào)度(每隔多久執(zhí)行)

weeks (int) ? number of weeks to waitdays (int) ? number of days to waithours (int) ? number of hours to waitminutes (int) ? number of minutes to waitseconds (int) ? number of seconds to waitstart_date (datetime|str) ? starting point for the interval calculationend_date (datetime|str) ? latest possible date/time to trigger ontimezone (datetime.tzinfo|str) ? time zone to use for the date/time calculations

例子:

#表示每隔3天17時(shí)19分07秒執(zhí)行一次任務(wù)sched.add_job(my_job, ’interval’,days = 03,hours = 17,minutes = 19,seconds = 07)

(3). date 定時(shí)調(diào)度(作業(yè)只會(huì)執(zhí)行一次)

run_date (datetime|str) ? the date/time to run the job at -(任務(wù)開始的時(shí)間)timezone (datetime.tzinfo|str) ? time zone for run_date if it doesn’t have one already

例子:

# The job will be executed on November 6th, 2009sched.add_job(my_job, ’date’, run_date=date(2009, 11, 6), args=[’text’])# The job will be executed on November 6th, 2009 at 16:30:05sched.add_job(my_job, ’date’, run_date=datetime(2009, 11, 6, 16, 30, 5), args=[’text’])

以上就是本文的全部?jī)?nèi)容,希望對(duì)大家的學(xué)習(xí)有所幫助,也希望大家多多支持好吧啦網(wǎng)。

標(biāo)簽: Python 編程
相關(guān)文章:
主站蜘蛛池模板: 不锈钢水箱厂家,不锈钢保温水箱-山东桑特供水设备 | 最新电影-好看的电视剧大全-朝夕电影网 | LHH药品稳定性试验箱-BPS系列恒温恒湿箱-意大利超低温冰箱-上海一恒科学仪器有限公司 | 杭州公司变更法人-代理记账收费价格-公司注销代办_杭州福道财务管理咨询有限公司 | 鑫达滑石-辽宁鑫达滑石集团 | 武汉天安盾电子设备有限公司 - 安盾安检,武汉安检门,武汉安检机,武汉金属探测器,武汉测温安检门,武汉X光行李安检机,武汉防爆罐,武汉车底安全检查,武汉液体探测仪,武汉安检防爆设备 | 二手电脑回收_二手打印机回收_二手复印机回_硒鼓墨盒回收-广州益美二手电脑回收公司 | 盘扣式脚手架-附着式升降脚手架-移动脚手架,专ye承包服务商 - 苏州安踏脚手架工程有限公司 | 石家庄网站建设|石家庄网站制作|石家庄小程序开发|石家庄微信开发|网站建设公司|网站制作公司|微信小程序开发|手机APP开发|软件开发 | 航空障碍灯_高中低光强航空障碍灯_民航许可认证航空警示灯厂家-东莞市天翔航天科技有限公司 | 篮球地板厂家_舞台木地板品牌_体育运动地板厂家_凯洁地板 | 钢化玻璃膜|手机钢化膜|钢化膜厂家|手机保护膜-【东莞市大象电子科技有限公司】 | 导电银胶_LED封装导电银胶_半导体封装导电胶厂家-上海腾烁 | 外贮压-柜式-悬挂式-七氟丙烷-灭火器-灭火系统-药剂-价格-厂家-IG541-混合气体-贮压-非贮压-超细干粉-自动-灭火装置-气体灭火设备-探火管灭火厂家-东莞汇建消防科技有限公司 | 热镀锌槽钢|角钢|工字钢|圆钢|H型钢|扁钢|花纹板-天津千百顺钢铁贸易有限公司 | 双工位钻铣攻牙机-转换工作台钻攻中心-钻铣攻牙机一体机-浙江利硕自动化设备有限公司 | 宿舍管理系统_智慧园区系统_房屋/房产管理系统_公寓管理系统 | 英超直播_英超免费在线高清直播_英超视频在线观看无插件-24直播网 | 智成电子深圳tdk一级代理-提供TDK电容电感贴片蜂鸣器磁芯lambda电源代理经销,TDK代理商有哪些TDK一级代理商排名查询。-深圳tdk一级代理 | Safety light curtain|Belt Sway Switches|Pull Rope Switch|ultrasonic flaw detector-Shandong Zhuoxin Machinery Co., Ltd | 飞歌臭氧发生器厂家_水处理臭氧发生器_十大臭氧消毒机品牌 | 好物生环保网、环保论坛 - 环保人的学习交流平台 | 蓝米云-专注于高性价比香港/美国VPS云服务器及海外公益型免费虚拟主机 | 合肥宠物店装修_合肥宠物美容院装修_合肥宠物医院设计装修公司-安徽盛世和居装饰 | 超声波电磁流量计-液位计-孔板流量计-料位计-江苏信仪自动化仪表有限公司 | 三价铬_环保铬_环保电镀_东莞共盈新材料贸易有限公司 | 不锈钢拉手厂家|浴室门拉手厂家|江门市蓬江区金志翔五金制品有限公司 | PC构件-PC预制构件-构件设计-建筑预制构件-PC构件厂-锦萧新材料科技(浙江)股份有限公司 | 台式恒温摇床价格_大容量恒温摇床厂家-上海量壹科学仪器有限公司 | 掺铥光纤放大器-C/L波段光纤放大器-小信号光纤放大器-合肥脉锐光电技术有限公司 | 深圳3D打印服务-3D打印加工-手板模型加工厂-悟空打印坊 | 章丘丰源机械有限公司 - 三叶罗茨风机,罗茨鼓风机,罗茨风机 | 细沙回收机-尾矿干排脱水筛设备-泥石分离机-建筑垃圾分拣机厂家-青州冠诚重工机械有限公司 | 【同风运车官网】一站式汽车托运服务平台,验车满意再付款 | 飞象网 - 通信人每天必上的网站 全球化工设备网—化工设备,化工机械,制药设备,环保设备的专业网络市场。 | 柔性输送线|柔性链板|齿形链-上海赫勒输送设备有限公司首页[输送机] | 亿诺千企网-企业核心产品贸易| 直流大电流电源,燃料电池检漏设备-上海政飞 | 沈阳网站建设_沈阳网站制作_沈阳网页设计-做网站就找示剑新零售 沈阳缠绕膜价格_沈阳拉伸膜厂家_沈阳缠绕膜厂家直销 | 喷漆房_废气处理设备-湖北天地鑫环保设备有限公司 | 纯水电导率测定仪-万用气体检测仪-低钠测定仪-米沃奇科技(北京)有限公司www.milwaukeeinst.cn 锂辉石检测仪器,水泥成分快速分析仪-湘潭宇科分析仪器有限公司 手术室净化装修-手术室净化工程公司-华锐手术室净化厂家 |