Python任務(wù)調(diào)度模塊APScheduler使用

更新時間：2020年04月15日 09:48:19 作者：cool小伙

這篇文章主要介紹了Python任務(wù)調(diào)度模塊APScheduler使用,文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友可以參考下

APScheduler是一個Python定時任務(wù)框架，使用起來十分方便。提供了基于日期、固定時間間隔以及crontab類型的任務(wù)，并且可以持久化任務(wù)、并以daemon方式運(yùn)行應(yīng)用。

在APScheduler中有四個組件：

觸發(fā)器(trigger)包含調(diào)度邏輯，每一個作業(yè)有它自己的觸發(fā)器，用于決定接下來哪一個作業(yè)會運(yùn)行。除了他們自己初始配置意外，觸發(fā)器完全是無狀態(tài)的。簡單說就是應(yīng)該說明一個任務(wù)應(yīng)該在什么時候執(zhí)行。
作業(yè)存儲(job store)存儲被調(diào)度的作業(yè)，默認(rèn)的作業(yè)存儲是簡單地把作業(yè)保存在內(nèi)存中，其他的作業(yè)存儲是將作業(yè)保存在數(shù)據(jù)庫中。一個作業(yè)的數(shù)據(jù)將在保存在持久化作業(yè)存儲時被序列化，并在加載時被反序列化。調(diào)度器不能分享同一個作業(yè)存儲。
執(zhí)行器(executor)處理作業(yè)的運(yùn)行，他們通常通過在作業(yè)中提交制定的可調(diào)用對象到一個線程或者進(jìn)城池來進(jìn)行。當(dāng)作業(yè)完成時，執(zhí)行器將會通知調(diào)度器。
調(diào)度器(scheduler)任務(wù)控制器：通過配置executor、jobstore、trigger，使用線程池(ThreadPoolExecutor默認(rèn)值20)或進(jìn)程池(ProcessPoolExecutor 默認(rèn)值5)并且默認(rèn)最多3個(max_instances)任務(wù)實(shí)例同時運(yùn)行，實(shí)現(xiàn)對job的增刪改查等調(diào)度控制

你需要選擇合適的調(diào)度器，這取決于你的應(yīng)用環(huán)境和你使用APScheduler的目的。通常最常用的兩個：

BlockingScheduler：當(dāng)調(diào)度器是你應(yīng)用中唯一要運(yùn)行的東西時使用。

BackgroundScheduler：當(dāng)你不運(yùn)行任何其他框架時使用，并希望調(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ù)只運(yùn)行一次，運(yùn)行完畢自動清除；若錯過指定運(yùn)行時間，任務(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è):