Airflow Sensor - Queue Consume

Hey Guys -

As anyone tried creating a Airflow Plugin with a Sensor that consumes
messages from a RabbitMQ Queue?


If you have a working example, can you please let me know - if you used
RabbitMQ's Pika Library or anything else?

Krishna

Reply via email to