airflow.providers.google.cloud.sensors.tasks

此模組包含 Google Cloud Task 感測器。

模組內容

類別

TaskQueueEmptySensor

從雲端任務佇列中提取任務計數;等待佇列回傳任務計數為 0。

class airflow.providers.google.cloud.sensors.tasks.TaskQueueEmptySensor(*, location, project_id=PROVIDE_PROJECT_ID, queue_name=None, gcp_conn_id='google_cloud_default', impersonation_chain=None, **kwargs)[原始碼]

基底類別: airflow.sensors.base.BaseSensorOperator

從雲端任務佇列中提取任務計數;等待佇列回傳任務計數為 0。

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

  • gcp_conn_id (str) – 用於連線到 Google Cloud 的連線 ID。

  • queue_name (str | None) – 需要任務空佇列感測的佇列名稱。

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

template_fields: collections.abc.Sequence[str] = ('project_id', 'location', 'queue_name', 'gcp_conn_id', 'impersonation_chain')[原始碼]
poke(context)[原始碼]

在衍生此類別時覆寫。

此條目是否有幫助?