Python Celery定時任務詳細講解

2022-08-01 22:02:10

前言

Celery在python中的應用除了實現非同步任務（async task)外也可以執行定時任務(beat)

一、Celery定時任務是什麼？

Celery預設任務單元由任務生產者觸發,但有時可能需要其自動觸發,而Beat程序正是負責此類任務,能夠自動觸發定時/週期性任務.

Celery 進行週期任務也很簡單，只需要在設定中設定好週期任務，然後在執行一個週期任務觸發器(beat)即可,具體網上看

二、使用步驟

win10 + python3 + redis + celery 5

1.程式碼結構

celery_config.py設定:

程式碼如下（範例）：

#-*-coding=utf-8-*-
from datetime import timedelta
from celery.schedules import crontab
# 中介軟體
BROKER_URL = 'redis://scck2svr03:6379/6'
# 結果儲存
# CELERY_RESULT_BACKEND = 'redis://:scck2svr03:6379/5'
CELERYD_CONCURRENCY = 20  # 並行worker數
CELERYD_FORCE_EXECV = True  # 非常重要,有些情況下可以防止死鎖
# CELERY_TASK_SERIALIZER = 'msgpack' # 任務序列化和反序列化使用msgpack方案
CELERY_RESULT_SERIALIZER = 'json'  # 讀取任務結果一般效能要求不高，所以使用了可讀性更好的JSON
CELERY_TASK_RESULT_EXPIRES = 60 * 60 * 24  # celery任務結果有效期
CELERY_ACCEPT_CONTENT = ['json', 'msgpack']  # 指定接受的內容型別
CELERY_TIMEZONE = 'Asia/Shanghai'  # celery使用的時區
CELERY_ENABLE_UTC = True  # 啟動時區設定
# 預設worker佇列
#CELERY_DEFAULT_QUEUE = 'default'
# 非同步任務
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.啟動定時任務

程式碼如下（範例）：

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

終端1

終端2

3.執行結果

兩個定時任務，一個每分鐘執行，一個每10秒執行

結果如下：

總結

到此這篇關於Python Celery定時任務詳細講解的文章就介紹到這了,更多相關Python Celery 內容請搜尋it145.com以前的文章或繼續瀏覽下面的相關文章希望大家以後多多支援it145.com！