av一区二区在线观看_亚洲男人的天堂网站_日韩亚洲视频_在线成人免费_欧美日韩精品免费观看视频_久草视

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

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

瀏覽:43日期:2022-07-30 08:49:00

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

在APScheduler中有四個(gè)組件:

觸發(fā)器(trigger)包含調(diào)度邏輯,每一個(gè)作業(yè)有它自己的觸發(fā)器,用于決定接下來哪一個(gè)作業(yè)會(huì)運(yùn)行。除了他們自己初始配置意外,觸發(fā)器完全是無狀態(tài)的。簡(jiǎn)單說就是應(yīng)該說明一個(gè)任務(wù)應(yīng)該在什么時(shí)候執(zhí)行。 作業(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)城池來進(jìn)行。當(dāng)作業(yè)完成時(shí),執(zhí)行器將會(huì)通知調(diào)度器。 調(diào)度器(scheduler)任務(wù)控制器:通過配置executor、jobstore、trigger,使用線程池(ThreadPoolExecutor默認(rèn)值20)或進(jìn)程池(ProcessPoolExecutor 默認(rèn)值5)并且默認(rèn)最多3個(gè)(max_instances)任務(wù)實(shí)例同時(shí)運(yùn)行,實(shí)現(xiàn)對(duì)job的增刪改查等調(diào)度控制

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

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

BackgroundScheduler:當(dāng)你不運(yùn)行任何其他框架時(shí)使用,并希望調(diào)度器在你應(yīng)用的后臺(tái)執(zhí)行。

作業(yè)存儲(chǔ)

支持4中作業(yè)存儲(chǔ),分別是:MemoryJobStore(存儲(chǔ)在內(nèi)存中)、sqlalchemy(關(guān)系型數(shù)據(jù)庫(kù))、mongodb(文檔數(shù)據(jù)庫(kù))、redis(內(nèi)存型鍵值對(duì)數(shù)據(jù)庫(kù))

觸發(fā)方式

date:固定日期觸發(fā)器:任務(wù)只運(yùn)行一次,運(yùn)行完畢自動(dòng)清除;若錯(cuò)過指定運(yùn)行時(shí)間,任務(wù)不會(huì)被創(chuàng)建

interval:時(shí)間間隔觸發(fā)器,每個(gè)一定時(shí)間間隔執(zhí)行一次。

cron:cron風(fēng)格的任務(wù)觸發(fā)。

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

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

作業(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()來完成,它會(huì)返回所有的job實(shí)例。或者使用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)度器

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

scheduler.shutdown()

scheduler.shutdown(wait=False)

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

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

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

標(biāo)簽: Python 編程
相關(guān)文章:
主站蜘蛛池模板: 狠狠综合久久av一区二区小说 | 日韩综合一区 | 日韩国产在线观看 | 欧美精品在线播放 | 99日韩 | 亚洲日韩中文字幕一区 | 黄色av网站在线观看 | 久久中文字幕一区 | 久久久精品亚洲 | 亚洲午夜精品一区二区三区 | 久久精品国产久精国产 | 欧美在线视频免费 | 三级av免费| 日韩欧美国产成人一区二区 | 国产精品一区二区三区四区五区 | 欧美中文字幕一区二区三区亚洲 | 亚洲精品免费在线观看 | 伊人久久免费 | 黄色片免费看 | 欧美性猛交一区二区三区精品 | 亚洲高清免费观看 | 国产免费福利 | 成人三级av| 国产电影一区 | 国产乱码精品一区二区三区中文 | 国产日韩欧美中文字幕 | 一区二区三区四区在线免费观看 | 国产日韩欧美一区 | 欧美日韩高清一区二区三区 | 成人免费三级电影 | 热久色| 不卡一二三区 | 神马九九| 欧美一区免费 | 99久久婷婷国产综合精品电影 | 日日骚网 | 欧美一区二区三区久久精品 | 免费成人在线网站 | 91av精品 | 一区二区精品电影 | 高清人人天天夜夜曰狠狠狠狠 |