如何配置Airflow使Flower的Broker标签在RabbitMQ SSL环境下正常工作？

要让Flower的Broker标签正常显示RabbitMQ队列（SSL连接场景），无需修改Flower源码，直接通过Airflow配置传递所需参数即可，具体配置方式如下：

1. 确保Celery Broker URL配置正确 #

Airflow的Celery Executor已在airflow.cfg的[celery]段配置Broker地址，Flower会默认继承该配置。针对SSL连接的RabbitMQ，需保证broker_url格式合规：

[celery]
# 基础SSL连接格式
broker_url = amqp://<用户名>:<密码>@<rabbitmq域名>:5671/?ssl=true
# 若需严格SSL验证（如自签名证书），添加证书路径参数
# broker_url = amqp://<用户名>:<密码>@<rabbitmq域名>:5671/?ssl=true&ssl_ca_certs=/path/to/ca.pem&ssl_certfile=/path/to/client_cert.pem&ssl_keyfile=/path/to/client_key.pem

2. 配置RabbitMQ HTTP API访问地址 #

Flower需要通过RabbitMQ的15672端口HTTP API获取队列数据，可通过以下两种方式配置：

方式一：通过airflow.cfg的[flower]段配置 #

在airflow.cfg中添加flower_options参数，直接传递broker_api选项：

[flower]
# 基础API地址配置
flower_options = --broker_api=https://<用户名>:<密码>@<rabbitmq域名>:15672/api/
# 若API需SSL验证，添加证书验证参数（生产环境推荐）
# flower_options = --broker_api=https://<用户名>:<密码>@<rabbitmq域名>:15672/api/ --broker_api_verify=/path/to/ca.pem
# 测试环境可临时跳过验证（不推荐生产）
# flower_options = --broker_api=https://<用户名>:<密码>@<rabbitmq域名>:15672/api/ --broker_api_verify=false

方式二：通过环境变量配置（适合容器化部署） #

设置对应环境变量，Airflow启动Flower时会自动读取：

# 设置API地址
export FLOWER_BROKER_API_URL=https://<用户名>:<密码>@<rabbitmq域名>:15672/api/
# 可选：设置SSL验证方式
# export FLOWER_BROKER_API_VERIFY=/path/to/ca.pem
# 或跳过验证
# export FLOWER_BROKER_API_VERIFY=false

3. 重启Flower服务 #

修改配置后，重启Airflow的Flower服务使配置生效：

airflow celery flower

完成以上配置后，Flower的Broker标签即可正常显示RabbitMQ队列信息，无需修改Flower的broker.py源码。

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