Django中celery异步任务队列的实现

Celery异步任务队列

本质：通过创建进程调用函数来实现任务的异步执行。

概念：

• 任务发出者：发出任务(要执行函数)消息
• 任务执行者：提前创建的进程
• 中间人(任务队列)：存放发出任务消息

使用：
1）安装：

pip install celery

2）创建一个

Celery

# main.py
from celery import Celery

# 创建Celery类对象
celery_app = Celery('demo')

# 加载配置信息
celery_app.config_from_object('配置文件包路径')

# celery worker启动时自动发现任务函数
celery_app.auto_discover_tasks([...])

# config.py
# 设置中间人地址
# broker_url = 'redis://<ip>:<port>/<db>'
broker_url = 'redis://172.16.179.139:6379/3'

3）封装任务函数

@celery_app.task(name='send_sms_code')def send_sms_code(a, b):
# 任务函数的代码...

4）启动

worker

xxxxxxxxxx celery -A 'celery_app对象所在文件包路径' worker -l info

5）发出任务消息

send_sms_code.delay(1, 3)

Django中celery异步任务队列搭建完毕！