文章目录
- 简介
- 安装和配置
- 创建并调度任务
- 启动Celery Worker
- 在视图中调用异步任务
- 拓展功能
简介
Django Celery 是一个为Django应用程序提供异步任务处理能力的强大工具。它通过与消息代理（如RabbitMQ、Redis）集成，可以轻松地处理需要长时间运行的任务，例如发送电子邮件、生成报告、定时任务等。
安装和配置
首先，使用以下命令安装Celery和RabbitMQ：
pip install celery
然后，在Django项目的settings.py文件中添加以下配置：
# settings.py
CELERY_BROKER_URL = 'amqp://guest:guest@localhost'
CELERY_RESULT_BACKEND = 'rpc://'
这些配置指定了Celery使用RabbitMQ作为消息代理，并将结果存储在RPC后端中。
创建并调度任务
在Django应用程序中定义异步任务非常简单。在应用程序目录下创建tasks.py文件，编写异步任务的代码，例如：
# tasks.py
from celery import shared_task
@shared_task
def send_email():
# 发送电子邮件的逻辑
pass
然后可以使用Celery的调度功能来执行这些任务。例如，可以使用定时任务来调度发送邮件的任务：
# tasks.py
from celery import shared_task
from datetime import timedelta
from celery.schedules import crontab
from celery.task import periodic_task
@periodic_task(run_every=crontab(hour=8, minute=0, day_of_week="mon"))
def scheduled_task():
# 执行定时任务的逻辑
send_email.delay()
启动Celery Worker
要执行Celery任务，需要启动Celery Worker。在项目根目录下执行以下命令：
celery -A myproject worker --loglevel=info
这会启动Celery Worker，并开始监听任务队列以执行异步任务。
在视图中调用异步任务
在Django应用程序的视图中调用异步任务非常简单。导入任务并调用它即可，例如：
# views.py
from myapp.tasks import send_email
def my_view(request):
# 调用发送电子邮件的异步任务
send_email.delay()
这样，当调用send_email.delay()时，任务将被放入Celery队列中，并由Celery Worker异步执行。
通过以上步骤，你已经成功集成了Django和Celery，实现了在Django应用程序中处理异步任务的功能。 Celery的强大功能和灵活性使其成为处理异步任务的理想选择。
拓展功能
除了上述基本功能外，Django Celery还具有许多高级功能，如：
- 任务结果处理：Celery允许轻松处理异步任务的结果，包括获取任务状态、结果和异常信息。
- 任务重试和错误处理：可以配置Celery来自动重试失败的任务，并设置错误处理逻辑。
- 任务链和组合：可以使用Celery创建任务链和组合多个任务，实现复杂的工作流程。
- 监控和管理：通过Celery提供的监控工具和管理界面，可以方便地监控任务执行情况和管理任务队列。
通过以上功能，Django Celery不仅能满足基本的异步任务处理需求，还能处理复杂的任务调度和管理，为Django应用程序提供了强大的异步处理能力。
