Informatica Cloud 与 OceanBase 数据库集成指南

简介

Informatica 提供一系列数据集成产品，旨在帮助企业进行大规模的数据仓库集成、大数据集成、云计算集成、实时数据集成、数据质量管理、数据治理和数据交换等。

Informatica 提供了一系列数据管理产品和解决方案，包括 ETL、数据质量、数据治理、数据隐私和保护工具，以及针对特定行业的解决方案。

本文介绍的 Informatica Cloud 是 Informatica 提供的一套基于云的数据集成和数据管理解决方案。这个平台使用户能够在云环境中连接和整合异构数据源，包括本地数据源和基于云的数据源，以便更好地进行数据分析、数据洞察和业务决策。

前置操作

在开始使用 Informatica Cloud 之前，您需要进行一些前置配置操作，以确保数据连接和同步的顺利进行。

1. 登录 Informatica Cloud，根据官方文档配置 Agent。

   注意

   • 如果您使用的 OceanBase 版本低于 V4.2.4，建议您使用自行管理 Agent 的方式，并根据文档安装 MySQL ODBC 8.0.32 及更高版本。
   • 使用 Informatica Cloud 遵循 Informatica 的收费规则，并可能产生相应费用。请在继续前，访问其官网或查阅相关文档，确认并接受其收费标准。如不同意，请勿继续操作。

2. 在 OceanBase Cloud 平台，将 Informatica Cloud Agent 所在节点的 IP 加入白名单。

3. （可选）开启 CDC 功能。如果您需要使用 CDC 功能，在 OceanBase Cloud 平台为实例开启 Binlog 服务。

使用示例

本节将 OceanBase 作为连接上游，通过 Informatica Cloud 将数据同步到下游 Snowflake。

1. 从 Data Integration -> New Asset 选择 Copy data to a existing target，您也可以根据实际需要选择 Replicate a MySQL table or view incrementally to an existing target 等其他类型的任务。

2. 选择 MySQL 类型增加连接，连接串信息可通过 OceanBase Cloud 控制台 Instance -> Tenant -> Connect -> Get Connection String 获得。点击 Test 确保连接成功。

   

3. 连接上游 OceanBase 实例成功后，在下个步骤选择需要同步的库表，点击 OK 进入下一步。

   

4. 在新的连接信息中，选择 Snowflake Data Cloud，并填写 Snowflake 的连接信息，点击 Test 确保连接成功。

   

5. 填写 Mapping 配置，即上下游的字段映射关系。

   

6. 所有信息确认填写无误后，点击 Next 执行同步任务，并根据日志检查同步是否正常。