airflow.providers.google.cloud.sensors.tasks
¶
此模組包含 Google Cloud Task 感測器。
模組內容¶
類別¶
從雲端任務佇列中提取任務計數;等待佇列回傳任務計數為 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')[原始碼]¶