Celery无法读取Django外置配置文件中RABBITMQ_BROKER变量问题咨询

问题原因 #

你的Celery默认加载的是项目根目录下的主配置文件，没有读取外置覆盖配置，具体根因如下：

• celery.py中硬编码了默认加载的Django配置模块为mydangoproject.settings，也就是 /opt/mydangoproject/settings.py
• 你提到Django可以正常加载外置配置，是因为启动Django服务时你应该已经通过环境变量或者配置逻辑指定了加载/etc/opt/mydangoproject/settings.py，但Celery启动时没有沿用这个配置，只会读取celery.py中指定的默认配置模块，自然读不到外置配置里的RABBITMQ_BROKER变量。

修复方案 #

提供三种可选方案，按需选择即可：

方案1：启动Celery时手动指定配置（无需改代码，适合临时测试或多环境切换场景） #

启动Celery命令前新增两个环境变量，指定外置配置的导入路径和模块名：

PYTHONPATH=/etc/opt/mydangoproject DJANGO_SETTINGS_MODULE=settings celery -A mydangoproject worker -l info

如果用systemd管理Celery服务，直接在service配置文件的[Service]段加这两个环境变量即可。

方案2：修改Celery默认配置逻辑（一次修改永久生效） #

修改/opt/mydangoproject/celery.py，先将外置配置目录加入Python导入路径，再修改默认配置模块指向：

import os
import sys
from celery import Celery

# 新增：把外置配置目录加入Python导入路径
sys.path.insert(0, '/etc/opt/mydangoproject')

# 修改默认加载的配置模块为外置配置
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'settings')

app = Celery('mydangoproject')
default_config = 'mydangoproject.celery_config'
app.config_from_object(default_config)
app.autodiscover_tasks()

方案3：主配置自动加载外置覆盖（最稳妥，Django和Celery共用一套逻辑） #

在/opt/mydangoproject/settings.py末尾加入自动加载外置配置的逻辑，这样不管是Django还是Celery，只要加载主配置就会自动覆盖参数，不需要修改其他启动参数或代码：

import sys
# 把外置配置目录加入导入路径
sys.path.insert(0, '/etc/opt/mydangoproject')
try:
    # 加载外置覆盖配置，不存在也不报错
    from settings import *
except ImportError:
    pass

注意：你提供的路径中存在拼写不一致的问题，比如部分地方写的是mydangoproject，部分是mydjangoproject，实际配置时要确保路径和模块名拼写完全一致，否则会出现导入失败的问题。

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