Replicación de datos de HeatWave en OCI a Autonomous AI Lakehouse

Descubre cómo utilizar OCI GoldenGate para replicar datos de HeatWave en OCI en Autonomous AI Lakehouse.

Antes de empezar

Para completar correctamente este inicio rápido, debe tener lo siguiente:

OCI Bastion, para conectarse a HeatWave en OCI, cargar la base de datos de ejemplo y realizar inserciones
Una base de datos de HeatWave en OCI para servir como base de datos de origen
Una instancia de Autonomous AI Lakehouse que servirá como base de datos de destino

Configuración del entorno: HeatWave en OCI

Para configurar el entorno para este inicio rápido:

Descargue el script de datos de ejemplo y, a continuación, ejecute el script en la base de datos de HeatWave en OCI para crear la base de datos y cargar los datos.

Cree un usuario ggadmin con el siguiente script. Recuerde sustituir <ggadmin-password> por una contraseña válida:

CREATE USER 'ggadmin' IDENTIFIED BY '<ggadmin-password>';
GRANT SELECT, REPLICATION SLAVE, REPLICATION CLIENT, CREATE,CREATE VIEW, EVENT, INSERT, UPDATE, DROP,EXECUTE, DELETE ON *.* TO 'ggadmin';

Abra port 3306, a través del cual se puede conectar OCI GoldenGate.
1. En la consola de Oracle Cloud, localice la subred que utiliza HeatWave en la base de datos de OCI.
2. En la lista de seguridad de la subred, cree una regla para port TCP/3306.
Descargue las secuencias de comandos del esquema de destino y, a continuación, ejecute las secuencias de comandos en la instancia de Autonomous AI Lakehouse para crear el esquema y las tablas. Puede utilizar la herramienta SQL para ejecutar los scripts de Autonomous AI Lakehouse Database Actions:
1. En la consola de Oracle Cloud, abra la página de detalles de la base de datos de Autonomous AI Lakehouse y, a continuación, seleccione Database Actions.
2. En Database Actions, en Desarrollo, seleccione SQL.
3. En la herramienta SQL, copie y pegue el script de OCIGGLL_OCIGGS_SETUP_USERS_ADW.sql en la hoja de trabajo SQL y, a continuación, seleccione Ejecutar script. Si se realiza correctamente, el separador Salida de script muestra mensajes de confirmación.
4. Borre la hoja de trabajo de SQL y, a continuación, copie y pegue solo los scripts Crear tabla de OCIGGLL_OCIGGS_SRC_MIRROR_USER_SEED_DATA.sql. Los datos se cargarán en una tarea posterior.
  
  Consejo: Puede que necesite ejecutar cada sentencia Crear tabla por separado para que la herramienta SQL ejecute los scripts correctamente.
5. Para verificar que las tablas se han creado correctamente, cierre la ventana SQL y vuelva a abrirla. En el separador Navegador, busque el esquema SRC_OCIGGLL y, a continuación, seleccione las tablas en sus respectivas listas desplegables.

Tarea 1: Creación de recursos de OCI GoldenGate

En este ejemplo de inicio rápido se necesitan despliegues y conexiones tanto para el origen como para el destino.

Cree un despliegue para la base de datos de origen HeatWave en OCI.
Cree un despliegue para la instancia de Autonomous AI Lakehouse de destino.
Cree una conexión al origen de HeatWave en la base de datos de OCI.
Cree una conexión para el lakehouse de IA autónoma de destino.
Cree una conexión a GoldenGate y, a continuación, asigne esta conexión al despliegue de MySQL de origen.
Asigne la conexión de origen al despliegue de MySQL de destino.
Asigne la conexión de destino al despliegue de destino de Oracle.

Tarea 2: Creación de los Extracts

En la página Despliegues, seleccione el despliegue de MySQL creado en la tarea 1.
En la página de detalles del despliegue, seleccione Iniciar consola.
Conéctese a la consola de despliegue de MySQL de origen con las credenciales de administrador especificadas al crear el despliegue en la tarea 1.
En el menú de navegación, seleccione Conexiones de Base de Datos.
Revise las credenciales para la conexión de HeatWave en OCI. Tome nota del dominio y el alias.
Agregue y ejecute una extracción de captura de datos de cambio con los siguientes valores:
- En Tipo de extracción, seleccione Cambiar captura de datos.
- En Nombre de proceso, introduzca un nombre para el proceso Extract.
- En Dominio, seleccione el dominio.
- En Alias, seleccione el alias.
- En Nombre de pista de extracción, introduzca un nombre para el archivo de pistas.
- En la página Archivo de parámetros, agregue lo siguiente:
```
TABLE SRC_OCIGGLL.*;
```
Agregue y ejecute un Extract de carga inicial con los siguientes valores:
- En Tipo de extracción, seleccione Extracción de carga inicial.
- En Nombre de proceso, introduzca un nombre.
- En la página Archivo de parámetros, agregue lo siguiente:
```
TABLE SRC_OCIGGLL.*;
```

Tarea 3: Creación de la ruta de distribución para un Extract de carga inicial

En la página Despliegues, seleccione el despliegue de Autonomous AI Database de destino.
En la página de detalles del despliegue, seleccione Iniciar consola y, a continuación, conéctese como usuario administrador.
Si utiliza el almacén de credenciales de IAM, continúe con el paso Crear una ruta de distribución. Si utiliza el almacén de credenciales de GoldenGate, cree un usuario con el que GoldenGate de origen utilice para conectarse al GoldenGate de destino.
1. En el menú de navegación, seleccione User Administration (Administración de usuarios).
2. Seleccione Agregar nuevo usuario (icono con signo más), complete los campos como se indica a continuación y, a continuación, seleccione Enviar:
  - En Nombre de usuario, introduzca ggsnet.
  - En Rol, seleccione Operador.
  - Introduzca la contraseña dos veces para su verificación.
En la consola de despliegue de MySQL de origen, cree una conexión de ruta para el usuario creado en el paso anterior.
1. En el menú de navegación, seleccione Path Connections (Conexiones de ruta).
2. Seleccione Agregar conexión de ruta de acceso (icono más), complete los campos de la siguiente manera y, a continuación, seleccione Enviar:
  - En Alias de credencial, introduzca dpuser.
  - En ID de usuario, introduzca ggsnet
  - En Contraseña, introduzca la misma contraseña utilizada en el paso anterior.
Crear una ruta de distribución.
1. En la barra de menús del servicio, seleccione Servicio de distribución y, a continuación, seleccione Agregar ruta de distribución (icono más).
2. Complete el formulario Agregar ruta de la siguiente manera:
  - En la página Path Information:
    1. En Nombre de la ruta, introduzca un nombre para esta ruta.
    2. Seleccione Next (Siguiente).
  - En la página Source Options:
    1. En Extracción de origen, deje en blanco.
    2. En Nombre de pista, introduzca el nombre de pista de Extract de carga inicial (I1).
    3. Seleccione Next (Siguiente).
  - En la página Opciones de Destino:
    1. En Destino, seleccione wss.
    2. En Host de Destino, introduzca la URL de despliegue de origen, sin https:// ni barras inclinadas finales.
    3. En Número de puerto, introduzca 443.
    4. En Nombre de la pista, introduzca I1.
    5. En Método de autenticación del destino, seleccione Alias de ID de Usuario.
    6. En Dominio, introduzca el nombre de dominio creado en el paso anterior.
    7. En Alias, introduzca el alias creado en el paso anterior (dpuser).
    8. Seleccione Next (Siguiente).
3. Seleccione Crear y ejecutar.
Volverá a la página Servicio de distribución, donde podrá revisar la ruta de acceso creada.
Revise la ruta de distribución:
1. Seleccione Servicio de receptor.
2. Revise los detalles de la ruta de distribución.

Tarea 4: Adición del Replicat para la carga inicial

En la consola de despliegue de OCI GoldenGate de destino, agregue una tabla de puntos de control.
1. Abra el menú, a continuación, seleccione Conexiones de base de datos.
2. Seleccione Conectar a base de datos.
3. En el menú de navegación, seleccione Checkpoint (Punto de control).
4. En la página Punto de Control, seleccione Agregar Punto de Control (icono más).
5. En Tabla de puntos de control, introduzca SRCMIRROR_OCIGGLL.CHECKTABLE.
6. Seleccione Enviar.
  
  Consejo: la pantalla no se refrescará al enviar. Para confirmar que se ha agregado la tabla de puntos de control, introduzca SRCMIRROR_OCIGGLL.CHECKTABLE en el campo de búsqueda y, a continuación, seleccione Buscar.
Agregue el Replicat:
1. Seleccione Administrator Service (Servicio de administrador) y, a continuación, seleccione Add Replicat (icono más).
2. En la página Agregar Replicat, complete los siguientes campos del formulario y, a continuación, seleccione Siguiente.
  - Para el tipo Replicat, seleccione Replicat no integrado.
  - En Nombre de proceso, introduzca un nombre, como RIL.
3. En la página Opciones de Replicat, complete los siguientes campos del formulario y, a continuación, seleccione Siguiente:
  - En Nombre, introduzca el nombre de los pista de las tareas 2 (I1).
  - En Dominio, seleccione el dominio para la conexión a la base de datos de IA autónoma.
  - En Alias, seleccione el alias de la conexión a la base de datos de IA autónoma.
  - En Tabla de puntos de Control, seleccione la tabla que ha creado en el paso 1.
4. En la página Managed Options, deje los campos como están y seleccione Next.
5. En la página Parámetros de Replicat, agregue la siguiente asignación y, a continuación, seleccione Crear y ejecutar:
```
MAP SRC_OCIGGLL.*, TARGET SRCMIRROR_OCIGGLL.*;
```
Volverá a la página Visión general, donde podrá revisar los detalles del Replicat.
Seleccione el Replicat (RIL) y vea los Detalles.
Seleccione Estadísticas y revise el número de inserciones. Refresque la página.
- Si el número de inserciones no cambia, significa que se han cargado todos las historias clínicas de la carga inicial y que puede parar el Replicat (RIL)
- Si el número de inserciones continúa aumentando, siga refrescando la página hasta que todos los registros de la carga inicial se hayan cargado antes de continuar.

Tarea 5: Verificación de la carga inicial

En la consola de Oracle Cloud, abra Database Actions desde la página del detalle de la base de datos de Autonomous AI Lakehouse.
En Database Actions, en Desarrollo, seleccione SQL.
En la herramienta SQL, introduzca cada una de las siguientes sentencias en la hoja, y seleccione Ejecutar sentencia:
```
SELECT * FROM SRCMIRROR_OCIGGLL.SRC_CITY;
SELECT * FROM SRCMIRROR_OCIGGLL.SRC_CUSTOMER;
```

La salida debe devolver los datos que se han cargado en las tablas de la base de datos de destino como resultado de la carga inicial.

Tarea 6: Creación de una ruta de distribución para la captura de cambios en los datos

En la consola de despliegue de origen, seleccione Servicio de distribución.
Seleccione Agregar ruta de distribución.
Complete el formulario Agregar ruta de la siguiente manera:
1. En la página Path Information:
  1. En Nombre de ruta, introduzca un nombre.
  2. Seleccione Next (Siguiente).
2. En la página Source Options:
  1. En Extracción de origen, seleccione la extracción de captura de datos de cambio (ECDC).
  2. En Nombre de la pista, seleccione el archivo del registro de captura del cambio de datos (C1).
  3. Seleccione Next (Siguiente).
3. En la página Opciones de Destino:
  1. En Destino, seleccione wss.
  2. En Host de destino, introduzca la URL de la consola de despliegue de destino (puede encontrarlo en la página de detalles del despliegue, sin https:// ni barras finales).
  3. En Número de puerto, introduzca 443.
  4. En Nombre de la pista, introduzca C1.
  5. En Método de autenticación del destino, seleccione Alias de ID de Usuario.
  6. En Dominio, introduzca el nombre de dominio.
  7. En Alias, introduzca el alias.
4. Seleccione Create Path and Run.
En la Consola de Despliegue de Destino, seleccione Servicio de Receptor y, a continuación, revise la ruta de receptor creada.

Tarea 7: Adición de un Replicat para la captura de cambios en los datos

Agregue el Replicat con los siguientes valores:
1. En la página Replicat Information:
  - En Tipo de Replicat, seleccione Replicat Coordinado.
  - En Nombre de proceso, introduzca un nombre, como RCDC.
2. En la página Replicat Options:
  - En Pista de Replicat, introduzca el nombre de las pistas desde la tarea 2 (C1).
  - En Dominio, seleccione el dominio para la conexión a la base de datos de IA autónoma.
  - En Alias, introduzca el alias de credencial.
  - En Tabla de puntos de Control, seleccione la tabla del punto de control que ha creado.
3. En la página Parámetros de Replicat, agregue la siguiente asignación y, a continuación, seleccione Crear y ejecutar:
```
MAP SRC_OCIGGLL.*, TARGET SRCMIRROR_OCIGGLL.*;
```
En la página Visión general de servicio de administración, seleccione el Replicat para Carga inicial (RIL) y vea los Detalles.
Seleccione Estadísticas y revise el número de inserciones. Refresque la página.
- Si el número de inserciones no cambia, quiere decir que se han cargado todos los registros de la carga inicial y que puede parar el Replicat (RIL).
- Si el número de inserciones continúa aumentando, siga refrescando la página hasta que todos los registros de la carga inicial se hayan cargado antes de continuar.
Vuelva a la página Descripción general del servicio de administración y, a continuación, inicie el Replicat coordinado (RCDC).
Después de iniciar el Replicat coordinado, revise sus Detalles y Estadísticas para ver el número de inserciones.

Tarea 8: Verificación de la captura de cambios en los datos

Realice actualizaciones en la base de datos de origen HeatWave en OCI para verificar la replicación en Autonomous AI Lakehouse.

En OCI Bastion, cree una sesión de reenvío de puerto SSH mediante la IP de MySQL y el puerto 3306. Agregue su clave SSH pública.
Conéctese a MySQL en Cloud Shell mediante su clave privada y el puerto 3306.
Después de conectarse correctamente, ejecute el siguiente comando:
```
mysqlsh admin@localhost:3306 --sql
```

Ejecute el siguiente script para realizar inserciones en la base de datos de HeatWave en OCI:

use SRC_OCIGGLL;
Insert into SRC_OCIGGLL.SRC_CITY (CITY_ID,CITY,REGION_ID,POPULATION) values (1000,'Houston',20,743113);
Insert into SRC_OCIGGLL.SRC_CITY (CITY_ID,CITY,REGION_ID,POPULATION) values (1001,'Dallas',20,822416);
Insert into SRC_OCIGGLL.SRC_CITY (CITY_ID,CITY,REGION_ID,POPULATION) values (1002,'San Francisco',21,157574);
Insert into SRC_OCIGGLL.SRC_CITY (CITY_ID,CITY,REGION_ID,POPULATION) values (1003,'Los Angeles',21,743878);
Insert into SRC_OCIGGLL.SRC_CITY (CITY_ID,CITY,REGION_ID,POPULATION) values (1004,'San Diego',21,840689);
Insert into SRC_OCIGGLL.SRC_CITY (CITY_ID,CITY,REGION_ID,POPULATION) values (1005,'Chicago',23,616472);
Insert into SRC_OCIGGLL.SRC_CITY (CITY_ID,CITY,REGION_ID,POPULATION) values (1006,'Memphis',23,580075);
Insert into SRC_OCIGGLL.SRC_CITY (CITY_ID,CITY,REGION_ID,POPULATION) values (1007,'New York City',22,124434);
Insert into SRC_OCIGGLL.SRC_CITY (CITY_ID,CITY,REGION_ID,POPULATION) values (1008,'Boston',22,275581);
Insert into SRC_OCIGGLL.SRC_CITY (CITY_ID,CITY,REGION_ID,POPULATION) values (1009,'Washington D.C.',22,688002);
commit;

En la Consola de despliegue de MySQL de origen, seleccione el nombre de Extract de captura de cambios en los datos y, a continuación, seleccione Estadísticas. Verifique que SRC_OCIGGLL.SRC_CITY tenga 10 inserciones.

Nota: Si el Extract no capturó ninguna inserción, reinicie el Extract.