Uso de modelos de IA en OCI GoldenGate para crear incrustaciones vectoriales

Descubra cómo generar incrustaciones vectoriales con el servicio AI en despliegues de replicación de datos con GoldenGate 26ai y versiones posteriores.

Visión general

OCI GoldenGate incluye un servicio de IA que permite a los procesos de GoldenGate interactuar con modelos de IA de varios proveedores (OCI Generative AI, OpenAI, Google Gemini y Voyage AI) para generar incrustaciones vectoriales directamente dentro de los pipelines de replicación de datos.

Los siguientes pasos le guiarán a través de cómo configurar la conectividad a los modelos de IA y utilizarlos para generar incrustaciones vectoriales en un Replicat.

Antes de empezar

Para continuar, debe tener lo siguiente:

Tarea 1: Configuración del entorno

Tarea 2: Configuración del modelo AI

Tarea 3: Creación del Extract integrado

Un Extract integrado captura los cambios en curso en la base de datos de origen.

  1. En la página Detalles del despliegue, seleccione Iniciar consola.

  2. Si es necesario, introduzca oggadmin para el nombre de usuario y la contraseña que ha utilizado al crear el despliegue y, a continuación, seleccione Conectar.

  3. Agregar datos de transacción y 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 SourceDB.

    3. En el menú de navegación, seleccione Trandata (Datos de transacción) y, a continuación, Add Trandata (icono más).

    4. En Nombre de esquema, introduzca SRC_OCIGGLL y, a continuación, seleccione Enviar.

    5. Para verificarlo, introduzca SRC_OCIGGLL en el campo Buscar y seleccione Buscar.

    6. Abra el menú de navegación y, a continuación, seleccione Conexiones de base de datos.

    7. Seleccione Conectar a base de datos TargetDB.

    8. En el menú de navegación, seleccione Checkpoint (Punto de control) y, a continuación, Add Checkpoint (Agregar punto de control) (icono más).

    9. En Tabla de puntos de control, introduzca "SRCMIRROR_OCIGGLL"."CHECKTABLE" y, a continuación, seleccione Enviar.

  4. Agregue un Extract.

    Nota: Consulte opciones adicionales de parámetros de extracción para obtener más información sobre los parámetros que puede utilizar para especificar tablas de origen.

    En la página Parámetros de extracción, agregue las siguientes líneas en EXTTRAIL <trail-name>:

    -- Capture DDL operations for listed schema tables
    ddl include mapped
    
    -- Add step-by-step history of to the report file. Useful when troubleshooting.
    ddloptions report
    
    -- Write capture stats per table to the report file daily.
    report at 00:01
    
    -- Rollover the report file weekly. Useful when IE runs
    -- without being stopped/started for long periods of time to
    -- keep the report files from becoming too large.
    reportrollover at 00:01 on Sunday
    
    -- Report total operations captured, and operations per second
    -- every 10 minutes.
    reportcount every 10 minutes, rate
    
    -- Table list for capture
    table SRC_OCIGGLL.*;
  5. Compruebe si hay transacciones de larga duración. Ejecute el siguiente script en la base de datos de origen:

    select start_scn, start_time from gv$transaction where start_scn < (select max(start_scn) from dba_capture);

    Si la consulta devuelve alguna fila, debe buscar el SCN de la transacción y, a continuación, confirmar o realizar un rollback de la transacción.

Tarea 4: Adición y ejecución de un Replicat sin integrar

  1. Agregue y ejecute un Replicat.

    En la pantalla Archivo de parámetros, sustituya MAP *.*, TARGET *.*; por el siguiente script:

    	-- Capture DDL operations for listed schema tables
     ddl include mapped
     --
     -- Add step-by-step history of ddl operations captured
     -- to the report file. Very useful when troubleshooting.
     ddloptions report
     --
     -- Write capture stats per table to the report file daily.
     report at 00:01
     --
     -- Rollover the report file weekly. Useful when PR runs
     -- without being stopped/started for long periods of time to
     -- keep the report files from becoming too large.
     reportrollover at 00:01 on Sunday
     --
     -- Report total operations captured, and operations per second
     -- every 10 minutes.
     reportcount every 10 minutes, rate
     --
     -- Table map list for apply
     MAP SRC_OCIGGLL.SRC_CITY, TARGET SRCMIRROR_OCIGGLL.SRC_CITY_VECTOR,
     COLMAP (
     USEDEFAULTS,
     CITY_EMBED = @AISERVICE(embed,'OCI_GenAI_TextEmbeddingSmall',CITY)
     );

    Nota

    La función @AISERVICE crea una incrustación de vectores a partir de los datos almacenados en la columna CITY mediante la conexión de modelo de AI definida anteriormente.

  2. Realice inserciones en la base de datos origen:

    1. Vuelva a la consola de Oracle Cloud y utilice el menú de navegación para volver a Oracle AI Database, Autonomous AI Transaction Processing y, a continuación, SourceDB.

    2. En la página Detalles de SourceDB, seleccione Acciones de base de datos y, a continuación, SQL.

    3. Introduzca las siguientes inserciones y, a continuación, 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);
    4. En la consola de despliegue de OCI GoldenGate, seleccione el nombre de extracción (UAEXT) y, a continuación, seleccione Estadísticas. Verifique que SRC_OCIGGLL.SRC_CITY se muestra con 10 inserciones.

    5. Vuelva a la pantalla Visión general, seleccione el nombre de Replicat (REP) y, a continuación, seleccione Estadísticas. Verifique que SRCMIRROR_OCIGGLL.SRC_CITY se muestra con 10 inserciones

    6. Vaya a la página de destino Autonomous AI Lakehouse Details, seleccione Database Actions y, a continuación, seleccione SQL

    7. En SQL, ejecute select * from SRCMIRROR_OCIGGLL.SRC_CITY_VECTOR; y revise los resultados, incluidas las incrustaciones vectoriales creadas por OCI GoldenGate mediante el servicio AI.

La tabla SRCMIRROR_OCIGGLL.SRC_CITY_VECTOR contiene filas replicadas desde SRC_OCIGGLL.SRC_CITY y la columna CITY_EMBED contiene una embebido de vector generado para cada ciudad.

Solución de problemas