如何在SSL上使用Airflow和RabbitMq在flower中使用经纪人选项卡?

okxuctiv  于 2022-11-08  发布在  RabbitMQ
关注(0)|答案(1)|浏览(190)

在Flower中,当将代理选项卡与Airflow 2.3.4、RabbitMQ over SSL和Celery Executor一起使用时,代理选项卡不显示队列
据我所知,Flower需要两个参数才能使此选项卡正常工作:
1.经纪人URL,例如amqp:username:password@somedomain.amazonaws.com:5671/?ssl=true

  1. http_api,例如https://username:password@somedomain.amazonaws.com:15672/api/
    我不知道如何配置Airflow,以便将此信息正确传递给Flower,而Flower正在使用带有RabbitMQ的ssl,并在端口15672上连接到http_api。
    如果我broker.py在花包中破解www.example.com,在花中的经纪人选项卡工作正常。
dgsult0t

dgsult0t1#

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

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

相关问题