celery worker启动失败因未配置broker_url，需显式设置app.conf.broker_url或通过config_from_object加载；flask中调用delay无反应多因worker未加载最新任务模块或序列化不匹配。
celery worker 启不起来，报错 KeyError: 'broker_url'
没配好消息中间件地址，Celery 就不知道往哪儿发任务。这个错误说明 celery 实例初始化时根本没读到 broker_url 配置。
- 检查是否在
celery.py或配置模块里显式设置了app.conf.broker_url，或通过app.config_from_object()加载了含该键的配置字典/模块 - 别依赖环境变量自动注入——除非你明确调用了
os.environ.get('CELERY_BROKER_URL')并赋值，否则 Celery 不会自己去查 - 常见误操作：只写了
result_backend却漏了broker_url；或者把配置写在 Flask 的app.config里，但没桥接到 Celery 实例 - 推荐写法：
app = Celery('myapp') app.conf.broker_url = 'redis://localhost:6379/0' app.conf.result_backend = 'redis://localhost:6379/1'
用 Flask 调用 delay() 没反应，也没报错
任务发出去了，但 worker 没消费，通常不是代码问题，而是进程隔离或序列化失配。
- 确认 worker 进程启动时加载的是同一份任务模块（比如
tasks.py），路径、包结构、Python 版本都得一致；改了任务函数却忘了重启 worker，就会静默失败 - Flask 中调用
my_task.delay()前，确保my_task是从 Celery 实例上 import 来的，而不是本地重新定义的同名函数 - 默认用
pickle序列化，但生产环境常禁用它；如果开了task_serializer = 'json'，就别在任务参数里传datetime、Decimal这类非 JSON 原生类型，否则会卡在 broker 层无提示 - 加一句
print(app.control.inspect().active())在 Flask 视图里，看任务是否真进队列了
apply_async() 和 delay() 选哪个？参数怎么传才不丢
delay() 只是 apply_async() 的语法糖，所有关键控制都在后者里。不用 delay()，直接上 apply_async() 更可控。
-
delay(a, b)等价于apply_async(args=[a, b])；但如果你想设重试、超时、路由、优先级，必须用apply_async() - 传参别用关键字参数混搭：比如
apply_async(args=[x], kwargs={'y': z})可以，但apply_async(x, y=z)会报错——Celery 不支持这种调用签名 - 异步任务里不能访问 Flask 的
request或g对象，它们只在请求上下文里存在；需要的数据必须在调用apply_async()时全部塞进args或kwargs - 大对象（如文件内容、数据库记录）别直接当参数传，改用 ID + 任务内查库，避免序列化开销和 broker 压力
任务执行完查不到 result.get() 返回值
不是任务没跑，而是结果后端没配对、过期了，或者你根本没等它跑完。
-
result.get()是阻塞调用，如果任务耗时长又没设timeout，会一直卡住；线上绝对要加timeout=30这类限制 - 确认
result_backend和broker_url指向不同 Redis DB（或至少不同 key 前缀），否则可能相互覆盖 - 默认结果保留 1 天，但如果你改过
result_expires（比如设成 60），而客户端隔 2 分钟才去取，就返回None—— 查日志会看到Result not found - 用
result.ready()先判断是否完成，比盲等更稳妥；尤其对长任务，建议前端轮询/task/status/<id></id>接口，而不是后端死等
Python免费学习笔记（深入）：立即使用
在学习笔记中，你将探索 Python 的核心概念和高级技巧！
