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