Django的Celery与Flask的异步任务处理

Django 是一个基于 Python 的高级 Web 开发框架，它鼓励快速开发和干净、实用的设计。Celery 是一个分布式任务队列，用于处理异步任务和消息传递。Flask 是一个轻量级的 Web 开发框架，用于构建 Web 应用程序。

将 Django 与 Celery 结合使用，可以在 Django 项目中轻松地处理异步任务。以下是如何在 Django 项目中使用 Celery 进行异步任务处理的步骤：

1. 安装 Celery 和 Redis（或其他消息代理）：

pip install celery redis

2. 在 Django 项目的根目录下创建一个名为 celery.py 的文件，用于配置 Celery：

from __future__ import absolute_import, unicode_literals
import os
from celery import Celery

# 设置默认的 Django 设置模块
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'your_project_name.settings')

app = Celery('your_project_name')

# 使用字符串来配置 Celery，这样 Celery 就不会在启动时查找模块
app.config_from_object('django.conf:settings', namespace='CELERY')

# 自动发现并加载任务模块
app.autodiscover_tasks()

3. 在 Django 项目的 settings.py 文件中，添加 Celery 配置：

# ...

# Celery 配置
CELERY_BROKER_URL = 'redis://localhost:6379/0'
CELERY_RESULT_BACKEND = 'redis://localhost:6379/0'
CELERY_ACCEPT_CONTENT = ['json']
CELERY_TASK_SERIALIZER = 'json'
CELERY_RESULT_SERIALIZER = 'json'
CELERY_TIMEZONE = 'UTC'

4. 在 Django 应用中创建一个名为 tasks.py 的文件，用于定义异步任务：

from celery import shared_task

@shared_task
def my_async_task(param1, param2):
    # 在这里执行异步任务
    pass

5. 在需要执行异步任务的地方，调用 my_async_task：

from .tasks import my_async_task

my_async_task.delay(param1, param2)

6. 运行 Celery worker：

celery -A your_project_name worker --loglevel=info

现在，当你在 Django 项目中调用 my_async_task.delay() 时，Celery 会将任务添加到消息队列中，并在后台异步执行。

Flask 与 Celery 的结合使用类似。首先，你需要在 Flask 应用中配置 Celery，然后定义异步任务并在需要时调用它们。这里是一个简单的例子：

1. 安装 Flask 和 Celery：

pip install flask celery redis

2. 创建一个名为 app.py 的 Flask 应用文件：

from flask import Flask
from celery import Celery

app = Flask(__name__)

# 配置 Celery
app.config['CELERY_BROKER_URL'] = 'redis://localhost:6379/0'
app.config['CELERY_RESULT_BACKEND'] = 'redis://localhost:6379/0'

celery = Celery(app.name, broker=app.config['CELERY_BROKER_URL'])
celery.conf.update(app.config)

@celery.task()
def my_async_task(param1, param2):
    # 在这里执行异步任务
    pass

@app.route('/')
def index():
    my_async_task.delay(param1, param2)
    return 'Async task started.'

if __name__ == '__main__':
    app.run()

3. 运行 Flask 应用：

python app.py

现在，当用户访问应用的根 URL 时，异步任务将被添加到消息队列中并在后台执行。