消息触发器

Common Messaging 提供者中的 Operators、sensors 和 triggers 作为围绕其他提供者(特别是针对消息队列的提供者)的包装器。它们提供了一个抽象层,以简化使用并更容易地在不同的队列提供者之间进行切换。

支持的队列提供者

  • Amazon SQS: SqsMessageQueueProvider

添加对提供者的支持

要支持新的提供者,请遵循以下步骤

1. 创建一个继承 BaseMessageQueueProvider 的新类。确保它实现了所有抽象方法 2. 将此类别添加到 airflow/providers/common/messaging/providers/__init__.py 中的 MESSAGE_QUEUE_PROVIDERS 列表中

此条目有帮助吗?