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]¶