Django 在生产环境中运行 Django-Celery

在本文中，我们将介绍如何在 Django 项目的生产环境中运行 Django-Celery。Django-Celery 是一个用于异步任务处理的 Django 应用，它可以将耗时的任务放到后台执行，从而提高网站的性能和效率。

为什么使用 Django-Celery

在开发现代化的 Web 应用程序时，经常会遇到一些需要耗费较长时间的任务，例如发送邮件、生成报表等。如果这些任务在用户请求的过程中直接执行，会导致用户等待时间过长，甚至导致应用程序崩溃。而 Django-Celery 可以将这些耗时任务放到后台执行，不影响用户体验。

使用 Django-Celery 的好处如下：

异步处理：Django-Celery 将任务放到消息队列中，通过 Celery Worker 异步执行，不阻塞主线程。
提高性能：将耗时任务放到后台执行，可以释放服务器资源，提高网站的响应速度。
分布式处理：Django-Celery 支持多个任务执行器，可以在多个节点上分布任务，提高处理能力。

配置 Django-Celery

步骤一：安装 Celery

首先，我们需要在 Django 项目中安装 Celery。通过 pip 命令执行以下命令：

pip install celery

步骤二：配置消息队列

Django-Celery 使用消息队列来实现任务的分发和执行，常用的消息队列有 RabbitMQ、Redis 等。在本例中，我们选择 Redis 作为消息队列。首先，确保你已经安装了 Redis，并在设置文件中做如下配置：

# settings.py

CELERY_BROKER_URL = 'redis://localhost:6379/0'

步骤三：创建 tasks.py

在 Django 项目的根目录下创建一个名为 tasks.py 的文件，用于定义需要异步执行的任务。例如，我们创建一个发送邮件的任务：

# tasks.py

from celery import shared_task
from django.core.mail import send_mail

@shared_task
def send_email_task(subject, message, from_email, recipient_list):
    send_mail(subject, message, from_email, recipient_list)

步骤四：启动 Celery Worker

在项目的根目录下执行以下命令，启动 Celery Worker：

celery -A your_project_name worker -l info

在生产环境中使用 Django-Celery

在生产环境中使用 Django-Celery 时，我们需要注意以下几点：

使用 Celery Worker 来处理任务，确保设置 -l info 参数以记录日志，方便排查问题。
使用 Supervisor 或者 Systemd 等工具来管理 Celery Worker 进程，确保进程崩溃时能够自动重启。
配置 Celery Worker 进程数以及并发数，根据服务器资源和任务类型来调整。

下面是一个使用 Supervisor 管理 Celery Worker 的示例配置文件：

[program:celery]
command=/path/to/your/virtualenv/bin/celery -A your_project_name worker -l info
directory=/path/to/your/project
autostart=true
autorestart=true
redirect_stderr=true
user=your_username