消息触发器¶
Common Messaging 提供者中的 Operators、sensors 和 triggers 作为围绕其他提供者(特别是针对消息队列的提供者)的包装器。它们提供了一个抽象层,以简化使用并更容易地在不同的队列提供者之间进行切换。
支持的队列提供者¶
Amazon SQS:
SqsMessageQueueProvider
添加对提供者的支持¶
要支持新的提供者,请遵循以下步骤
1. 创建一个继承 BaseMessageQueueProvider
的新类。确保它实现了所有抽象方法 2. 将此类别添加到 airflow/providers/common/messaging/providers/__init__.py
中的 MESSAGE_QUEUE_PROVIDERS
列表中