无法在 Flask 应用程序中启动 Celery

Question

尝试启动 Celery worker (Windows) 时出现以下错误。

我正在使用 Celery 5.0.5。

celery.exe -A api.app -> ModuleNotFoundError: No module named 'api'

ma​​in.py

import os

from api.app import create_app

app = create_app(os.getenv("FLASK_ENV"))

if __name__ == '__main__':
    app.run(threaded=True, host='0.0.0.0')

api\app.py

from celery import Celery
from flask import Flask
from flask_redis import FlaskRedis
from flask_restful import Api
from api.config import env_config


redis_client = FlaskRedis()
celery = Celery(__name__, broker="redis://...")


def create_app(config_name):
    import resources

    app = Flask(__name__)
    app.config.from_object(env_config[config_name])
    redis_client.init_app(app)

    app.config.update(
        CELERY_BROKER_URL="redis://...",
        CELERY_RESULT_BACKEND="redis://..."
    )
    celery.conf.update(app.config)

    with app.app_context():
        from .routes import ccl_routes
        from .routes import scan_routes

    return app

文件夹结构如下：

helheim
| |api
|   |app.py
|   |__init.py__
|main.py

我做错了什么？这里已经很晚了，所以可能很明显但看不到它:)

谢谢！

Answer 1

编辑：我认为您可以在进行任何重大更改之前尝试celery -A api.app.celery worker。

不知道你的整个文件结构是什么样的，但例如

project
| |_api
|   |_app
_...

您应该以celery -A project.api.app.celery worker 开头。将 .celery 替换为您的 celery 实例名称。或者你也可以参考这个repo https://github.com/mushcatshiro/flask-template。

还请注意，根据我的经验，在 Windows 上使用 celery 4.X 有点挑战性，请改用 celery 5.0。