Utilizzare i modelli AI in OCI GoldenGate per creare integrazioni vettoriali

Scopri come generare integrazioni vettoriali utilizzando il servizio AI nelle distribuzioni di replica dei dati utilizzando GoldenGate 26ai e versioni successive.

Panoramica

OCI GoldenGate include un servizio AI che consente AI processi GoldenGate di interagire con i modelli AI di vari provider (OCI Generative AI, OpenAI, Google Gemini e Voyage AI) per generare integrazioni vettoriali direttamente all'interno delle pipeline di replica dei dati.

I passi riportati di seguito descrivono come impostare la connettività AI modelli AI e utilizzarli per generare integrazioni vettoriali in un Replicat.

Prima di iniziare

Per procedere è necessario disporre dei seguenti elementi:

Task 1: Impostare l'ambiente

Task 2: configurare il modello AI

Task 3: Creazione dell'estrazione integrata

Un'estrazione integrata acquisisce le modifiche in corso al database di origine.

  1. Nella pagina Dettagli distribuzione selezionare Avvia console.

  2. Se necessario, immettere oggadmin per il nome utente e la password utilizzati durante la creazione della distribuzione, quindi selezionare Connetti.

  3. Aggiungi dati transazione e tabella checkpoint:

    1. Aprire il menu di navigazione, quindi selezionare Connessioni DB.

    2. Selezionare Connetti a database SourceDB.

    3. Nel menu di navigazione selezionare Trandata, quindi selezionare Aggiungi Trandata (icona più).

    4. Per Nome schema, immettere SRC_OCIGGLL, quindi selezionare Sottometti.

    5. Per verificare, immettere SRC_OCIGGLL nel campo Cerca e selezionare Cerca.

    6. Aprire il menu di navigazione, quindi selezionare Connessioni DB.

    7. Selezionare Connetti a database TargetDB.

    8. Nel menu di navigazione selezionare Checkpoint, quindi selezionare Aggiungi checkpoint (icona più).

    9. Per Tabella checkpoint, immettere "SRCMIRROR_OCIGGLL"."CHECKTABLE", quindi selezionare Sottometti.

  4. Aggiungi un'estrazione.

    Nota: per ulteriori informazioni sui parametri che è possibile utilizzare per specificare le tabelle di origine, vedere opzioni aggiuntive dei parametri di estrazione.

    Nella pagina Estrai parametri, aggiungere le righe seguenti in 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. Controllare le transazioni a esecuzione prolungata. Eseguire lo script seguente nel database di origine:

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

    Se la query restituisce righe, è necessario individuare l'SCN della transazione e quindi eseguire il commit o il rollback della transazione.

Task 4: Aggiunta ed esecuzione di un Replicat non integrato

  1. Aggiungere ed eseguire Replicat.

    Nella schermata File dei parametri sostituire MAP *.*, TARGET *.*; con lo script seguente:

    	-- 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 funzione @AISERVICE crea un vettore che incorpora i dati memorizzati nella colonna CITY utilizzando la connessione al modello AI definita in precedenza.

  2. Eseguire inserimenti nel database di origine:

    1. Tornare alla console di Oracle Cloud e utilizzare il menu di navigazione per tornare a Oracle AI Database, Autonomous AI Transaction Processing e quindi a SourceDB.

    2. Nella pagina Dettagli SourceDB, selezionare Azioni database, quindi SQL.

    3. Immettere gli inserimenti riportati di seguito, quindi selezionare Esegui 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. Nella console di distribuzione OCI GoldenGate, selezionare il nome di estrazione (UAEXT), quindi selezionare Statistiche. Verificare che SRC_OCIGGLL.SRC_CITY sia elencato con 10 inserimenti.

    5. Tornare alla schermata Panoramica, selezionare Replicat name (REP), quindi selezionare Statistics. Verificare che SRCMIRROR_OCIGGLL.SRC_CITY sia elencato con 10 inserimenti

    6. Andare alla pagina Dettagli Autonomous AI Lakehouse di destinazione, selezionare Azioni database, quindi selezionare SQL

    7. In SQL, eseguire select * from SRCMIRROR_OCIGGLL.SRC_CITY_VECTOR; ed esaminare i risultati, incluse le integrazioni vettoriali create da OCI GoldenGate utilizzando il servizio AI.

La tabella SRCMIRROR_OCIGGLL.SRC_CITY_VECTOR contiene righe replicate da SRC_OCIGGLL.SRC_CITY e la colonna CITY_EMBED contiene un incorporamento vettoriale generato per ogni città.

Risoluzione dei problemi