訊息觸發器

Common Messaging 提供者中的 Operators、sensors 和 triggers 作為圍繞其他提供者(特別是針對訊息佇列的提供者)的包裝器。它們提供了一個抽象層,以簡化使用並更容易地在不同的佇列提供者之間進行切換。

支援的佇列提供者

  • Amazon SQS: SqsMessageQueueProvider

新增對提供者的支援

要支援新的提供者,請遵循以下步驟

1. 建立一個繼承 BaseMessageQueueProvider 的新類。確保它實現了所有抽象方法 2. 將此類別新增到 airflow/providers/common/messaging/providers/__init__.py 中的 MESSAGE_QUEUE_PROVIDERS 列表中

此條目有幫助嗎?