Messaging Triggers

Operators, sensors, and triggers in the Common Messaging provider serve as wrappers around those from other providers, specifically for message queues. They offer an abstraction layer to simplify usage and make it easier to switch between different queue providers.

Supported queue providers

  • Amazon SQS: SqsMessageQueueProvider

Add support for a provider

To support a new provider please follow the steps below:

1. Create a new class extending BaseMessageQueueProvider. Make sure it implements all abstract methods 2. Add this class to the list MESSAGE_QUEUE_PROVIDERS in airflow/providers/common/messaging/providers/__init__.py

Was this entry helpful?