Celery任务无法发送至RabbitMQ Broker，调用apply_async时无限阻塞如何排查？

现象梳理 #

• 执行foo.s(first_arg="2").apply_async()时程序无限阻塞，无法返回AsyncResult对象
• 同任务用apply()同步执行逻辑完全正常
• Ctrl+C中断进程后，Traceback显示Kombu在反复重试连接，最终报本地5672端口连接被拒绝
• 同代码启动的Celery Worker，能正常连接实际RabbitMQ地址my-rabbit:5672并就绪
• 在生产端Python Shell中查看app连接池，实际指向amqp://guest:**@localhost:5672//
• 系统环境变量已配置CELERY_BROKER=pyamqp://guest@172.23.0.3//，但生产端app实例完全没有读取到该配置

根本原因 #

生产端导入的Celery app实例没有加载到正确的Broker连接配置，一直使用Celery内置默认地址localhost:5672发起连接。
由于本地5672端口没有运行RabbitMQ服务，Kombu触发内置的无限重试逻辑，每次重试间隔1秒，最终表现为程序挂起无响应。Traceback中出现的socket.gaierror: [Errno -9] Address family for hostname not supported是容器环境下本地地址解析的附带报错，本质还是因为程序在尝试连接不存在的本地Broker，和实际网络策略无关。
同配置下Worker能正常连接，是因为Worker启动流程加载了完整的项目配置，包括显式读取环境变量、指定配置文件的Broker地址；而Python Shell中导入的app实例存在配置加载遗漏，常见触发场景包括：

• celeryconfig.py中根本没有设置broker_url字段，Celery自动回退到默认的localhost地址
• 自定义命名的环境变量CELERY_BROKER没有被配置文件显式读取，Celery默认仅会自动识别和内置配置项名完全匹配的环境变量（如CELERY_BROKER_URL），不会自动把自定义变量映射到broker_url
• 查看连接时使用的app.pool.connection是app初始化阶段预建的连接池对象，地址在初始化时就已固定，哪怕后续修改app的Broker配置，连接池的旧地址也不会自动更新

排查修复步骤 #

1. 直接校验app实例本身的Broker配置，不要依赖连接池的返回值：

   from src.celery import app
   print(app.conf.broker_url)
   

   如果输出为默认的amqp://guest@localhost:5672//，即可确认配置未被正确加载。
2. 检查celeryconfig.py的配置逻辑：
   • 显式声明Broker地址读取逻辑，避免依赖Celery自动解析环境变量，例如：

     import os
     broker_url = os.getenv("CELERY_BROKER")
     

   • 注意Celery 5.x版本的配置项名全小写规范，老式的BROKER_URL写法已经废弃，无法被正确读取。
3. 配置修复后重新启动Python Shell验证：

   # 先确认配置生效
   assert app.conf.broker_url == "pyamqp://guest@172.23.0.3//"
   # 再执行异步任务发布
   promise = foo.s(first_arg="2").apply_async()
   

4. 可选优化：设置合理的连接重试规则，避免后续配置异常时程序无限挂起，可在配置中添加：

   broker_connection_retry_on_startup = False
   broker_connection_max_retries = 3
   broker_connection_timeout = 5
   

内容的提问来源于stack exchange，提问作者Anders_K