celery ImportError: No module named 'tasks'

Question

我正在尝试学习如何使用 celery 稍后集成到我的 Flask 应用程序中。我只是想执行在 Celery Docs 上找到的基本示例我创建了一个名为 task.py 的文件，并从文件 task.py 所在的文件夹中创建了我运行 celery -A tasks worker --loglevel=info 但它给出了一个错误。我似乎无法弄清楚哪里出了问题。

from celery import Celery

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

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

我看到的错误

celery -A tasks worker --loglevel=info

ImportError: 没有名为 'tasks'

的模块

Answer 1

尝试从应用程序文件夹级别执行命令。如果您的 tasks.py 在 flask_app/configs/tasks.py 中，则运行从 flask_app 文件夹中执行以下命令。

celery worker --app=configs.tasks:app --loglevel=info

如果你想守护 celery 使用下面的命令

celery multi start worker --app=configs.tasks:app --loglevel=info

** 多启动将守护芹菜，

如果应用程序运行在其中运行，请确保在运行命令之前激活 virtualenv。

我在 django 中使用 django-celery 成功运行ning 芹菜，遇到了同样的问题。

celery ImportError: No module named 'tasks'

celery ImportError: No module named 'tasks'

celery

celery-task

django-celery