Django 集成 Celery 实现高效的异步任务处理

# 在你的 Django 项目的 settings.py 文件中配置 Celery
# 假设你已经安装了 Celery 和支持的消息队列（例如：RabbitMQ 或 Redis）
 
# 设置 Celery 的 Broker URL，这里以 Redis 为例
CELERY_BROKER_URL = 'redis://localhost:6379/0'
# 设置 Celery 的结果存储后端，这里也以 Redis 为例
CELERY_RESULT_BACKEND = 'redis://localhost:6379/0'
 
# 在你的 Django 应用的 tasks.py 文件中定义你的异步任务
from celery import shared_task
 
@shared_task
def add(x, y):
    return x + y
 
# 在 Django 应用的 views.py 或其他适当的地方启动异步任务
from .tasks import add
 
def start_task():
    result = add.delay(4, 4)
    return result.id
 
# 使用 Django 管理命令启动 Celery 工人
# 在命令行中执行以下命令
# celery -A your_project worker -l info

这个例子展示了如何在 Django 项目中设置 Celery，定义一个简单的异步任务，以及如何在视图函数中启动这个任务。最后，提供了一个命令行启动 Celery 工人的例子。这样，你就可以在 Django 中使用 Celery 来处理异步任务了。