Replica i dati da HeatWave su OCI ad Autonomous AI Lakehouse

Scopri come utilizzare OCI GoldenGate per replicare i dati da HeatWave su OCI in Autonomous AI Lakehouse.

Prima di iniziare

Per completare correttamente questo avvio rapido, è necessario disporre dei seguenti elementi:

• OCI Bastion, per connettersi a HeatWave su OCI, caricare il database di esempio ed eseguire inserimenti

• Un HeatWave sul database OCI da servire come database di origine

• Un'istanza Autonomous AI Lakehouse da utilizzare come database di destinazione

Impostazione dell'ambiente: HeatWave su OCI

Per impostare l'ambiente per questo Quickstart:

1. Scarica lo script di dati di esempio, quindi esegui lo script su HeatWave nel database OCI per creare il database e caricare i dati.

2. Creare un utente ggadmin utilizzando lo script seguente. Ricordarsi di sostituire <ggadmin-password> con una password valida:

   CREATE USER 'ggadmin' IDENTIFIED BY '<ggadmin-password>';
   GRANT SELECT, REPLICATION SLAVE, REPLICATION CLIENT, CREATE,CREATE VIEW, EVENT, INSERT, UPDATE, DROP,EXECUTE, DELETE ON *.* TO 'ggadmin';

3. Aprire port 3306, tramite il quale OCI GoldenGate può connettersi.

   1. Nella console di Oracle Cloud, individuare la subnet utilizzata da HeatWave sul database OCI.

   2. Nella lista di sicurezza della subnet creare una regola di entrata per port TCP/3306.

4. Scaricare gli script dello schema di destinazione, quindi eseguire gli script nell'istanza Autonomous AI Lakehouse per creare lo schema e le tabelle. È possibile utilizzare lo strumento SQL Autonomous AI Lakehouse Database Actions per eseguire gli script:

   1. Nella console di Oracle Cloud aprire la pagina dei dettagli del database Autonomous AI Lakehouse, quindi selezionare Azioni del database.

   2. In Database Actions, in Sviluppo, selezionare SQL.

   3. Nello strumento SQL copiare e incollare lo script da OCIGGLL_OCIGGS_SETUP_USERS_ADW.sql nel foglio di lavoro SQL, quindi selezionare Esegui script. In caso di esito positivo, nella scheda Output script vengono visualizzati i messaggi di conferma.

   4. Cancellare il foglio di lavoro SQL, quindi copiare e incollare solo gli script Crea tabella da OCIGGLL_OCIGGS_SRC_MIRROR_USER_SEED_DATA.sql. I dati verranno caricati in un task successivo.

      Suggerimento: potrebbe essere necessario eseguire ciascuna istruzione Crea tabella separatamente affinché lo strumento SQL esegua correttamente gli script.

   5. Per verificare che le tabelle siano state create correttamente, chiudere la finestra SQL e riaprirla. Nella scheda Navigator, cercare lo schema SRC_OCIGGLL, quindi selezionare le tabelle dai rispettivi elenchi a discesa.

Task 1: creare le risorse OCI GoldenGate

Questo esempio di avvio rapido richiede distribuzioni e connessioni sia per l'origine che per la destinazione.

1. Crea una distribuzione per l'HeatWave di origine nel database OCI.

2. Creare una distribuzione per Autonomous AI Lakehouse di destinazione.

3. Creare una connessione all'HeatWave di origine nel database OCI.

4. Creare una connessione per Autonomous AI Lakehouse di destinazione.

5. Creare una connessione a GoldenGate, quindi assegnare questa connessione alla distribuzione MySQL di origine.

6. Assegnare la connessione di origine alla distribuzione MySQL di origine.

7. Assegnare la connessione di destinazione alla distribuzione Oracle di destinazione.

Task 2: Creazione delle estrazioni

1. Nella pagina Distribuzioni selezionare la distribuzione MySQL creata nel task 1.

2. Nella pagina dei dettagli della distribuzione selezionare Avvia console.

3. Connettersi alla console di distribuzione MySQL di origine utilizzando le credenziali di amministratore specificate durante la creazione della distribuzione nel task 1.

4. Nel menu di navigazione selezionare Connessioni DB.

5. Rivedere le credenziali per HeatWave sulla connessione OCI. Prendi nota del dominio e dell'alias.

6. Aggiungere ed eseguire un'estrazione di Change Data Capture con i seguenti valori:

   • Per Tipo estrazione, selezionare Modifica acquisizione dati.

   • In Nome processo, immettere un nome per il processo di estrazione.

   • Per Dominio, selezionare il dominio.

   • Per Alias, selezionare l'alias.

   • In Nome trail estrazione, immettere un nome per il file trail.

   • Nella pagina File dei parametri, aggiungere quanto segue:

     TABLE SRC_OCIGGLL.*;

7. Aggiungere ed eseguire un'estrazione caricamento iniziale con i seguenti valori:

   • Per Tipo estrazione, selezionare Estrazione caricamento iniziale.

   • In Nome processo, immettere un nome.

   • Nella pagina File dei parametri, aggiungere quanto segue:

     TABLE SRC_OCIGGLL.*;

Task 3: Creare il percorso di distribuzione per un'estrazione caricamento iniziale

1. Nella pagina Distribuzioni selezionare la distribuzione di Autonomous AI Database di destinazione.

2. Nella pagina dei dettagli della distribuzione, selezionare Avvia console, quindi eseguire il login come utente amministratore.

3. Se si utilizza l'area di memorizzazione delle credenziali IAM, passare al passo Crea percorso di distribuzione. Se si utilizza l'area di memorizzazione delle credenziali GoldenGate, creare un utente con il quale GoldenGate di origine utilizza per connettersi a GoldenGate di destinazione.

   1. Nel menu di navigazione selezionare Amministrazione utente.

   2. Selezionare Aggiungi nuovo utente (icona più), completare i campi come indicato di seguito, quindi selezionare Sottometti.

      • Per Nome utente, immettere ggsnet.

      • Per Ruolo, selezionare Operatore.

      • Immettere due volte la password per la verifica.

4. Nella console di distribuzione MySQL di origine, creare una connessione percorso per l'utente creato nel passo precedente.

   1. Nel menu di navigazione, selezionare Connessioni percorso.

   2. Selezionare Aggiungi connessione percorso (icona più), completare i campi come indicato di seguito, quindi selezionare Sottometti.

      • Per l'alias credenziali, immettere dpuser.

      • Per ID utente, immettere ggsnet

      • Per Password, immettere la stessa password utilizzata nel passo precedente.

5. Creare un percorso di distribuzione.

   1. Nella barra dei menu del servizio, selezionare Servizio di distribuzione, quindi selezionare Aggiungi percorso di distribuzione (icona più).

   2. Completare il modulo Aggiungi percorso come indicato di seguito.

      • Nella pagina Informazioni percorso:

        1. In Nome percorso, immettere un nome per questo percorso.

        2. Selezionare Next.

      • Nella pagina Opzioni origine, effettuare le operazioni riportate di seguito.

        1. Per Estrazione origine, lasciare vuoto.

        2. In Nome percorso, immettere il nome trail estrazione caricamento iniziale (I1).

        3. Selezionare Next.

      • Nella pagina Opzioni destinazione, effettuare le operazioni riportate di seguito.

        1. Per Destinazione, selezionare wss.

        2. Per Host di destinazione, immettere l'URL di distribuzione di destinazione senza le barre https:// o le barre finali.

        3. In Numero porta, immettere 443.

        4. Per Nome percorso, immettere I1.

        5. Per Metodo di autenticazione destinazione, selezionare Alias ID utente.

        6. Per Dominio, immettere il nome di dominio creato nel passo precedente.

        7. Per Alias, immettere l'alias creato nel passo precedente (dpuser).

        8. Selezionare Next.

   3. Selezionare Crea ed esegui.

   Si torna alla pagina Servizio di distribuzione in cui è possibile rivedere il percorso creato.

6. Esaminare il percorso di distribuzione:

   1. Selezionare Servizio ricevente.

   2. Esaminare i dettagli del percorso di distribuzione.

Task 4: Aggiungere un Replicat per l'estrazione del carico iniziale

1. Nella console di distribuzione OCI GoldenGate di destinazione, aggiungere una tabella di checkpoint.

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

   2. Selezionare Connetti a database.

   3. Nel menu di navigazione selezionare Checkpoint.

   4. Nella pagina Checkpoint, selezionare Aggiungi checkpoint (icona più).

   5. Per Tabella checkpoint, immettere SRCMIRROR_OCIGGLL.CHECKTABLE.

   6. Selezionare Sottometti.

      Suggerimento: la schermata non verrà aggiornata al momento della sottomissione. Per confermare l'aggiunta della tabella di checkpoint, immettere SRCMIRROR_OCIGGLL.CHECKTABLE nel campo di ricerca, quindi selezionare Cerca.

2. Aggiungere Replicat:

   1. Selezionare Servizio amministratore, quindi selezionare Aggiungi Replicat (icona più).

   2. Nella pagina Aggiungi replica, completare i campi modulo riportati di seguito, quindi selezionare Successivo.

      • Per il tipo Replicat selezionare Replicat non integrato.

      • In Nome processo, immettere un nome, ad esempio RIL.

   3. Nella pagina Opzioni replica, completare i campi modulo riportati di seguito, quindi selezionare Successivo.

      • Per Nome, immettere il nome del trail dal task 2 (I1).

      • Per Dominio, selezionare il dominio per la connessione ad Autonomous AI Database.

      • In Alias, selezionare l'alias della connessione Autonomous AI Database.

      • Per Tabella checkpoint, selezionare la tabella Checkpoint creata nel Passo 1.

   4. Nella pagina Opzioni gestite, lasciare i campi così come sono e selezionare Successivo.

   5. Nella pagina Parametri replica aggiungere il mapping riportato di seguito, quindi selezionare Crea ed esegui.

      MAP SRC_OCIGGLL.*, TARGET SRCMIRROR_OCIGGLL.*;

   Si torna alla pagina Panoramica, in cui è possibile rivedere i dettagli di Replicat.

3. Selezionare Replicat (RIL) e visualizzarne i dettagli.

4. Selezionare Statistiche ed esaminare il numero di inserimenti. Aggiornare la pagina.

   • Se il numero di inserimenti non cambia, tutti i record del caricamento iniziale sono stati caricati ed è possibile arrestare Replicat (RIL)

   • Se il numero di inserimenti continua ad aumentare, continuare ad aggiornare la pagina fino a quando i record Caricamento iniziale non vengono caricati tutti prima di continuare.

Task 5: verificare il carico iniziale

1. Nella console di Oracle Cloud, aprire Azioni del database dalla pagina dei dettagli del database Autonomous AI Lakehouse.

2. In Database Actions, in Sviluppo, selezionare SQL.

3. Nello strumento SQL immettere nel foglio di lavoro ciascuna delle istruzioni seguenti e selezionare Esegui istruzione:

   SELECT * FROM SRCMIRROR_OCIGGLL.SRC_CITY;
   SELECT * FROM SRCMIRROR_OCIGGLL.SRC_CUSTOMER;

L'output deve restituire i dati caricati nelle tabelle del database di destinazione in seguito al caricamento iniziale.

Task 6: Creare un percorso di distribuzione per un'acquisizione dei dati di modifica

1. Nella console di distribuzione di origine selezionare Servizio di distribuzione.

2. Selezionare Aggiungi percorso di distribuzione.

3. Completare il modulo Aggiungi percorso come indicato di seguito.

   1. Nella pagina Informazioni percorso:

      1. In Nome percorso, immettere un nome.

      2. Selezionare Next.

   2. Nella pagina Opzioni origine, effettuare le operazioni riportate di seguito.

      1. Per Estrazione origine, selezionare Estrazione acquisizione dati modifica (ECDC).

      2. In Nome percorso, selezionare il file trail di Change Data Capture (C1).

      3. Selezionare Next.

   3. Nella pagina Opzioni destinazione, effettuare le operazioni riportate di seguito.

      1. Per Destinazione, selezionare wss.

      2. Per Host di destinazione, immettere l'URL della console di distribuzione di destinazione, disponibile nella pagina dei dettagli della distribuzione, senza le barre https:// o le barre finali.

      3. In Numero porta, immettere 443.

      4. Per Nome percorso, immettere C1.

      5. Per Metodo di autenticazione destinazione, selezionare Alias ID utente.

      6. Per Dominio, immettere il nome del dominio.

      7. Per Alias, immettere l'alias.

   4. Selezionare Crea percorso ed esegui.

4. Nella console di distribuzione target, selezionare Servizio ricevente, quindi rivedere il percorso del ricevente creato.

Task 7: aggiungere un Replicat per Change Data Capture

1. Aggiungere Replicat con i valori seguenti:

   1. Nella pagina Informazioni Replicat:

      • In Tipo replicato, selezionare Replicat coordinato.

      • In Nome processo, immettere un nome, ad esempio RCDC.

   2. Nella pagina Opzioni Replicat:

      • In Replicat trail, immettere il nome del trail dal task 2 (C1).

      • Per Dominio, selezionare il dominio per la connessione ad Autonomous AI Database.

      • In Alias, immettere l'alias credenziale.

      • In Tabella checkpoint, selezionare la tabella Checkpoint creata.

   3. Nella pagina Parametri replica aggiungere il mapping riportato di seguito, quindi selezionare Crea ed esegui.

      MAP SRC_OCIGGLL.*, TARGET SRCMIRROR_OCIGGLL.*;

2. Nella pagina Panoramica del servizio di amministrazione, selezionare Replicat per caricamento iniziale (RIL) e visualizzarne i dettagli.

3. Selezionare Statistiche ed esaminare il numero di inserimenti. Aggiornare la pagina.

   • Se il numero di inserimenti non cambia, tutti i record del caricamento iniziale sono stati caricati ed è possibile arrestare Replicat (RIL)

   • Se il numero di inserimenti continua ad aumentare, continuare ad aggiornare la pagina fino a quando i record Caricamento iniziale non vengono caricati tutti prima di continuare.

4. Tornare alla pagina Panoramica del servizio di amministrazione, quindi avviare RCDC (Coordinated Replicat).

5. Dopo aver avviato Coordinated Replicat, rivedere i relativi Dettagli e Statistiche per visualizzare il numero di inserimenti.

Task 8: Verifica acquisizione dati modifica

Esegui gli aggiornamenti al HeatWave di origine nel database OCI per verificare la replica in Autonomous AI Lakehouse.

1. In OCI Bastion creare una sessione di inoltro della porta SSH utilizzando MySQL IP e la porta 3306. Aggiungere la chiave SSH pubblica.

2. Connettiti a MySQL in Cloud Shell utilizzando la chiave privata e la porta 3306.

3. Dopo aver eseguito correttamente la connessione, eseguire il comando seguente:

   mysqlsh admin@localhost:3306 --sql

4. Eseguire lo script seguente per eseguire gli inserimenti in HeatWave nel database OCI:

   use SRC_OCIGGLL;
   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);
   commit;

5. Nella console di distribuzione MySQL di origine, selezionare il nome Estrazione acquisizione dati modifica, quindi selezionare Statistiche. Verificare che in SRC_OCIGGLL.SRC_CITY siano presenti 10 inserimenti.

Nota: se Extract non ha acquisito alcun inserimento, riavviare Extract.

Task 9: Monitoraggio e manutenzione dei processi

1. Monitorare il processo di replica.

2. Gestisci file trail.