airflow.providers.google.cloud.sensors.datafusion¶
此模块包含 Google Cloud Data Fusion 传感器。
类¶
检查 Google Cloud Data Fusion 中管道的状态。 |
模块内容¶
- 类 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) – 如果您的管道属于 Basic 版本实例，则命名空间 ID 始终为 default。如果您的管道属于 Enterprise 版本实例，则可以创建命名空间。
gcp_conn_id (str) – 获取连接信息时使用的连接 ID。
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] = ('pipeline_id',)[源代码]¶