In the Airflow user interface, configure a connection with the Conn Type set to RabbitMQ. Configure the following fields:

• Conn Id: How you wish to reference this connection. The default value is rabbitmq_default.
• login: Login for the RabbitMQ server.
• password: Password for the RabbitMQ server.,
• port: Port for the RabbitMQ server, typically 5672.
• host: Host of the RabbitMQ server.
• vhost: The virtual host you wish to connect to.

The RabbitMQOperator publishes a message to your specificed RabbitMQ server.

Import into your DAG using:

from rabbitmq_provider.operators.rabbitmq import RabbitMQOperator

The RabbitMQSensor checks a given queue for a message. Once it has found a message the sensor triggers downstream proccesses in your DAG.

Import into your DAG using:

from rabbitmq_provider.sensors.rabbitmq import RabbitMQSensor

To run unit tests, use:

poetry run pytest .

A RabbitMQ instance is required to run the tests. Use the following command:

docker run --rm -it --hostname my-rabbit -p 15672:15672 -p 5672:5672 rabbitmq:3-management