????????APScheduler是一個Python定時任務(wù)框架,使用起來十分方便灰嫉。提供了基于日期嗓奢、固定時間間隔以及crontab類型的任務(wù)股耽,并且可以持久化任務(wù)、并以daemon方式運行應(yīng)用炎滞。
????????在APScheduler中有四個組件:?
? ??????觸發(fā)器(trigger)包含調(diào)度邏輯诬乞,每一個作業(yè)有它自己的觸發(fā)器震嫉,用于決定接下來哪一個作業(yè)會運行责掏。除了他們自己初始配置意外,觸發(fā)器完全是無狀態(tài)的痰驱。簡單說就是應(yīng)該說明一個任務(wù)應(yīng)該在什么時候執(zhí)行瞳浦。?
? ??????作業(yè)存儲(job store)存儲被調(diào)度的作業(yè)担映,默認的作業(yè)存儲是簡單地把作業(yè)保存在內(nèi)存中,其他的作業(yè)存儲是將作業(yè)保存在數(shù)據(jù)庫中叫潦。一個作業(yè)的數(shù)據(jù)將在保存在持久化作業(yè)存儲時被序列化蝇完,并在加載時被反序列化。調(diào)度器不能分享同一個作業(yè)存儲。?
? ??????執(zhí)行器(executor)處理作業(yè)的運行短蜕,他們通常通過在作業(yè)中提交制定的可調(diào)用對象到一個線程或者進城池來進行氢架。當(dāng)作業(yè)完成時,執(zhí)行器將會通知調(diào)度器朋魔。?
? ??????調(diào)度器(scheduler)任務(wù)控制器:通過配置executor岖研、jobstore、trigger孙援,使用線程池(ThreadPoolExecutor默認值20)或進程池(ProcessPoolExecutor 默認值5)并且默認最多3個(max_instances)任務(wù)實例同時運行,實現(xiàn)對job的增刪改查等調(diào)度控制
????????你需要選擇合適的調(diào)度器扇雕,這取決于你的應(yīng)用環(huán)境和你使用APScheduler的目的拓售。通常最常用的兩個:?
? ? ? ? BlockingScheduler:當(dāng)調(diào)度器是你應(yīng)用中唯一要運行的東西時使用。?
????????BackgroundScheduler:當(dāng)你不運行任何其他框架時使用镶奉,并希望調(diào)度器在你應(yīng)用的后臺執(zhí)行础淤。
作業(yè)存儲
????????支持4中作業(yè)存儲,分別是:MemoryJobStore(存儲在內(nèi)存中)哨苛、sqlalchemy(關(guān)系型數(shù)據(jù)庫)值骇、mongodb(文檔數(shù)據(jù)庫)、redis(內(nèi)存型鍵值對數(shù)據(jù)庫)
觸發(fā)方式
????????date:固定日期觸發(fā)器:任務(wù)只運行一次移国,運行完畢自動清除;若錯過指定運行時間道伟,任務(wù)不會被創(chuàng)建
????????interval:時間間隔觸發(fā)器迹缀,每個一定時間間隔執(zhí)行一次。
????????cron:cron風(fēng)格的任務(wù)觸發(fā)蜜徽。
作業(yè)操作
????????1. 添加作業(yè):上面是通過add_job()來添加作業(yè)祝懂,另外還有一種方式是通過scheduled_job()修飾器來修飾函數(shù)。
????????@sched.scheduled_job('cron', id='my_job_id', day='last sun')
????????def some_decorated_task():
????????????????print("I am printed at 00:00:00 on the last Sunday of every month!")
????????2. 移除作業(yè)
????????job = scheduler.add_job(myfunc,'interval', minutes=2)
????????job.remove()
????????Same,using an explicit job ID:
????????scheduler.add_job(myfunc,'interval', minutes=2, id='my_job_id')
????????scheduler.remove_job('my_job_id')
????????3. 暫停和恢復(fù)作業(yè)
????????暫停作業(yè):
????????????–apscheduler.job.Job.pause()
????????????–apscheduler.schedulers.base.BaseScheduler.pause_job()
????????恢復(fù)作業(yè):
????????????–apscheduler.job.Job.resume()
????????????–apscheduler.schedulers.base.BaseScheduler.resume_job()
????????4. 獲得job列表
????????獲得調(diào)度作業(yè)的列表拘鞋,可以使用get_jobs()來完成砚蓬,它會返回所有的job實例∨枭或者使用print_jobs()來輸出所有格式化的作業(yè)列表灰蛙。
????????5. 修改作業(yè)
????????def some_decorated_task():
????????????print("I am printed at 00:00:00 on the last Sunday of every month!")
????????6. 關(guān)閉調(diào)度器
????????默認情況下調(diào)度器會等待所有正在運行的作業(yè)完成后,關(guān)閉所有的調(diào)度器和作業(yè)存儲隔躲。如果你不想等待摩梧,可以將wait選項設(shè)置為False。
????????scheduler.shutdown()
????????scheduler.shutdown(wait=False)
作業(yè)運行的控制
????????add_job的第二個參數(shù)是trigger宣旱,它管理著作業(yè)的調(diào)度方式仅父。它可以為date, interval或者cron。對于不同的trigger,對應(yīng)的參數(shù)也相同笙纤。
????????(1). cron定時調(diào)度
????????(2). interval 間隔調(diào)度
????????(3). date 定時調(diào)度