使用 OCI GoldenGate 将数据暂存并合并到 Autonomous AI Lakehouse

此快速入门将引导您了解如何使用 OCI GoldenGate 大数据部署暂存和合并从自治 AI 事务处理到自治 AI 数据湖仓的数据。

开始之前

您必须具有以下项才能继续：

环境设置：自治 AI 数据库

  1. 下载并解压缩示例数据库方案。

  2. 设置源 Autonomous AI Transaction Processing：

    1. 在 Oracle Cloud 控制台中，从“Autonomous AI Database（自治 AI 数据库）”页面中选择您的 Autonomous AI Transaction Processing 实例，以查看其详细信息并访问 Database Actions。

    2. 选择数据库操作。

    3. 启用 GGADMIN 用户：

      1. 在 Administration（管理）下，选择 Database Users（数据库用户）。

      2. 找到 GGADMIN，然后选择其省略号菜单（三个点），然后选择编辑。

      3. 在 "Edit User"（编辑用户）面板中，输入 GGADMIN 密码，确认密码，然后禁用 Account is Locked 。

      4. 选择 Apply Changes（应用更改）。

    4. 加载源示例方案和数据：

      1. 从“Database Actions Selector（数据库操作选择器）”菜单的“Development（开发）”下，选择 SQL 。

      2. 将脚本从 OCIGGLL_OCIGGS_SETUP_USERS_ATP.sql 复制并粘贴到 SQL 工作表中。

      3. 选择运行脚本。“Script Output（脚本输出）”选项卡显示确认消息。

      4. 清除 SQL 工作表，然后从 OCIGGLL_OCIGGS_SRC_USER_SEED_DATA.sql 复制并粘贴 SQL 脚本。

      提示：您可能需要单独运行每个语句，SQL 工具才能成功执行脚本。

    5. 要验证表是否已成功创建，请关闭 SQL 窗口，然后重新打开它。在“Navigator（导航器）”选项卡中，查找 SRC_OCIGGLL 方案，然后从其各自的下拉列表中选择表。

    6. 启用补充事件记录：

      1. 清除 SQL 工作表。

      2. 输入以下语句，然后选择运行语句：

        ALTER PLUGGABLE DATABASE ADD SUPPLEMENTAL LOG DATA;

  3. 设置目标自治 AI 数据湖仓：

    1. 在 Oracle Cloud 控制台中，从“Autonomous AI Databases（自治 AI 数据库）”页面中选择您的自治 AI 数据湖仓实例，以查看其详细信息并访问数据库工具。

    2. 选择数据库操作。

    3. 在“Database Actions（数据库操作）”菜单的“Development（开发）”下，选择 SQL 。

    4. 将以前下载的 OCIGGLL_OCIGGS_SETUP_USERS_ADW.sql 中的脚本复制并粘贴到 SQL 工作表中。

    5. 选择运行脚本。“Script Output（脚本输出）”选项卡显示确认消息。

    6. 清除 SQL 工作表，然后从 OCIGGLL_OCIGGS_SRC_MIRROR_USER_SEED_DATA.sql 复制并粘贴 SQL 脚本

    7. 选择运行脚本。

任务 1：创建 OCI GoldenGate 资源

此快速入门示例需要源和目标的部署和连接。

  1. 为源自治 AI 事务处理实例创建 Oracle 部署。

  2. 为目标自治 AI 数据湖仓一体创建大数据部署。

  3. 为源自治 AI 事务处理实例创建连接。

  4. 为目标自治 AI 数据湖仓实例创建连接。

  5. 为 Oracle 对象存储创建连接。

  6. 创建与 GoldenGate 的连接，然后将此连接分配给源 Oracle 部署。

  7. 将自治 AI 事务处理连接分配给源 Oracle 部署。

  8. 将自治 AI 数据湖仓一体连接分配给目标大数据部署。

  9. 将 Oracle 对象存储连接分配给目标大数据部署。

任务 2：添加提取

  1. 在“Deployments（部署）”页面上，选择源 Autonomous AI Transaction Processing 部署。

  2. 在部署详细信息页上，选择启动控制台。

  3. 使用源部署的管理员用户名和密码登录。

  4. 添加提取。

任务 3：添加和运行分发路径

  1. 如果使用 GoldenGate 身份证明存储，请在目标大数据部署中为分发路径创建用户，否则跳至步骤 3。

  2. 在 source GoldenGate 部署控制台中，为在步骤 1 中创建的用户添加路径连接。

    1. 在源 GoldenGate 部署控制台中，在左侧导航中选择 Path Connections（路径连接）。

    2. 选择添加路径连接（加号图标），然后完成以下操作：

      1. 对于身份证明别名，输入 GGSNetwork。

      2. 对于用户 ID ，输入在步骤 1 中创建的用户的名称。

      3. 输入用户的密码两次以进行验证。

    3. 选择提交。

      路径连接将显示在“路径连接”列表中。

  3. 在 source 部署控制台中， add a Distribution Path with the following values：

    1. 在源选项页上：

      • 对于源提取，选择在任务 2 中创建的提取。

      • 对于线索名称，输入两个字符的名称，例如 E1。

    2. 在目标选项页上：

      • 对于目标主机，输入目标部署的主机域。

      • 在端口号中，输入 443。

      • 对于线索名称，输入两个字符的名称，例如 E1。

      • 对于别名，输入在步骤 2 中创建的身份证明别名。

  4. 在 target 大数据部署控制台中，查看作为分发路径结果创建的接收器路径。

    1. 在目标大数据部署控制台中，选择接收方服务。

    2. 查看路径详细信息。此路径是在上一步中创建的分发路径的结果创建的。

任务 4：添加并运行复制

  1. 在目标大数据部署控制台中，选择 Administrator Service ，然后选择 Add Replicat （加号图标）。

  2. Add a Replicat ，包含以下值：

    1. 在 "Replicat Information" 页面上的 "Replicat type" 下，选择 Classic Replicat 并输入进程名称。

    2. 在“复制选项”页面上：

      • 对于名称，输入任务 2 中的线索名称。

      • 对于域，选择一个域。

      • 对于别名，选择在任务 1 中创建的 Oracle 对象存储连接和 Autonomous AI Lakehouse 连接。

      • 对于检查点表，选择为目标部署创建的检查点表。

    3. 在“托管选项”页面上，将字段保留原样，然后选择下一步。

    4. 在“复制参数”页上，将 MAP 行更改为以下内容：

      MAP SRC_OCIGGLL.*, TARGET SRCMIRROR_OCIGGLL.*;

  3. 在“属性”页面上，配置以下属性：

    1. gg.eventhandler.oci.compartmentID：添加存储 Oracle 对象存储存储桶的区间的 OCID。

    2. gg.eventhandler.oci.bucketMappingTemplate：添加 Oracle Object Storage 存储桶的名称。

  4. 选择创建并运行。

任务 5：验证复制

  1. 在 Oracle Cloud 控制台的导航菜单中，选择 Oracle AI Database，然后选择 Autonomous AI Transaction Processing 。

  2. 在自治 AI 事务处理实例列表中，选择源实例以查看其详细信息。

  3. 在“数据库详细信息”页上，选择数据库操作。

    注：您应该自动登录。如果没有，则使用数据库身份证明登录。

  4. 在 Database Actions 主页中，选择 SQL 。

  5. 在工作表中输入以下内容，然后选择运行脚本。

  6. 在源 GoldenGate OCI GoldenGate 部署控制台中，选择提取名称，然后选择统计信息。验证 SRC_OCIGGLL.SRC_CUSTOMER 是否有 7 个插入。

    Insert into SRC_OCIGGLL.SRC_CUSTOMER (CUSTID,DEAR,LAST_NAME,FIRST_NAME,ADDRESS,CITY_ID,PHONE,AGE,SALES_PERS_ID) values (1001,0,'Brendt','Paul','10 Jasper Blvd.',107,'(212) 555 2146',19,10);
Insert into SRC_OCIGGLL.SRC_CUSTOMER (CUSTID,DEAR,LAST_NAME,FIRST_NAME,ADDRESS,CITY_ID,PHONE,AGE,SALES_PERS_ID) values (1002,0,'McCarthy','Robin','27 Pasadena Drive',11,'(214) 555 3075',29,11);
Insert into SRC_OCIGGLL.SRC_CUSTOMER (CUSTID,DEAR,LAST_NAME,FIRST_NAME,ADDRESS,CITY_ID,PHONE,AGE,SALES_PERS_ID) values (1003,0,'Travis','Peter','7835 Hartford Drive',12,'(510) 555 4448',34,12);
Insert into SRC_OCIGGLL.SRC_CUSTOMER (CUSTID,DEAR,LAST_NAME,FIRST_NAME,ADDRESS,CITY_ID,PHONE,AGE,SALES_PERS_ID) values (1004,0,'Larson','Joe','87 Carmel Blvd.',13,'(213) 555 5095',45,13);
Insert into SRC_OCIGGLL.SRC_CUSTOMER (CUSTID,DEAR,LAST_NAME,FIRST_NAME,ADDRESS,CITY_ID,PHONE,AGE,SALES_PERS_ID) values (1005,0,'Goldschmidt','Tony','91 Torre drive',14,'(619) 555 6529',55,20);
Insert into SRC_OCIGGLL.SRC_CUSTOMER (CUSTID,DEAR,LAST_NAME,FIRST_NAME,ADDRESS,CITY_ID,PHONE,AGE,SALES_PERS_ID) values (1006,0,'Baker','William','2890 Grant Avenue',15,'(312) 555 7040',64,21);
Insert into SRC_OCIGGLL.SRC_CUSTOMER (CUSTID,DEAR,LAST_NAME,FIRST_NAME,ADDRESS,CITY_ID,PHONE,AGE,SALES_PERS_ID) values (1007,0,'Swenson','Jack','64 Imagination Drive',19,'(202) 555 8125',74,22);

  7. 在目标大数据部署控制台中，选择复制名称，然后选择统计信息。验证 SRC_OCIGGLL.SRC_CUSTOMER 是否有 7 个插入。

  8. 在目标自治 AI 数据湖仓云 SQL 控制台中，执行以下命令以验证复制的数据：

    select * from SRCMIRROR_OCIGGLL.SRC_CUSTOMER;