Invia dati da HeatWave su OCI agli hub eventi di Azure

Scopri come utilizzare OCI GoldenGate per replicare i dati da HeatWave su OCI agli hub eventi di Azure.

Prima di iniziare

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

  • OCI Bastion, per connettersi a HeatWave sul database OCI, caricare il database di esempio ed eseguire inserimenti.
  • Un HeatWave nel database OCI da utilizzare come database di origine.
  • Spazio di nomi degli hub eventi di Azure e hub eventi creati
    Nota

    Kafka Surface non è abilitato nel livello base degli hub eventi di Azure. Il livello Standard o Premium è obbligatorio.

Panoramica

Questo esempio di avvio rapido mostra come impostare ed eseguire una replica tra OCI MySQL Database e Azure Event Hubs utilizzando OCI GoldenGate.

Task 0: Impostare l'ambiente

Per impostare l'ambiente per questo Quickstart:
  1. Scaricare lo script di dati di esempio, quindi eseguire lo script in 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 nel database OCI.
    2. Nella lista di sicurezza della subnet creare una regola di entrata per port TCP/3306.

Task 2: Creazione delle estrazioni

  1. Nella pagina Distribuzioni selezionare la distribuzione MySQL creata nel task 1.
  2. Nella pagina dei dettagli della distribuzione fare clic su Avvia console.
  3. Collegarsi alla console di distribuzione MySQL di origine utilizzando le credenziali di amministratore specificate durante la creazione della distribuzione nel task 1.
  4. Aprire il menu di navigazione, quindi selezionare Configurazione.
  5. Rivedere le credenziali per la connessione al server MySQL Database. Prendere nota del dominio e delle alias.
  6. Tornare alla pagina Panoramica del servizio di amministrazione.
  7. Nella pagina Panoramica servizio di amministrazione, fare clic su Aggiungi estrazione (icona più).
  8. Nella pagina Tipo di estrazione selezionare Modifica estrazione acquisizione dati, quindi fare clic su Successivo.
  9. Completare le opzioni di estrazione come indicato di seguito, quindi fare clic su Successivo.
    1. In Nome processo, immettere un nome per Extract, ad esempio CDCEXT.
    2. Per Dominio credenziale, selezionare il dominio dal Passo 5.
    3. Per Alias credenziale, selezionare l'alias dal Passo 5.
    4. Per Nome percorso, immettere un nome trail di due caratteri, ad esempio C1.
  10. Abilita Remote se l'acquisizione da un MySQL Database che non utilizza identificativi di transazione globali (GTID).
  11. Nella pagina Estrai parametri, aggiungere quanto riportato di seguito.
    TABLE SRC_OCIGGLL.*;
  12. Fare clic su Crea ed esegui.

    Si torna alla pagina Panoramica del servizio di amministrazione, in cui è possibile osservare l'avvio dell'estrazione.

Task 3: Creare il percorso di distribuzione per la distribuzione dei Big Data di destinazione

  1. Nella pagina Distribuzioni selezionare la distribuzione Big Data di destinazione.
  2. Nella pagina dei dettagli della distribuzione fare clic su Avvia console.
  3. Creare un utente per il percorso di distribuzione:
    1. Aprire il menu di navigazione, quindi fare clic su Amministratore.
    2. Fare clic su Aggiungi nuovo utente (icona più), completare i campi come indicato di seguito, quindi fare clic su 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 credenziale per l'utente creato nel passo precedente.
    1. Aprire il menu di navigazione, quindi selezionare Configurazione.
    2. Fare clic su Aggiungi credenziale (icona più), completare i campi come indicato di seguito, quindi fare clic su Sottometti.
      • Per Dominio credenziale, immettere GGSNetwork.
      • Per Alias credenziale, immettere dpuser.
      • Per Nome database, è possibile immettere qualsiasi nome e lasciare vuoti i campi Server database e Porta oppure utilizzare i valori predefiniti.
      • Per ID utente, immettere ggsnet.
      • Per la password, immettere la stessa password utilizzata nel passo precedente.
  5. Creare un percorso di distribuzione:
    1. Nella console di distribuzione MySQL di origine, fare clic su Servizio di distribuzione, quindi su Aggiungi percorso (icona più).
    2. Completare i campi riportati di seguito e fare clic su Crea ed esegui.
    • In Nome percorso, immettere un nome per questo percorso.
    • Per Estrazione origine, selezionare Modifica estrazione acquisizione dati (CDCEXT).
    • In Nome percorso, selezionare il file trail di estrazione di acquisizione dati di modifica (C1).
    • Per Metodo di autenticazione destinazione, selezionare UserID Alias.
    • Per Destinazione, selezionare wss.
    • Per Host di destinazione, immettere l'URL della console di distribuzione OCI GoldenGate di destinazione, senza le barre https:// o le barre finali.
    • Per Numero porta, immettere 443.
    • Per Nome percorso, immettere C1.
    • Per Dominio, immettere il nome di dominio creato nel passo precedente.
    • Per Alias, immettere l'alias creato nel passo precedente.

    Si torna alla pagina Panoramica del servizio di distribuzione, in cui è possibile rivedere il percorso creato.

  6. Nella console di distribuzione Big Data OCI GoldenGate di destinazione, esaminare il percorso del ricevente creato come risultato del percorso di distribuzione:
    1. Fare clic su Servizio ricevente.
    2. Rivedere i dettagli del percorso del ricevente.

Task 4: aggiungere un Replicat per gli hub eventi di Azure

  1. Nella distribuzione dei Big Data, fare clic su Administrator Service, quindi su Aggiungi Replicat (icona più).
  2. Aggiungere un valore Replicat con i valori seguenti:
    1. Nella pagina Informazioni Replicat, sotto il tipo Replicat, selezionare Classic Replicat e immettere un nome processo.
    2. Nella pagina Opzioni Replicat:
      • In Nome percorso, immettere il nome dello storico dal task 2.
      • In Destinazione, selezionare un hub eventi di Azure.
      • In Alias selezionare la connessione degli hub eventi di Azure creata nel task 1.
    3. Nella pagina Parametri Replicat, lasciare l'impostazione predefinita.
    4. Nella pagina File delle proprietà, fornire un nome di argomento per topicMappingTemplate.
    5. Fare clic su Crea ed esegui.

Task 5: verifica della replica dei dati da HeatWave su OCI agli hub eventi Azure

Eseguire gli aggiornamenti al file HeatWave di origine nel database OCI per verificare la replica negli hub eventi di Azure.
  1. In OCI Bastion creare una sessione di inoltro della porta SSH utilizzando l'IP MySQL e port 3306. Aggiungere la chiave SSH pubblica.
  2. Connettersi a MySQL in Cloud Shell utilizzando la chiave privata e port 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 Change Data Capture Extract, quindi fare clic su Statistiche. Verificare che in SRC_OCIGGLL.SRC_CITY siano presenti 10 inserimenti.
  6. Nella console di distribuzione Big Data di destinazione selezionare il nome Replicat, quindi fare clic su Statistiche. Verificare che in SRC_OCIGGLL.SRC_CITY siano presenti 10 inserimenti.
  7. In Hub eventi di Azure è possibile controllare le statistiche dei messaggi.