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)[source]¶
基类：
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')[source]¶