django中celery的定時(shí)任務(wù)使用

更新時(shí)間：2023年09月19日 14:53:21 作者：Li- Li

這篇文章主要介紹了django中celery的定時(shí)任務(wù)使用方式,具有很好的參考價(jià)值,希望對(duì)大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教

1.celery 的介紹

1.1celery的基本介紹

celery是基于python實(shí)現(xiàn)的一個(gè)異步任務(wù)的調(diào)用工具，同時(shí)還是一個(gè)任務(wù)隊(duì)列，主要用于處理耗時(shí)的任務(wù)。

celery也被稱為芹菜。

celery架構(gòu)由三個(gè)模塊組成：消息中間件，任務(wù)執(zhí)行單元和任務(wù)執(zhí)行結(jié)果儲(chǔ)存組成。

其實(shí)那在剛接觸的時(shí)候小編的理解是：

老板把地皮交給包工頭去干讓包工頭把房子建好然后包工頭找了工人把任務(wù)分配給工人讓工人去干最后工人蓋好房子老板驗(yàn)收（這是小編自己的理解也就適合入門）

1.2什么是celery beat

celery支持定時(shí)任務(wù)，設(shè)定好任務(wù)的執(zhí)行時(shí)間，

celery就會(huì)定時(shí)自動(dòng)幫你執(zhí)行，這個(gè)定時(shí)任務(wù)模塊叫celery beat

2.celery定時(shí)任務(wù)的配置

__init__.py

里面主要是celery初始化配置

from datetime import timedelta
from celery import Celery
import os
import django
os.environ.setdefault("DJANGO_SETTINGS_MODULE", "自己的項(xiàng)目名.settings")
django.setup()
celery_app = Celery('mycelery')
#讀取celery 的配置
celery_app.config_from_object('celery_task.config')
# 定時(shí)任務(wù)
                             # 文件夾名.文件名
celery_app.autodiscover_tasks(['celery_task.times'])
celery_app.conf.update(
    CELERYBEAT_SCHEDULE={
        'sum-task': {
             # 文件夾名.文件名.方法名
            'task': 'celery_task.times.my_con',
             # 多少秒執(zhí)行一次（eg:5秒一執(zhí)行）
            'schedule':  timedelta(seconds=5),
             # 這是傳入my_con方法中的參數(shù)
            'args': (5, 6)
        },
        'sum-task1': {
            'task': 'celery_task.times.my_print',
            'schedule':  timedelta(seconds=3),
            'args': ()
        },
    }
)

config.py

"""
    celery 配置
"""
消息中間件 broker
BROKER_URL = 'redis://xx.xx.xx.xx:6379/11'
任務(wù)結(jié)果存儲(chǔ) results  backend
    CELERY_RESULT_BACKEND = 'redis://xx.xx.xx.xx:6379/12'
    # 時(shí)區(qū)
    CELERY_TIMEZONE = 'Asia/Shanghai'
    # 導(dǎo)入指定的任務(wù)模塊
    CELERY_IMPORTS = (
        'celery_task.tasks'
    )

task.py 里面寫的是異步任務(wù)就不展示了

times.py

里面寫的是定時(shí)任務(wù)

# 定時(shí)任務(wù)
import time
from celery_task import celery_app
@celery_app.task()
def my_con(x,y):
    print(x,y)
    print('x和y相加')
    return x+y
@celery_app.task()
def my_print():
    print('22222222')