Python?Celery定時(shí)任務(wù)詳細(xì)講解

更新時(shí)間：2022年08月01日 16:54:39 作者：panda_225400

這篇文章主要介紹了Python?Celery定時(shí)任務(wù)詳細(xì)講解，文章圍繞主題展開詳細(xì)的內(nèi)容介紹，具有一定的參考價(jià)值，需要的朋友可以參考一下

前言

Celery在python中的應(yīng)用除了實(shí)現(xiàn)異步任務(wù)（async task)外也可以執(zhí)行定時(shí)任務(wù)(beat)

一、Celery定時(shí)任務(wù)是什么？

Celery默認(rèn)任務(wù)單元由任務(wù)生產(chǎn)者觸發(fā),但有時(shí)可能需要其自動(dòng)觸發(fā),而Beat進(jìn)程正是負(fù)責(zé)此類任務(wù),能夠自動(dòng)觸發(fā)定時(shí)/周期性任務(wù).

Celery 進(jìn)行周期任務(wù)也很簡(jiǎn)單，只需要在配置中配置好周期任務(wù)，然后在運(yùn)行一個(gè)周期任務(wù)觸發(fā)器(beat)即可,具體網(wǎng)上看

二、使用步驟

win10 + python3 + redis + celery 5

1.代碼結(jié)構(gòu)

celery_config.py配置:

代碼如下（示例）：

#-*-coding=utf-8-*-
from datetime import timedelta
from celery.schedules import crontab
# 中間件
BROKER_URL = 'redis://scck2svr03:6379/6'
# 結(jié)果存儲(chǔ)
# CELERY_RESULT_BACKEND = 'redis://:scck2svr03:6379/5'
CELERYD_CONCURRENCY = 20  # 并發(fā)worker數(shù)
CELERYD_FORCE_EXECV = True  # 非常重要,有些情況下可以防止死鎖
# CELERY_TASK_SERIALIZER = 'msgpack' # 任務(wù)序列化和反序列化使用msgpack方案
CELERY_RESULT_SERIALIZER = 'json'  # 讀取任務(wù)結(jié)果一般性能要求不高，所以使用了可讀性更好的JSON
CELERY_TASK_RESULT_EXPIRES = 60 * 60 * 24  # celery任務(wù)結(jié)果有效期
CELERY_ACCEPT_CONTENT = ['json', 'msgpack']  # 指定接受的內(nèi)容類型
CELERY_TIMEZONE = 'Asia/Shanghai'  # celery使用的時(shí)區(qū)
CELERY_ENABLE_UTC = True  # 啟動(dòng)時(shí)區(qū)設(shè)置
# 默認(rèn)worker隊(duì)列
#CELERY_DEFAULT_QUEUE = 'default'
# 異步任務(wù)
CELERY_IMPORTS = (
    "celery_learning.email.tasks"
)
# celery beat
CELERYBEAT_SCHEDULE = {
    'periodic_task-every-minute': {
        'task': 'celery_learning.email.tasks.add',
        'schedule': crontab(minute="*/1"),
        'args': (1,2)
    },
    'periodic_task-every-10second':{
        'task':'celery_learning.email.tasks.add',
        'schedule':timedelta(seconds=10),
        'args':(1,12)
    }
}

2.啟動(dòng)定時(shí)任務(wù)

代碼如下（示例）：

終端1:celery -A celery_learning.celery_app worker -l info -P gevent
終端2:celery -A celery_learning.celery_app beat

終端1

終端2

3.執(zhí)行結(jié)果

兩個(gè)定時(shí)任務(wù)，一個(gè)每分鐘執(zhí)行，一個(gè)每10秒執(zhí)行

結(jié)果如下：

總結(jié)

到此這篇關(guān)于Python Celery定時(shí)任務(wù)詳細(xì)講解的文章就介紹到這了,更多相關(guān)Python Celery 內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章:

国产无遮挡裸体免费直播视频,久久精品国产蜜臀av,动漫在线视频一区二区,欧亚日韩一区二区三区,久艹在线免费视频,国产精品美女网站免费,正在播放 97超级视频在线观看,斗破苍穹年番在线观看免费,51最新乱码中文字幕

Python?Celery定時(shí)任務(wù)詳細(xì)講解

目錄

前言

一、Celery定時(shí)任務(wù)是什么？