使用场景:
1. 异步任务时候用,如发送验证码(不能是同步操作)
2. 定时任务时候用
异步任务定义:
1. settings同级目录创建文件celery.py
from __future__ import absolute_import, unicode_literals import os from celery import Celery os.environ.setdefault(‘DJANGO_SETTINGS_MODULE‘, ‘integral_mall.settings‘) # 设置django环境 app = Celery(‘integral_mall‘) # 项目名 app.config_from_object(‘django.conf:settings‘, namespace=‘CELERY‘) # 使用CELERY_ 作为前缀,在settings中写配置 app.autodiscover_tasks() # 发现任务文件每个app下的task.py
# 标红地方需要改成项目名称
2. settings添加celery配置
# celery配置 CELERY_BROKER_URL = ‘redis://:redis密码@redis机器ip:redis端口/redis库‘ # Broker配置,使用Redis作为消息中间件 CELERY_RESULT_BACKEND = ‘redis://:redis密码@redis机器ip:redis端口/redis库‘ # BACKEND配置,这里使用redis CELERY_RESULT_SERIALIZER = ‘json‘ # 结果序列化方案
演示:
原文:https://www.cnblogs.com/zezhou/p/13331042.html