airflow.providers.google.cloud.sensors.tasks¶
此模組包含一個 Google Cloud Task sensor。
類¶
從 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)[source]¶
基類：
airflow.sensors.base.BaseSensorOperator從 Cloud Task 佇列中拉取任務數量；等待佇列返回任務數量為 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（該帳號將在請求中被模擬）所需的鏈式帳號列表。如果設定為字串，則該帳號必須授予發起帳號 Service Account Token Creator IAM 角色。如果設定為序列，則列表中的身份必須授予直接前一個身份 Service Account Token Creator IAM 角色，其中列表中的第一個帳號授予發起帳號此角色（模板化）。
- template_fields: collections.abc.Sequence[str] = ('project_id', 'location', 'queue_name', 'gcp_conn_id', 'impersonation_chain')[source]¶