Almacena en área temporal y fusiona datos en Autonomous AI Lakehouse mediante OCI GoldenGate

Este inicio rápido le guía sobre cómo almacenar y fusionar datos de Autonomous AI Transaction Processing en Autonomous AI Lakehouse mediante un despliegue de OCI GoldenGate Big Data.

Antes de empezar

Para continuar, debe tener lo siguiente:

Configuración del entorno: bases de datos de IA autónomas

  1. Descargue y descomprima el esquema de base de datos de ejemplo.

  2. Configure el procesamiento de transacciones de IA autónoma de origen:

    1. En la consola de Oracle Cloud, seleccione su instancia de procesamiento de transacciones de IA autónoma en la página Bases de datos de IA autónomas para ver los detalles y acceder a Database Actions.

    2. Seleccione Database Actions.

    3. Active el usuario GGADMIN:

      1. En Administración, seleccione 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, desactive La cuenta está bloqueada.

      4. Seleccione Apply Changes (Aplicar cambios).

    4. Cargue el esquema y los datos de ejemplo de origen:

      1. En el menú Selector de 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, por último, 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.

    6. 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;
  3. Configure el lakehouse de IA autónoma de destino:

    1. En la consola de Oracle Cloud, seleccione su instancia de Autonomous AI Lakehouse en la página Autonomous AI Databases para ver sus detalles y acceder a las herramientas de base de datos.

    2. Seleccione Database Actions.

    3. En el menú Database Actions, en Development, seleccione SQL.

    4. Copie y pegue el script de OCIGGLL_OCIGGS_SETUP_USERS_ADW.sql descargado anteriormente en la hoja de Trabajo de SQL.

    5. Seleccione Run Script. El separador Salida de script mostrará los mensajes de confirmación.

    6. Borre la hoja de trabajo SQL y, luego, copie y pegue el script SQL de OCIGGLL_OCIGGS_SRC_MIRROR_USER_SEED_DATA.sql

    7. Seleccione Run Script.

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.

  1. Cree un despliegue de Oracle para la instancia de Autonomous AI Transaction Processing del origen.

  2. Cree un despliegue de Big Data para el lakehouse de IA autónoma de destino.

  3. Cree una conexión para la instancia de Autonomous AI Transaction Processing de origen.

  4. Cree una conexión para la instancia de Autonomous AI Lakehouse de destino.

  5. Cree una conexión para Oracle Object Storage.

  6. Cree una conexión a GoldenGate y, a continuación, asigne esta conexión al despliegue de Oracle de origen.

  7. Asigne la conexión de Autonomous AI Transaction Processing al despliegue de Oracle de origen.

  8. Asigne la conexión de Autonomous AI Lakehouse al despliegue de Big Data de destino.

  9. Asigne la conexión de Oracle Object Storage al despliegue de Big Data de destino.

Tarea 2: Adición del Extract

  1. En la página Despliegues, seleccione el despliegue de Autonomous AI Transaction Processing de origen.

  2. En la página de detalles del despliegue, seleccione Iniciar consola.

  3. Conéctese con el nombre de usuario y la contraseña del administrador del despliegue de origen.

  4. Agregue un Extract.

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

  1. 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.

  2. 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.

  3. 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.

  4. 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 y ejecución del Replicat

  1. En la consola de despliegue de Big Data de destino, seleccione Servicio de administrador y, a continuación, seleccione Agregar Replicat (icono más).

  2. Agregar un Replicat con los siguientes valores:

    1. En la página Información de Replicat, en Tipo de Replicat, seleccione Replicat clásico e introduzca un nombre de proceso.

    2. En la página Replicat Options:

      • En Nombre, introduzca el nombre de una pista en la tarea 2.

      • Para Dominio, seleccione un dominio.

      • En Alias, seleccione la conexión de Oracle Object Storage y la conexión de Autonomous AI Lakehouse creada en la tarea 1.

      • En Tabla de puntos de Control, seleccione la tabla del punto de control que ha creado para el despliegue.

    3. En la página Managed Options, deje los campos como están y seleccione Next.

    4. En la página Parámetros de Replicat, cambie la línea de MAP a la siguiente:

      MAP SRC_OCIGGLL.*, TARGET SRCMIRROR_OCIGGLL.*;
  3. En la página Propiedades, configure las siguientes propiedades:

    1. gg.eventhandler.oci.compartmentID: agregue el OCID del compartimento en el que se almacena el cubo de Oracle Object Storage.

    2. gg.eventhandler.oci.bucketMappingTemplate: agregue el nombre del cubo de almacenamiento de objetos de Oracle.

  4. Seleccione Crear y ejecutar.

Tarea 5: Verificación de la replicación

  1. En la consola de Oracle Cloud, en el menú de navegación, seleccione Oracle AI Database y, a continuación, seleccione Procesamiento de transacciones de IA autónoma.

  2. En la lista de instancias de Autonomous AI Transaction Processing, seleccione la instancia de origen para ver los detalles.

  3. En la página de detalles de la base de datos, seleccione Database Actions.

    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.

  4. En la página inicial de Database Actions, seleccione SQL.

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

  6. En la consola de despliegue de GoldenGate de OCI GoldenGate de origen, seleccione el nombre del Extract y, a continuación, seleccione Estadísticas. Verifique que SRC_OCIGGLL.SRC_CUSTOMER tenga 7 inserciones.

    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. En la consola de despliegue de Big Data de destino, seleccione el nombre de Replicat y, a continuación, seleccione Estadísticas. Verifique que SRC_OCIGGLL.SRC_CUSTOMER tenga 7 inserciones.

  8. En la consola de destino de Autonomous AI Lakehouse Cloud SQL, ejecute el siguiente comando para validar los datos replicados:

    select * from SRCMIRROR_OCIGGLL.SRC_CUSTOMER;