托管式连接概览

托管式连接流水线会将元数据从第三方来源导入 Knowledge Catalog（原 Dataplex Universal Catalog）。您可以使用这些流水线将元数据大规模导入 Knowledge Catalog，以便从数据源中提取数据。流水线还会根据需要在您的Google Cloud 项目中创建 Knowledge Catalog 条目组。通过这种方法，您可以根据自己的要求编排工作流和安排导入作业。

您可以构建自定义连接器，以从各种第三方来源（包括 MySQL、SQL Server、Oracle、Snowflake 和 Databricks）提取元数据。或者，您也可以使用社区贡献的自定义连接器来连接更多数据源。

托管式连接的运作方式

下图展示了托管式连接流水线。

托管式连接流水线。

概括来讲，托管式连接的运作方式如下：

  1. 您为数据源构建连接器。

    连接器必须是一个可在 Managed Service for Apache Spark 上运行的 Artifact Registry 映像。

  2. 您可以在编排平台 Workflows 中运行托管式连接流水线。

  3. 托管式连接流水线会执行以下操作：

    1. 如果目标条目组不存在，则根据您的配置创建一个目标条目组。
    2. 运行连接器。连接器会从您的数据源提取元数据，并生成可导入 Knowledge Catalog 的元数据导入文件。
    3. 监控元数据提取的进度。
    4. 运行元数据导入作业，将元数据导入 Knowledge Catalog。
    5. 监控元数据导入作业的进度。

托管式连接流水线使用 Managed Service for Apache Spark 运行连接器，并使用 Knowledge Catalog 元数据导入 API 方法运行元数据导入作业。

您导入的元数据由 Knowledge Catalog 条目及其切面组成。如需详细了解 Knowledge Catalog 元数据，请参阅 Knowledge Catalog 中的元数据管理简介。

社区提供的自定义连接器

如需从第三方来源导入元数据，您可以使用社区贡献的自定义连接器。如需了解设置说明和有关连接器的更多信息，请参阅每个连接器的自述文件。

数据源 代码库
AWS Glue Data Catalog aws-glue-connector
Databricks Unity Catalog databricks-connector
MySQL mysql-connector
Oracle oracle-connector
PostgreSQL postgresql-connector
雪花 snowflake-connector
Snowflake Horizon 目录 snowflake-horizon-connector
SQL Server sql-server-connector

后续步骤