Usar Modelos de IA no OCI GoldenGate para Criar Incorporações de Vetor

Saiba como gerar incorporações de vetores usando o AI Service em implantações de replicação de dados usando o GoldenGate 26ai e versões posteriores.

Visão geral

O OCI GoldenGate inclui um Serviço de IA que permite que os processos do GoldenGate interajam com modelos de IA de vários provedores (OCI Generative AI, OpenAI, Google Gemini e Voyage AI) para gerar incorporações de vetores diretamente nos pipelines de replicação de dados.

As etapas a seguir orientam você sobre como configurar a conectividade com Modelos de IA e usá-los para gerar incorporações de vetores em um Replicat.

Antes de começar

Para continuar, você deve ter o seguinte:

Tarefa 1: Configurar o ambiente

Tarefa 2: Configurar o Modelo AI

Tarefa 3: Criar o Extract Integrado

Um Extract Integrado captura alterações contínuas no banco de dados de origem.

  1. Na página Detalhes da implantação, selecione Iniciar console.

  2. Se necessário, informe oggadmin para o Nome do usuário e a senha que você usou ao criar a implantação e selecione Acessar.

  3. Adicionar Dados da Transação e uma Tabela de Checkpoint:

    1. Abra o menu e selecione Conexões de Banco de Dados.

    2. Selecione Conectar-se ao banco de dados SourceDB.

    3. No menu de navegação, selecione Trandata e, em seguida, Adicionar Trandata (ícone de mais).

    4. Para Nome do Esquema, digite SRC_OCIGGLL e selecione Enviar.

    5. Para verificar, digite SRC_OCIGGLL no campo Pesquisar e selecione Pesquisar.

    6. Abra o menu e selecione Conexões de Banco de Dados.

    7. Selecione Conectar-se ao banco de dados TargetDB.

    8. No menu de navegação, selecione Checkpoint e, em seguida, Add Checkpoint (ícone de mais).

    9. Para Tabela de Checkpoint, digite "SRCMIRROR_OCIGGLL"."CHECKTABLE" e selecione Submeter.

  4. Adicione um processo de Extract.

    Observação: Consulte opções de parâmetro de extração adicionais para obter mais informações sobre parâmetros que você pode usar para especificar tabelas de origem.

    Na página Parâmetros da Extração, anexe as seguintes linhas em 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. Verifique transações de longa execução. Execute o seguinte script no seu banco de dados de origem:

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

    Se a consulta retornar linhas, localize o SCN da transação e, em seguida, confirme ou reverta a transação.

Tarefa 4: Adicionar e executar um processo de Replicat Não Integrado

  1. Adicionar e executar um processo Replicat.

    Na tela Arquivo de Parâmetro, substitua MAP *.*, TARGET *.*; pelo seguinte 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)
 );

    Observação

    A função @AISERVICE cria uma incorporação vetorial a partir dos dados armazenados na coluna CITY usando a conexão do Modelo de IA definida anteriormente.

  2. Executar Inserções no banco de dados de origem:

    1. Retorne à console do Oracle Cloud e use o menu de navegação para navegar de volta para o Oracle AI Database, Autonomous AI Transaction Processing e, em seguida, SourceDB.

    2. Na página Detalhes do SourceDB, selecione Database actions e, em seguida, selecione SQL.

    3. Informe as seguintes inserções e selecione Executar 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. Na Console de Implantação do OCI GoldenGate, selecione o Nome da extração (UAEXT) e selecione Estatísticas. Verifique se SRC_OCIGGLL.SRC_CITY está listada com 10 inserções.

    5. Volte para a tela Visão Geral, selecione o Nome do replicador (REP) e, em seguida, selecione Estatísticas. Verifique se SRCMIRROR_OCIGGLL.SRC_CITY está listada com 10 inserções

    6. Vá para a página Detalhes do Autonomous AI Lakehouse de destino, selecione Database Actions e SQL

    7. Em SQL, execute select * from SRCMIRROR_OCIGGLL.SRC_CITY_VECTOR; e revise os resultados, incluindo as incorporações de vetores criadas pelo OCI GoldenGate usando o AI Service.

A tabela SRCMIRROR_OCIGGLL.SRC_CITY_VECTOR contém linhas replicadas de SRC_OCIGGLL.SRC_CITY e a coluna CITY_EMBED contém uma incorporação de vetor gerada para cada cidade.

Diagnosticando e Solucionando Problemas