官方文档：First steps with Django — Celery 5.1.2 documentation (celeryproject.org)
踩坑记录
1.celery高版本不兼容windows，因此需要pip install eventlet来兼容windows
因此在启动celery时执行命令式
celery -A meiduo_mall worker -l info -P eventlet
补充：celery worker工作模式
celery -A celery_tasks.main worker -l info -P eventlet -c 1000 #将进程改变为协程
celery模块结构
image.png
main.py
# Celery入口文件
from celery import Celery
import os
os.environ.setdefault('DJANGO_SETTINGS_MODULE','meiduo_mall.settings_real.dev')
# 创建celery实例（生产者）
celery_app = Celery('meiduo_mall')
# 加载配置
celery_app.config_from_object('celery_tasks.config')
# 注册任务
celery_app.autodiscover_tasks(['celery_tasks.sms'])
config.py
# celery 配置文件
# 指定中间人
broker_url = 'redis://192.168.xx.xx:6379/10'
tasks.py
# 定义任务
from celery_tasks.sms.yuntongxun.ccp_sms import CCP
from . import constants
from celery_tasks.main import celery_app
# 使用装饰器装饰异步任务，保证celery识别任务
@celery_app.task(name='send_sms_code')
def send_sms_code(mobile,sms_code):
send_ret = CCP().send_template_sms(mobile, [sms_code, constants.SMS_CODE_REDIS_EXPIRES // 60], constants.SEND_SMS_TEMPLATE_ID)
return send_ret
工程文件中配置
image.png
image.png
