airflow.providers.google.cloud.sensors.datafusion¶
此模块包含 Google Cloud Data Fusion 传感器。
模块内容¶
类¶
检查 Google Cloud Data Fusion 中管道的状态。 |
- class airflow.providers.google.cloud.sensors.datafusion.CloudDataFusionPipelineStateSensor(pipeline_name, pipeline_id, expected_statuses, instance_name, location, failure_statuses=None, project_id=PROVIDE_PROJECT_ID, namespace='default', gcp_conn_id='google_cloud_default', impersonation_chain=None, **kwargs)[源代码]¶
基类：
airflow.sensors.base.BaseSensorOperator检查 Google Cloud Data Fusion 中管道的状态。
- 参数
pipeline_name (str) – 您的管道名称。
pipeline_id (str) – 您的管道 ID。
expected_statuses (collections.abc.Iterable[str]) – 预期状态
failure_statuses (collections.abc.Iterable[str] | None) – 将以异常终止传感器的状态
instance_name (str) – 实例的名称。
location (str) – 用于处理请求的 Cloud Data Fusion 位置。
project_id (str) – 实例所属的 Google Cloud 项目的 ID。
namespace (str) – 如果您的管道属于基本版实例，则命名空间 ID 始终为默认。 如果您的管道属于企业版实例，则可以创建一个命名空间。
gcp_conn_id (str) – 获取连接信息时要使用的连接 ID。
impersonation_chain (str | collections.abc.Sequence[str] | None) – 使用短期凭据模拟的可选服务帐户，或获取列表中最后一个帐户的 access_token 所需的链式帐户列表，该帐户将在请求中被模拟。如果设置为字符串，则该帐户必须授予原始帐户“服务帐户令牌创建者”IAM 角色。 如果设置为序列，则列表中的标识必须将“服务帐户令牌创建者”IAM 角色授予紧随其后的标识，列表中的第一个帐户将此角色授予原始帐户（已模板化）。
- template_fields: collections.abc.Sequence[str] = ('pipeline_id',)[源代码]¶