django中最新使用celery的方法

在 Django 中使用 Celery 的步骤如下：

安装 Celery：可以使用 pip install celery 命令进行安装。

配置 Celery：在 Django 项目的 settings.py 文件中添加以下内容：

CELERY_BROKER_URL = 'redis://localhost:6379/0'
CELERY_RESULT_BACKEND = 'redis://localhost:6379/0'
登录后复制
其中，CELERY_BROKER_URL 表示消息代理的地址，这里使用 Redis；CELERY_RESULT_BACKEND 表示 Celery 的结果存储方式，也使用了 Redis。

创建 Celery 应用：在 Django 项目的根目录下创建一个 celery.py 文件，添加以下内容：

import os
from celery import Celery

os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'your_project.settings')

app = Celery('your_project')
app.config_from_object('django.conf:settings', namespace='CELERY')
app.autodiscover_tasks()
登录后复制
其中，your_project 表示你的 Django 项目名称。

定义任务：在 Django 项目中的某个 app 中创建一个 tasks.py 文件，并添加以下内容：

from celery import shared_task

@shared_task
def add(x, y):
return x + y
登录后复制
这里定义了一个名为 add 的任务，使用了 shared_task 装饰器。

启动 Celery：在终端中输入命令 celery -A your_project worker -l info 启动 Celery。

调用任务：在 Django 项目中需要调用 Celery 任务的地方，可以使用以下代码：

from your_app.tasks import add

result = add.delay(4, 4)
print(result.get())
登录后复制
其中，add.delay(4, 4) 表示异步调用 add 任务，返回一个结果对象；result.get() 表示获取 add 任务执行的结果。
注意：需要在 Django 项目启动时加载 Celery 应用，可以在项目的 __init__.py 文件中添加以下代码：
from .celery import app as celery_app

__all__ = ('celery_app',)
登录后复制