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

此模块包含 Google Data Fusion 链接。

模块内容¶

类¶

`BaseGoogleLink`	Google 操作符的链接。
`DataFusionInstanceLink`	用于构建 Data Fusion 实例链接的帮助类。
`DataFusionPipelineLink`	用于构建 Data Fusion 管道链接的帮助类。
`DataFusionPipelinesLink`	用于构建 Data Fusion 管道列表链接的帮助类。

属性¶

`BASE_LINK`
`DATAFUSION_INSTANCE_LINK`
`DATAFUSION_PIPELINES_LINK`
`DATAFUSION_PIPELINE_LINK`

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

airflow.providers.google.cloud.links.datafusion.DATAFUSION_INSTANCE_LINK[源代码]¶

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

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

class airflow.providers.google.cloud.links.datafusion.BaseGoogleLink[源代码]¶

基类： airflow.models.BaseOperatorLink

Google 操作符的链接。

防止在每次使用 URI 时在每个链接前面添加 https://console.cloud.google.com。

name: ClassVar[str][源代码]¶

key: ClassVar[str][源代码]¶

format_str: ClassVar[str][源代码]¶

get_link(operator, *, ti_key)[源代码]¶

链接到外部系统。

注意：此函数的旧签名是 (self, operator, dttm: datetime)。这在运行时仍然受支持，但已弃用。

参数

operator (airflow.models.BaseOperator) – 与此链接关联的 Airflow 操作符对象。
ti_key (airflow.models.taskinstancekey.TaskInstanceKey) – 用于返回链接的 TaskInstance ID。

返回

链接到外部系统

返回类型

class airflow.providers.google.cloud.links.datafusion.DataFusionInstanceLink[源代码]¶

基类：BaseGoogleLink

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

name = 'Data Fusion 实例'[源代码]¶

key = 'instance_conf'[源代码]¶

format_str[源代码]¶

static persist(context, task_instance, location, instance_name, project_id)[源代码]¶

class airflow.providers.google.cloud.links.datafusion.DataFusionPipelineLink[源代码]¶

基类：BaseGoogleLink

用于构建 Data Fusion 管道链接的帮助类。

name = 'Data Fusion 管道'[源代码]¶

key = 'pipeline_conf'[源代码]¶

format_str[源代码]¶

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

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

基类：BaseGoogleLink

用于构建 Data Fusion 管道列表链接的帮助类。

name = 'Data Fusion Pipelines List'[源]¶

key = 'pipelines_conf'[源]¶

format_str[源]¶

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

此条目是否有帮助？