不能在create_app()里直接创建Celery实例并调用init_app()，因Celery无此方法；须先声明实例，待Flask配置加载完毕后，用celery.conf.update(app.config)注入配置，并在配置后调用autodiscover_tasks()。
Flask应用工厂里怎么初始化Celery实例不报错
直接说结论：不能在 create_app() 里直接创建 Celery 实例并调用 init_app()，因为 Celery 本身没有 Flask 那样的 init_app() 方法；必须先创建实例，再延迟绑定 Flask 的配置（尤其是 broker_url 和 result_backend），且不能在模块顶层 import 时就触发 Flask app 创建逻辑。
常见错误现象是启动时报 RuntimeError: Working outside of application context，或者循环导入——比如 celery.py 里 import app，而 app.py 又 import celery。
- 把 Celery 实例声明放在独立模块（如
celery_worker.py或extensions.py），只创建不配置 - 用工厂函数返回的 app 实例去更新 Celery 的
conf.broker_url等字段，而不是靠init_app() - 确保
create_app()内部不 import 任何依赖已初始化 Celery 的模块
为什么不能在 create_app() 里 new Celery() 并传 app
Celery 不像 Flask-SQLAlchemy 那样支持延迟绑定 app 上下文。传入一个未完整初始化的 app（比如还没加载配置）会导致 celery.conf 读不到 CELERY_BROKER_URL，最终 fallback 到默认 localhost:6379，而你根本没配 Redis —— 这就是为什么本地跑通、部署就连不上 broker。
更隐蔽的问题是：如果你在 create_app() 里写 celery = Celery(app)，Celery 会立刻尝试从 app.config 读配置，但此时 app.config 可能还没被 app.config.from_object() 或 app.config.from_envvar() 填充。
立即学习“Python免费学习笔记（深入）”；
- Celery 初始化必须等 Flask 配置加载完成之后才执行
- 推荐做法：先
celery = Celery(__name__)，再手动celery.conf.update(app.config) - 注意
app.config里键名要和 Celery 期望的一致，比如CELERY_BROKER_URL要对应celery.conf.broker_url
如何避免 celery.py 和 app.py 相互 import
典型循环引入路径：app.py → create_app() → import tasks → tasks.py → import celery → celery.py → import app。只要任一环节提前触达了对方的模块级代码，就会卡死。
关键原则：所有对 Flask app 的引用，必须发生在函数内部（即运行时），不能出现在模块顶层（即 import 时）。
- 把 task 定义放在
tasks/子包里，且tasks/__init__.py不 import app 或 celery 实例 -
celery.py里只做实例创建和基础配置，不 importapp、不调用create_app() - 在
create_app()结尾处，用celery.conf.update(...)注入配置，再通过celery.autodiscover_tasks()加载任务
worker 启动命令怎么写才读得到配置
用 celery -A 启动时，如果入口模块（比如 celery_worker.py）里直接 new 了 Celery，又没显式加载 Flask 配置，它就只能看到默认值或环境变量——而你很可能把配置写在 config.py 里，靠 Flask 加载。
正确做法是让 worker 入口也走一遍 Flask 配置流程，但只取配置，不启 HTTP server。
- worker 入口（如
worker.py）里调用create_app()，拿到 app 后立即取app.config给 celery 设置 - 命令行启动写成：
celery -A worker.celery worker --loglevel=info - 别用
celery -A app.celery，因为app.py里的create_app()是函数，不是模块级实例
@task 函数。 
