安装包
pip install celery
pip install eventlet 1.在项目文件的根目录下创建目录结果
2. 在main.py文件中
# !/usr/bin/env python
# -*-coding:utf-8 -*-
"""
# Author ：skyTree
# version ：python 3.11
# Description：celery 主文件
"""
from celery import Celery
# 1,创建celery实例对象
celery_app = Celery('meiduo')
# 2,加载配置文件
celery_app.config_from_object('celery_tasks.config')
# 3,自动注册异步任务
celery_app.autodiscover_tasks(['celery_tasks.sms'])3.config.py文件
# !/usr/bin/env python
# -*-coding:utf-8 -*-
"""
# Author ：skyTree
# version ：python 3.11
# Description：celery 配置文件
"""
# 指定任务队列的位置
broker_url = "redis://localhost:6379/0"4.在项目后端文件下执行启动命令，即可，此时说明clery已经安装成功！
# celery_tasks.main为celery包名加主文件
celery -A celery_tasks.main worker -l info5.在task.py文件中将发送短信的任务注册到task中必须使用装饰器并在装饰器中设置别名便于区分
# !/usr/bin/env python
# -*-coding:utf-8 -*-
"""
# Author ：skyTree
# version ：python 3.11
# Description：sms功能异步任务
"""
from .send_sms import Send_SMS
from ..main import celery_app
@celery_app.task(name='send_sms_code')
def send_sms_code(mobile, sms_code):
"""
发送短信验证码的celery异步任务
:param mobile: 手机号
:param sms_code: 验证码
:return:
"""
Send_SMS().send(mobile=mobile, code=sms_code)6.在视图函数中调用异步任务
# apply_async接受的参数必须为元组或者列表
result = send_sms_code.apply_async((mobile, sms_code,))
# 使用dealy方法也可以
result = send_sms_code.dealy(mobile, sms_code)
7.执行celery启动命令
注意： 必须使用 celery -A celery_tasks.main worker -l info -P eventlet 才会提示如下信息表示成功
如果使用 celery -A celery_tasks.main worker -l info 命令显示如下信息，此时任务根本没有执行文章来源：https://www.toymoban.com/news/detail-835341.html
文章来源地址https://www.toymoban.com/news/detail-835341.html
到了这里，关于Django使用Celery异步的文章就介绍完了。如果您还想了解更多内容，请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章，希望大家以后多多支持TOY模板网！
