我正在尝试学习如何使用芹菜,以便以后集成到我的烧瓶应用程序中。我只是在尝试执行在 Celery Docs 上找到的基本示例,我已经创建了一个名为 task.py 的文件,并从存在文件 task.py 的文件夹中运行芹菜 -A 任务工作者 --loglevel=info,但它给出了错误。我似乎无法弄清楚出了什么问题。
from celery import Celery
app = Celery('tasks', broker='amqp://localhost')
@app.task
def add(x, y):
return x + y
我看到的错误
芹菜 -A 任务工作者 --loglevel=info
导入错误:没有名为"任务"的模块
尝试从应用程序文件夹级别执行命令。如果您的 tasks.py 位于 flask_app/configs/tasks.py 中,请从文件夹内运行以下命令flask_app。
celery worker --app=configs.tasks:app --loglevel=info
如果要守护芹菜,请使用以下命令
celery multi start worker --app=configs.tasks:app --loglevel=info
** 多启动将守护芹菜,
并确保在运行命令之前激活 virtualenv(如果应用程序在命令中运行)。
我正在用姜戈芹菜成功地在 django 中运行芹菜,遇到了同样的问题。