airflow.providers.google.cloud.triggers.pubsub

此模組包含 Google Cloud Pubsub 觸發器。

模組內容

類別

PubsubPullTrigger

使用需要的參數初始化 Pubsub Pull Trigger。
class airflow.providers.google.cloud.triggers.pubsub.PubsubPullTrigger(project_id, subscription, max_messages, ack_messages, gcp_conn_id, poke_interval=10.0, impersonation_chain=None)[原始碼]

繼承自: airflow.triggers.base.BaseTrigger

使用需要的參數初始化 Pubsub Pull Trigger。

參數

  • project_id (str) – 訂閱的 Google Cloud 專案 ID (樣板化)

  • subscription (str) – Pub/Sub 訂閱名稱。請勿包含完整訂閱路徑。

  • max_messages (int) – 每次 PubSub pull 請求要檢索的最大訊息數

  • ack_messages (bool) – 若為 True，則每個訊息將立即確認，而非由任何下游任務確認

  • gcp_conn_id (str) – 參考 google cloud 連線 ID

  • poke_interval (float) – 檢查狀態的輪詢間隔（秒）

  • impersonation_chain (str | collections.abc.Sequence[str] | None) – 選擇性服務帳戶，用於使用短期憑證模擬身分，或取得清單中最後一個帳戶的 access_token 所需的鏈結帳戶清單，該帳戶將在請求中被模擬身分。 如果設定為字串，則帳戶必須授予原始帳戶「服務帳戶權杖建立者」IAM 角色。 如果設定為序列，則清單中的身分必須授予緊接在前的身分「服務帳戶權杖建立者」IAM 角色，清單中的第一個帳戶將此角色授予原始帳戶 (樣板化)。

serialize()[原始碼]

序列化 PubsubPullTrigger 參數和類別路徑。

async run()[原始碼]

在非同步環境中執行觸發器。

觸發器應在想要觸發事件時產生一個 Event，如果完成則傳回 None。單一事件觸發器應因此產生然後立即傳回。

如果它產生，則很可能很快會恢復，但也可能不會（例如，如果工作負載正在移至另一個觸發器程序，或者多事件觸發器用於單一事件任務延遲）。

在任何情況下，Trigger 類別都應假設它們將被持久化，然後依賴於在不再需要它們時調用 cleanup()。

async message_acknowledgement(pulled_messages)[原始碼]
hook()[原始碼]

此條目是否有幫助？