如何将Celery设置为Django的守护进程

2023-04-11 00:00:00 设置为守护如何将

要将Celery设置为Django的守护进程，可以按照以下步骤进行操作：

步骤1：安装Celery和Django-Celery

使用以下命令安装Celery和Django-Celery：

pip install celery django-celery

步骤2：在Django项目中设置Celery

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

import djcelery

# 设置消息中间件（RabbitMQ、Redis等）
BROKER_URL = 'amqp://guest@localhost//'

# 设置任务结果存储（数据库、Redis等）
CELERY_RESULT_BACKEND = 'db+sqlite:///results.sqlite'

# 设置Django-Celery
djcelery.setup_loader()

步骤3：创建Celery任务

创建一个tasks.py文件，并且在其中定义Celery任务：

from celery import Celery

app = Celery('tasks', broker='amqp://guest@localhost//')

@app.task
def add(x, y):
    return x + y

步骤4：启动Celery守护进程

运行以下命令来启动Celery守护进程：

celery worker -A myproject.celery -l info

这里的myproject是你的Django项目名称。

步骤5：测试Celery任务

在Django中使用tasks.add.delay(4, 4)来调用Celery任务：

from myproject.tasks import add

result = add.delay(4, 4)
print(result.get())

这里的myproject是你的Django项目名称。

以上就是将Celery设置为Django的守护进程的步骤，希望有帮助。

相关文章