Replicación de datos de Autonomous AI Transaction Processing en Apache Kafka

Descubra cómo configurar OCI GoldenGate para replicar datos de Autonomous AI Transaction Processing (ATP) en Apache Kafka.

Visión general

Con OCI GoldenGate, puede replicar datos de una base de datos de IA autónoma en un destino de Big Data, como Apache Kafka. Este inicio rápido muestra cómo configurar un despliegue de OCI GoldenGate, conexiones de origen y destino, y procesos de replicación.

Antes de empezar

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

Una VCN con el puerto 9092 (u otro puerto utilizado para el servidor de inicialización) abierto en las reglas de entrada.
Instancia de procesamiento de transacciones de IA autónoma de origen
Un nodo de Apache Kafka de destino

Configuración del entorno: procesamiento de transacciones de IA autónoma

Si aún no tiene una base de datos de origen configurada para la replicación, puede seguir estos pasos para cargar un esquema de ejemplo que utilizar para este inicio rápido. Este inicio rápido utiliza el procesamiento de transacciones de IA autónoma para la base de datos de origen.

Para configurar el procesamiento de transacciones de IA autónoma de origen:

Descargue y descomprima el esquema de base de datos de ejemplo.
En la consola de Oracle Cloud, seleccione su instancia de procesamiento de transacciones de IA autónoma (ATP) en la página Bases de datos de IA autónomas para ver los detalles y acceder a Database Actions.
Desbloquee el usuario de GGADMIN:
1. Seleccione Acciones de base de datos y, a continuación, Usuarios de base de datos.
2. Localice GGADMIN y, a continuación, seleccione el menú de puntos suspensivos (tres puntos) y seleccione Editar.
3. En el panel Editar usuario, introduzca la contraseña de GGADMIN, confirme la contraseña y, a continuación, anule la selección de Cuenta bloqueada.
4. Seleccione Apply Changes (Aplicar cambios).
Cargue el esquema de ejemplo y datos del origen:
1. En el menú Acciones de base de Datos, en Desarrollo, seleccione SQL.
2. Copie y pegue el script de OCIGGLL_OCIGGS_SETUP_USERS_ATP.sql en la hoja de Trabajo de SQL.
3. Seleccione Run Script. El separador Salida de script mostrará los mensajes de confirmación.
4. Borre la hoja de trabajo SQL y, luego, copie y pegue el script SQL de OCIGGLL_OCIGGS_SRC_USER_SEED_DATA.sql.
  
  Consejo: puede que necesite ejecutar cada sentencia 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 la tabla en sus respectivas listas desplegables.
Active el registro complementario:
1. Borre la hoja de trabajo de SQL.
2. Introduzca la siguiente sentencia y, a continuación, seleccione Ejecutar sentencia:
```
ALTER PLUGGABLE DATABASE ADD SUPPLEMENTAL LOG DATA;
```

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 de Oracle para la instancia de procesamiento de transacciones de IA autónoma (ATP) de origen.
Cree un despliegue de Big Data para el nodo de Kafka Apache de destino.
Cree una conexión para la instancia de Autonomous AI Transaction Processing de origen.
Cree una conexión para el nodo del Apache Kafka de destino.
Cree una conexión a GoldenGate y, a continuación, asigne esta conexión al despliegue de Oracle de origen.
Asigne la conexión ATP al despliegue de Oracle de origen.
Asigne la conexión de Apache Kafka al despliegue de Big Data de destino.

Tarea 2: Adición del Extract

En la página Despliegues, seleccione el despliegue de Autonomous AI Transaction Processing de origen.
En la página de detalles del despliegue, seleccione Iniciar consola.
Conéctese con el nombre de usuario y la contraseña del administrador del despliegue de origen.
Agregue un Extract.

Tarea 3: Adición y ejecución de la ruta de distribución

Si utiliza el almacén de credenciales de GoldenGate, cree un usuario para la ruta de distribución en el despliegue de Big Data del destino; de lo contrario, vaya al paso 3.
En la consola de despliegue de GoldenGate de origen, agregue una conexión de ruta de acceso para el usuario creado en el paso 1.
1. En la consola de despliegue de GoldenGate de origen, seleccione Conexiones de ruta en la navegación izquierda.
2. Seleccione Agregar conexión de ruta de acceso (icono más) y, a continuación, complete lo siguiente:
  1. En Alias de credencial, introduzca GGSNetwork.
  2. En User ID (ID de usuario), introduzca el nombre del usuario creado en 1º paso.
  3. Introduzca la contraseña del usuario dos veces para su verificación.
3. Seleccione Enviar.
  
  La conexión de ruta de acceso aparece en la lista Conexiones de ruta.
En la consola de despliegue del origen, agregue una ruta de distribución con los siguientes valores:
1. En la página Opciones de origen:
  - En Extract de origen, seleccione el Extract creado en el tarea 2.
  - En Nombre de la pista, introduzca un Nombre de dos caracteres como E1.
2. En la página Opciones de destino:
  - En Host de destino, introduzca el dominio de host del despliegue del destino.
  - En Número de puerto, introduzca 443.
  - En Nombre de la pista, introduzca un Nombre de dos caracteres como E1.
  - En Alias, introduzca el alias de credencial creado en la etapa 2.
En la consola de despliegue de Big Data de destino, revise la Ruta de receptor creada como resultado de la Ruta de distribución.
1. En la consola de despliegue de Big Data de destino, seleccione Servicio de receptor.
2. Revise los detalles de la ruta. Esta ruta se ha creado como resultado de la Ruta de distribución creada en el paso anterior.

Tarea 4: Adición del Replicat

En el menú de navegación de la consola de despliegue de Big Data de destino, seleccione Replicats y, a continuación, Add Replicat (icono más).
Agregar un Replicat con los siguientes valores:
1. En la página Información de Replicat, en Tipo de Replicat, seleccione Replicat clásico, introduzca un nombre de proceso y, a continuación, seleccione Siguiente.
2. En la página Replicat Options:
  - En Nombre, introduzca el nombre de una pista en la tarea 3.
  - En Destino, seleccione Kafka.
  - En Alias, seleccione la conexión de Kafka creada en el tarea 1.
3. En la página Parámetros de Replicat, deje el valor por defecto.
4. En la página Archivo de propiedades, proporcione un nombre de tema para la siguiente propiedad:
```
gg.handler.kafkahandler.topicMappingTemplate=
```
  Si no hay ningún tema, OCI GoldenGate crea uno para usted.
Seleccione Crear y ejecutar.

Volverá a la página Replicats, donde podrá revisar los detalles de Replicat.

Tarea 5: Verificación de la replicación

Realice algunas actualizaciones en la instancia de Autonomous Transaction Processing de origen para verificar la replicación en Apache Kafka.

En la consola de Oracle Cloud, abra el menú de navegación, seleccione Oracle AI Database y, a continuación, seleccione Procesamiento de transacciones de IA autónoma.
En la lista de instancias de Autonomous AI Transaction Processing, seleccione la instancia de origen para ver los detalles.
En la página de detalles de base de datos, seleccione Acciones de base de datos.

Nota: Esta acción le debería conectar de forma automática. Si no es así, conéctese con las credenciales de la base de datos.
En la página de inicio de Database actions, seleccione SQL.

Introduzca lo siguiente en la hoja de trabajo y seleccione Ejecutar script.

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);

En la consola, seleccione el nombre del Extract y, a continuación, seleccione Estadísticas. Verifique que SRC_OCIGGLL.SRC_CITY tenga 10 inserciones.
En la consola de despliegue de Big Data OCI GoldenGate de destino, seleccione el nombre del Replicat y, a continuación, seleccione Estadísticas. Verifique que SRC_OCIGGLL.SRC_CITY tenga 10 inserciones.
En la consola de Oracle Cloud, desplácese hasta el cubo de Oracle Object Storage y compruebe su contenido.