Replica i dati da Autonomous AI Transaction Processing a Microsoft Fabric Eventstream

Impara a replicare i dati da un'origine Autonomous AI Transaction Processing a Microsoft Fabric Eventstream utilizzando OCI GoldenGate.

Prima di iniziare

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

Istanza di Autonomous AI Transaction Processing di origine.
Microsoft Fabric Eventstream di destinazione.

Impostazione dell'ambiente: Autonomous AI Transaction Processing

Se non si dispone già di un database di origine impostato per la replica, è possibile seguire questi passi per caricare uno schema di esempio da utilizzare per questo avvio rapido. Questo Quickstart utilizza Autonomous AI Transaction Processing per il database di origine.

Per impostare l'elaborazione delle transazioni AI autonoma di origine:

Scaricare ed estrarre lo schema di database di esempio.
Nella console di Oracle Cloud, selezionare l'istanza di Autonomous AI Transaction Processing (ATP) dalla pagina Database AI autonomi per visualizzarne i dettagli e accedere a Database Actions.
Sblocca l'utente GGADMIN:
1. Selezionare Azioni del database, quindi Utenti del database.
2. Individuare GGADMIN, quindi selezionare il menu con i puntini di sospensione (tre punti) e selezionare Modifica.
3. Nel pannello Modifica utente immettere la password GGADMIN, confermare la password, quindi deselezionare Account bloccato.
4. Selezionare Applica modifiche.
Caricare lo schema e i dati di esempio di origine:
1. Nel menu Azioni database, in Sviluppo, selezionare SQL.
2. Copiare e incollare lo script da OCIGGLL_OCIGGS_SETUP_USERS_ATP.sql nel foglio di lavoro SQL.
3. Selezionare Esegui script. Nella scheda Output script vengono visualizzati i messaggi di conferma.
4. Cancellare il foglio di lavoro SQL, quindi copiare e incollare lo script SQL da OCIGGLL_OCIGGS_SRC_USER_SEED_DATA.sql.
  
  Suggerimento: potrebbe essere necessario eseguire ciascuna istruzione 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.
Abilita il log supplementare:
1. Cancellare il foglio di lavoro SQL.
2. Immettere l'istruzione seguente, quindi selezionare Esegui istruzione:
```
ALTER PLUGGABLE DATABASE ADD SUPPLEMENTAL LOG DATA;
```

Task 1: creare le risorse OCI GoldenGate

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

Creare una distribuzione Oracle per l'istanza di Autonomous AI Transaction Processing di origine.
Creare una distribuzione Big Data per il flusso di eventi Microsoft Fabric di destinazione.
Creare una connessione all'elaborazione delle transazioni AI autonoma di origine.
Creare una connessione a Microsoft Fabric Eventstream.
Creare una connessione a GoldenGate, quindi assegnare questa connessione alla distribuzione Oracle di origine.
Assegnare la connessione Autonomous AI Transaction Processing alla distribuzione Oracle di origine.
Assegnare la connessione Microsoft Fabric Eventstream alla distribuzione Big Data di destinazione.

Task 2: Aggiunta dell'estrazione

Nella pagina Distribuzioni selezionare la distribuzione Autonomous AI Transaction Processing di origine.
Nella pagina dei dettagli della distribuzione selezionare Avvia console.
Eseguire il login con nome utente e password dell'amministratore della distribuzione di origine.
Aggiungi un'estrazione.

Task 3: Aggiungi percorso di distribuzione

Se si utilizza l'area di memorizzazione delle credenziali GoldenGate, creare un utente per il percorso di distribuzione nella distribuzione dei Big Data destinazione, altrimenti passare al passo 3.
Nella console di distribuzione origine GoldenGate aggiungere una connessione percorso per l'utente creato nel Passo 1.
1. Nella console di distribuzione GoldenGate di origine, selezionare Connessioni percorso nella navigazione a sinistra.
2. Selezionare Aggiungi connessione percorso (icona più), quindi completare quanto riportato di seguito.
  1. Per Alias credenziale, immettere GGSNetwork.
  2. In ID utente, immettere il nome dell'utente creato nel Passo 1.
  3. Immettere due volte la password dell'utente per la verifica.
3. Selezionare Sottometti.
  
  La connessione al percorso viene visualizzata nell'elenco Connessioni percorso.
Nella console di distribuzione origine, aggiungere un percorso di distribuzione con i valori seguenti:
1. Nella pagina Opzioni di origine effettuare le operazioni riportate di seguito.
  - Per Estrazione origine, selezionare l'estrazione creata nel task 2.
  - In Nome percorso, immettere un nome di due caratteri, ad esempio E1.
2. Nella pagina Opzioni di destinazione effettuare le operazioni riportate di seguito.
  - Per Host di destinazione, immettere il dominio host della distribuzione di destinazione.
  - In Numero porta, immettere 443.
  - In Nome percorso, immettere un nome di due caratteri, ad esempio E1.
  - In Alias, immettere l'alias credenziale creato nel Passo 2.
Nella console di distribuzione Big Data destinazione, esaminare il percorso del ricevente creato come risultato del percorso di distribuzione.
1. Nella console di distribuzione Big Data di destinazione selezionare Servizio ricevente.
2. Rivedere i dettagli del percorso. Questo percorso è stato creato come risultato del percorso di distribuzione creato nel passo precedente.

Task 4: Aggiungere ed eseguire Replicat

Nella console di distribuzione Big Data di destinazione, selezionare Replicat, quindi selezionare Aggiungi Replicat (icona più).
Aggiungere un Replicat con i valori seguenti:
1. Nella pagina Informazioni Replicat, in Tipo Replicat, selezionare Replicat classico, immettere un Nome processo, quindi selezionare Successivo.
2. Nella pagina Opzioni replica:
  - Per Nome, immettere il nome dello trail dal task 2.
  - Per Destinazione, selezionare Microsoft Fabric Eventstream.
  - In Formato, selezionare il formato da includere nel flusso di eventi Microsoft Fabric. Il valore predefinito è JSON.
  - Per Alias disponibile, selezionare la connessione Eventstream Microsoft Fabric dall'elenco a discesa.
3. Nella pagina Opzioni gestite, lasciare le impostazioni predefinite.
4. Nella pagina Parametri replica, lasciare le impostazioni predefinite.
5. Nella pagina Proprietà Replicat aggiornare i campi contrassegnati con #TODO.
Selezionare Crea ed esegui.

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

Task 5: Verificare la replica

Eseguire alcuni aggiornamenti all'istanza di Autonomous AI Transaction Processing di origine per verificare la replica in Microsoft Fabric Lakehouse.

Nella console di Oracle Cloud, aprire il menu di navigazione, selezionare Oracle AI Database, quindi selezionare Autonomous AI Transaction Processing.
Nell'elenco delle istanze di Autonomous AI Transaction Processing selezionare l'istanza di origine per visualizzarne i dettagli.
Nella pagina dei dettagli del database selezionare Azioni del database.

Nota: il login deve essere eseguito automaticamente. In caso contrario, eseguire il login con le credenziali del database.
Nella home page delle azioni del database selezionare SQL.

Immettere quanto segue nel foglio di lavoro e 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);

Nella console di distribuzione ATP di origine selezionare il nome di estrazione, quindi selezionare Statistiche. Verificare che in SRC_OCIGGLL.SRC_CITY siano presenti 10 inserimenti.
Nella console di distribuzione Big Data OCI GoldenGate di destinazione, selezionare il nome Replicat, quindi selezionare Statistiche. Verificare che in SRC_OCIGGLL.SRC_CITY siano presenti 10 inserimenti.
Nella console di Oracle Cloud, accedere al bucket di Oracle Object Storage e controllarne il contenuto.