如何修改Django Celery配置中的transport连接URL

1. 优先检查Celery实例初始化参数 #

你使用的Celery 5.x版本和Django集成时，必须在加载配置时指定namespace='CELERY'，才会自动读取Django settings中以CELERY_为前缀的配置项。请检查你的项目根目录下celery.py的初始化代码，修正为如下格式：

import os
from celery import Celery

# 替换为你项目的Django配置模块路径
os.environ.setdefault('DJANGO_SETTINGS_MODULE', '你的项目名.settings')

app = Celery('你的项目名')
# 核心配置：指定namespace才会加载CELERY_开头的配置
app.config_from_object('django.conf:settings', namespace='CELERY')
# 自动扫描各Django app下的tasks任务
app.autodiscover_tasks()

如果没有加namespace='CELERY'参数，你需要把settings里的配置项去掉CELERY_前缀，改为直接配置BROKER_URL、RESULT_BACKEND等。

2. 检查docker-compose配置是否存在变量覆盖 #

确认docker-compose.yml中celery服务的environment配置段，没有声明CELERY_BROKER_URL、BROKER_URL等环境变量。环境变量的优先级高于Django settings中的配置，会直接覆盖你写的配置值。

3. 强制显式指定broker配置 #

如果上述方法都不生效，可以直接在celery.py中显式赋值broker地址，强制覆盖默认值：

# 读取环境变量拼接broker地址，和你settings里的逻辑保持一致
REDIS_PASSWORD = os.getenv('REDIS_PASSWORD')
app.conf.broker_url = f'redis://:{REDIS_PASSWORD}@redis:6379/4'
app.conf.broker_transport_options = {'visibility_timeout': 3600}

验证方法 #

在celery.py的app.config_from_object行后添加打印代码，启动容器后查看日志即可确认配置是否正确加载：

print("加载的broker地址：", app.conf.broker_url)

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