airflow.providers.google.cloud.sensors.cloud_composer¶
此模块包含 Cloud Composer 传感器。
模块内容¶
类¶
检查 DAG 运行是否已完成。 |
- class airflow.providers.google.cloud.sensors.cloud_composer.CloudComposerDAGRunSensor(*, project_id, region, environment_id, composer_dag_id, allowed_states=None, execution_range=None, gcp_conn_id='google_cloud_default', impersonation_chain=None, deferrable=conf.getboolean('operators', 'default_deferrable', fallback=False), poll_interval=10, **kwargs)[源代码]¶
基类:
airflow.sensors.base.BaseSensorOperator检查 DAG 运行是否已完成。
- 参数
project_id (str) – 必需。服务所属的 Google Cloud 项目的 ID。
region (str) – 必需。服务所属的 Google Cloud 区域的 ID。
environment_id (str) – Composer 环境的名称。
composer_dag_id (str) – 可执行 DAG 的 ID。
allowed_states (collections.abc.Iterable[str] | None) – 允许的状态的可迭代对象，默认为
['success']。execution_range (datetime.timedelta | list[datetime.datetime] | None) – 执行 DAG 的时间范围。传感器仅检查在此时间范围内启动的 DAG 的状态。对于昨天，使用 [正值!] datetime.timedelta(days=1)。对于未来，使用 [负值!] datetime.timedelta(days=-1)。对于特定时间，使用日期时间列表 [datetime(2024,3,22,11,0,0), datetime(2024,3,22,12,0,0)]。或者 [datetime(2024,3,22,0,0,0)]，在这种情况下，传感器将检查从过去特定时间到当前时间执行的状态。默认值 datetime.timedelta(days=1)。
gcp_conn_id (str) – 获取连接信息时使用的连接 ID。
impersonation_chain (str | collections.abc.Sequence[str] | None) – 可选的服务帐户，使用短期凭据进行模拟，或获取列表中最后一个帐户的 access_token 所需的帐户链表，该帐户将在请求中被模拟。如果设置为字符串，则该帐户必须授予原始帐户服务帐户令牌创建者 IAM 角色。如果设置为序列，则列表中的身份必须将服务帐户令牌创建者 IAM 角色授予紧随其后的身份，列表中的第一个帐户将此角色授予原始帐户（已模板化）。
poll_interval (int) – 可选：控制对可延迟运行结果的轮询速率。
deferrable (bool) – 在可延迟模式下运行传感器。