气流 RabbitMQ 传感器

Airflow RabbitMQ sensor

是否存在订阅 RabbitMQ 队列中消息的气流传感器?

我注意到有一个 PubSub sensor 可以实现与我想要的相似的效果。

我可以使用 PythonOperator 轻松完成此操作,但我发现 RabbitMQ 传感器尚不存在很奇怪。

我是不是漏掉了什么明显的东西?

我认为不会 - 你不会错过任何东西。 Airflow 是一个开源项目,拥有近 1800 名贡献者。并且可能 none 他们贡献了 RabbitMQ 传感器。

这对您来说是个好机会 - 创建一个新的提供者并在那里贡献一个 RabbitMQ 传感器怎么样?

很高兴帮助和审查 PR!