Flask Error: Unable to load celery application

Question

请帮我解决这个问题我在运行

的时候遇到了这个问题

celery -A app.celery worker --loglevel=info

错误：

Unable to load celery application.
The module app.celery was not found.

我的代码是--

#  Celery Configuration
from celery import Celery
from app import app
print("App Name=",app.import_name)

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

@celery.task
def download_content():
    return "hello"

目录结构-- newYoutube/app/auth/routes.py 并且此函数存在于 routes.py 中 auth 是蓝图。

Answer 1

通过

调用芹菜时

celery -A app.celery ...

celery 将在 app 命名空间中查找名称 celery，期望它包含 Celery 的实例。如果你把它放在其他地方（比如，在 app.auth.routes 中），那么 celery 将找不到它。

我有一个工作示例，您可以从 https://github.com/davewsmith/flask-celery-starter

或者，参考 Flask Mega Tutorial 的第 22 章，它使用 rx 而不是 celery，但是构建代码的一般方法是相似的。

Flask Error: Unable to load celery application

Flask Error: Unable to load celery application

python

celery

flask

celery-task

python-3.x