Python定時(shí)任務(wù)APScheduler原理及實(shí)例解析
定時(shí)任務(wù):
1、 線程睡眠函數(shù) sleep() ——粗暴!一直占有 CPU 資源,導(dǎo)致后續(xù)操作無法執(zhí)行
2、 threading.Timer(10, task, ()).start() # (間隔s,任務(wù)task, 函參)
3、 import sched
# 初始化 sched 模塊的 scheduler 類scheduler = sched.scheduler(time.time, time.sleep)# 增加調(diào)度任務(wù) enter(delay, priority, action, argument=(), kwargs={})scheduler.enter(10, 1, task) # 運(yùn)行任務(wù)scheduler.run()
scheduler 中的每個(gè)調(diào)度任務(wù)只會(huì)工作一次,不會(huì)無限循環(huán)被調(diào)用。如果想重復(fù)執(zhí)行同一任務(wù), 需要重復(fù)添加調(diào)度任務(wù)即可。
enter(delay, priority, action, argument=(), kwargs={}) 間隔執(zhí)行任務(wù)。delay單位是秒。priority越小優(yōu)先級(jí)越大。兩個(gè)任務(wù)指定相同的延遲時(shí)間,優(yōu)先級(jí)大的任務(wù)會(huì)向被執(zhí)行。action 即需要執(zhí)行的函數(shù),argument 和 kwargs 分別是函數(shù)的位置和關(guān)鍵字參數(shù)。 scheduler.enterabs(time, priority, action, argument=(), kwargs={}) 時(shí)間點(diǎn)執(zhí)行任務(wù)。因此,time是絕對(duì)時(shí)間.其他參數(shù)用法與 enter() 中的參數(shù)用法是一致。APScheduler——Advanced Python Scheduler。
一個(gè)輕量級(jí)的 Python 定時(shí)任務(wù)調(diào)度框架。APScheduler 支持三種調(diào)度任務(wù):固定時(shí)間間隔,固定時(shí)間點(diǎn)(日期),Linux下Crontab 命令。同時(shí),它還支持異步執(zhí)行、后臺(tái)執(zhí)行調(diào)度任務(wù)。
import datetimeimport timefrom apscheduler.schedulers.background import BackgroundSchedulerdef timedTask(): print(datetime.datetime.utcnow().strftime('%Y-%m-%d %H:%M:%S.%f')[:-3])if __name__ == ’__main__’: # 1.創(chuàng)建后臺(tái)執(zhí)行的 schedulers scheduler = BackgroundScheduler() # 2.添加調(diào)度任務(wù),調(diào)度方法為 timedTask,觸發(fā)器選擇 interval(間隔性),間隔時(shí)長(zhǎng)為 2 秒 job = scheduler.add_job(timedTask, ’interval’, seconds=2) # 3.啟動(dòng)調(diào)度任務(wù) scheduler.start() while True: print(time.time()) time.sleep(5)
基礎(chǔ)組件
schedulers(調(diào)度器)它是任務(wù)調(diào)度器,屬于控制器角色。它配置作業(yè)存儲(chǔ)器和執(zhí)行器可以在調(diào)度器中完成,例如添加、修改和移除作業(yè)。 BlockingScheduler : 調(diào)度器在當(dāng)前進(jìn)程的主線程中運(yùn)行,也就是會(huì)阻塞當(dāng)前線程。 BackgroundScheduler : 調(diào)度器在后臺(tái)線程中運(yùn)行,不會(huì)阻塞當(dāng)前線程。 AsyncIOScheduler : 結(jié)合 asyncio 模塊(一個(gè)異步框架)一起使用。 GeventScheduler : 程序中使用 gevent(高性能的Python并發(fā)框架)作為IO模型,和 GeventExecutor 配合使用。 TornadoScheduler : 程序中使用 Tornado(一個(gè)web框架)的IO模型,用 ioloop.add_timeout 完成定時(shí)喚醒。 TwistedScheduler : 配合 TwistedExecutor,用 reactor.callLater 完成定時(shí)喚醒。 QtScheduler : 你的應(yīng)用是一個(gè) Qt 應(yīng)用,需使用QTimer完成定時(shí)喚醒。 triggers(觸發(fā)器)描述調(diào)度任務(wù)被觸發(fā)的條件。不過觸發(fā)器完全是無狀態(tài)的。 date 時(shí)間點(diǎn)觸發(fā): scheduler .add_job(job_func, ’date’, run_date=datetime(2017, 12, 13, 14, 0, 0), args=[’text’]) interval 固定時(shí)間間隔觸發(fā): scheduler .add_job(job_func, ’interval’, minutes=2, start_date=’2017-12-13 14:00:01’ , end_date=’2017-12-13 14:00:10’) cron 特定時(shí)間周期性地觸發(fā): scheduler .add_job(job_func, ’cron’, month=’1-3,7-9’,day=’0, tue’, hour=’0-3’) job stores(作業(yè)存儲(chǔ)器)任務(wù)持久化倉(cāng)庫(kù),默認(rèn)保存任務(wù)在內(nèi)存中,也可將任務(wù)保存都各種數(shù)據(jù)庫(kù)中,任務(wù)中的數(shù)據(jù)序列化后保存到持久化數(shù)據(jù)庫(kù),從數(shù)據(jù)庫(kù)加載后又反序列化。 有兩種添加方法,一是 add_job(), 二是scheduled_job()修飾器來修飾函數(shù)。區(qū)別是:第一種方法返回一個(gè) apscheduler.job.Job 的實(shí)例,可用來改變或移除 job。第二種方法只適用于應(yīng)用運(yùn)行期間不會(huì)改變的 job。 移除 job 也有兩種方法:remove_job() 和 job.remove()。 remove_job() 是根據(jù) job 的 id 來移除,所以要在 job 創(chuàng)建時(shí)指定一個(gè) id。job.remove() 則是對(duì) job 執(zhí)行 remove 方法即可。 獲取 job 列表:通過 scheduler.get_jobs() 方法能夠獲取當(dāng)前調(diào)度器中的所有 job 的列表。 修改job: 用Job.modify() 或 modify_job()方法來修改 job 的屬性。但注意job 的 id 是無法被修改的。 關(guān)閉 job:默認(rèn)情況下調(diào)度器會(huì)等待所有正在運(yùn)行的作業(yè)完成后,關(guān)閉所有的調(diào)度器和作業(yè)存儲(chǔ)。如果你不想等待,可以將 wait 選項(xiàng)設(shè)置為 False。 更新任務(wù)reschedule_job() executors(執(zhí)行器)負(fù)責(zé)處理作業(yè)的運(yùn)行,它們通常通過在作業(yè)中提交指定的可調(diào)用對(duì)象到一個(gè)線程或進(jìn)城池來進(jìn)行。當(dāng)作業(yè)完成時(shí),執(zhí)行器將會(huì)通知調(diào)度器。最常用的 executor 有兩種:ProcessPoolExecutor 和 ThreadPoolExecutor以上就是本文的全部?jī)?nèi)容,希望對(duì)大家的學(xué)習(xí)有所幫助,也希望大家多多支持好吧啦網(wǎng)。
相關(guān)文章:
1. 如何在jsp界面中插入圖片2. ASP實(shí)現(xiàn)加法驗(yàn)證碼3. python selenium 獲取接口數(shù)據(jù)的實(shí)現(xiàn)4. ASP刪除img標(biāo)簽的style屬性只保留src的正則函數(shù)5. 詳解JSP 內(nèi)置對(duì)象request常見用法6. 利用ajax+php實(shí)現(xiàn)商品價(jià)格計(jì)算7. Python matplotlib 繪制雙Y軸曲線圖的示例代碼8. jsp EL表達(dá)式詳解9. JSP servlet實(shí)現(xiàn)文件上傳下載和刪除10. springboot集成與使用Sentinel的方法
