訊息觸發器¶
Common Messaging 提供者中的 Operators、sensors 和 triggers 作為圍繞其他提供者(特別是針對訊息佇列的提供者)的包裝器。它們提供了一個抽象層,以簡化使用並更容易地在不同的佇列提供者之間進行切換。
支援的佇列提供者¶
Amazon SQS:
SqsMessageQueueProvider
新增對提供者的支援¶
要支援新的提供者,請遵循以下步驟
1. 建立一個繼承 BaseMessageQueueProvider 的新類。確保它實現了所有抽象方法 2. 將此類別新增到 airflow/providers/common/messaging/providers/__init__.py 中的 MESSAGE_QUEUE_PROVIDERS 列表中