airflow.providers.google.cloud.links.datafusion¶

此模块包含 Google Data Fusion 链接。

属性¶

`BaseGoogleLink`	Google operator 的链接。
`DataFusionInstanceLink`	用于构建 Data Fusion 实例链接的辅助类。
`DataFusionPipelineLink`	用于构建 Data Fusion Pipeline 链接的辅助类。
`DataFusionPipelinesLink`	用于构建 Data Fusion Pipelines 列表链接的辅助类。

airflow.providers.google.cloud.links.datafusion.BASE_LINK = 'https://console.cloud.google.com/data-fusion'[source]¶

airflow.providers.google.cloud.links.datafusion.DATAFUSION_INSTANCE_LINK = 'https://console.cloud.google.com/data-fusion/locations/{region}/instances/{instance_name}?projec...[source]¶

airflow.providers.google.cloud.links.datafusion.DATAFUSION_PIPELINES_LINK = '{uri}/cdap/ns/{namespace}/pipelines'[source]¶

airflow.providers.google.cloud.links.datafusion.DATAFUSION_PIPELINE_LINK = '{uri}/pipelines/ns/{namespace}/view/{pipeline_name}'[source]¶

class airflow.providers.google.cloud.links.datafusion.BaseGoogleLink[source]¶

基类: airflow.sdk.BaseOperatorLink

Google operator 的链接。

在使用 URI 的每个链接前，阻止添加 https://console.cloud.google.com。

get_link(operator, *, ti_key)[source]¶

外部系统的链接。

参数:

返回:

外部系统的链接

返回类型:

str

class airflow.providers.google.cloud.links.datafusion.DataFusionInstanceLink[source]¶

用于构建 Data Fusion 实例链接的辅助类。

format_str = 'https://console.cloud.google.com/data-fusion/locations/{region}/instances/{instance_name}?projec...[source]¶

static persist(context, task_instance, location, instance_name, project_id)[source]¶

class airflow.providers.google.cloud.links.datafusion.DataFusionPipelineLink[source]¶

用于构建 Data Fusion Pipeline 链接的辅助类。

static persist(context, task_instance, uri, pipeline_name, namespace)[source]¶

class airflow.providers.google.cloud.links.datafusion.DataFusionPipelinesLink[source]¶

用于构建 Data Fusion Pipelines 列表链接的辅助类。

static persist(context, task_instance, uri, namespace)[source]¶