如何让Celery Worker获取与Flask一致的.env文件环境变量？

核心问题分析 #

启动Celery Worker时，没有加载.env文件中的环境变量，且Flask应用工厂的配置加载顺序错误，导致db.init_app(app)执行时无法获取SQLALCHEMY_DATABASE_URI，触发报错：

RuntimeError: Either 'SQLALCHEMY_DATABASE_URI' or 'SQLALCHEMY_BINDS' must be set.

单独启动Flask正常是因为Flask入口文件通常会自动加载.env，但Celery启动流程不会默认执行该操作。

解决方案步骤 #

1. 手动加载.env文件 #

Celery Worker启动时不会自动读取.env，需要在make_celery.py中显式加载：
首先确保安装依赖：

pip install python-dotenv

修改make_celery.py：

import os
from dotenv import load_dotenv

# 加载项目根目录下的.env文件
load_dotenv()

from app import create_app

flask_app = create_app(os.getenv('FLASK_CONFIG') or 'default')
celery_app = flask_app.extensions["celery"]

2. 调整Flask应用工厂的配置加载顺序 #

原来的create_app中，环境变量加载在db.init_app之后，导致初始化数据库时还未拿到环境变量。需要把环境变量加载步骤提前到db.init_app之前：

修改create_app函数：

from celery_app import celery_init_app
from config import config
from flask import Flask
from flask_sqlalchemy import SQLAlchemy

db = SQLAlchemy()


def create_app(config_name):
    app = Flask(__name__)
    # 1. 加载基础配置类
    app.config.from_object(config[config_name])
    config[config_name].init_app(app)
    
    # 2. 优先加载环境变量（覆盖基础配置），必须在db.init_app之前执行
    app.config.from_prefixed_env()
    
    # 3. 现在初始化SQLAlchemy，已能获取到环境变量中的数据库URI
    db.init_app(app)

    with app.app_context():
        # 导入模型（确保在app_context内导入，避免循环引用）
        # from .models import YourModel
        
        # 配置Celery
        app.config.from_mapping(
            CELERY=dict(
                broker_url="amqp://guest:guest@127.0.0.1:5672//",
                result_backend=app.config['CELERY_BACKEND_URL'],
                task_ignore_result=True,
            ),
        )
        celery_init_app(app)

    return app

3. 调试Celery Worker的小技巧 #

如果Worker启动后无控制台输出，可启动时指定更详细的日志级别：

celery -A make_celery worker --loglevel DEBUG

也可以在代码中添加print()或logging语句，输出关键配置值，排查环境变量是否正确加载。

额外检查点 #

• 确认.env文件中SQLALCHEMY_DATABASE_URI变量拼写正确（全大写，无拼写错误）
• 检查config[config_name]对应的配置类中，是否正确从环境变量读取数据库配置，而非硬编码无效值

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