如何让花的经纪人标签与Airflow和RabbitMq通过SSL合作

Question

在Flower中，当与Airflow 2.3.4、RabbitMQ over SSL和Celery Executitor 一起使用时，broker选项卡不会显示队列

据我所知，Flower需要两个参数才能使此选项卡工作：

1. broker_url，例如。amqp://username:[e-mail]:5671/？ssl=真
2. http_api，例如。https://username:[e-mail]:15672/api/

我不知道如何配置Airflow，以便将此信息正确传递给Flower，而Flower正在将ssl与RabbitMQ一起使用，并连接到端口15672上的http_api。

如果我破解Flower包中的broker.py，Flower中的broker选项卡工作正常。

Answer 1

您可以在启动花进程时将http_api作为额外参数传递：

airflow celery flower  --help
...
-a BROKER_API, --broker-api BROKER_API
...