Replica i dati da Autonomous AI Transaction Processing ad Azure Synapse Analytics
Questo QuickStart mostra come impostare una replica dei dati da Autonomous AI Transaction Processing a Azure Synapse Analytics utilizzando OCI GoldenGate.
Prima di iniziare
Per completare correttamente questo avvio rapido, è necessario disporre dei seguenti elementi:
-
Contenitore di storage Azure associato a Azure Synapse Analytics Workspace
-
Credenziale con ambito database di Azure Synapse Analytics per concedere le autorizzazioni al pool SQL per accedere all'account di storage
-
Esistenza tabella di destinazione: le tabelle di destinazione devono esistere nel database Synapse prima della replica. Poiché GoldenGate utilizza un'istruzione SQL di unione, la tabella di destinazione deve essere una tabella distribuita hash.
-
Connessione di storage OCI GoldenGate Azure Data Lake assegnata alla distribuzione. Se non esiste, creare una connessione di Azure Data Lake Storage e assegnarla alla distribuzione.
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:
-
Selezionare Azioni del database, quindi Utenti del database.
-
Individuare GGADMIN, quindi selezionare il menu con i puntini di sospensione (tre punti) e selezionare Modifica.
-
Nel pannello Modifica utente immettere la password GGADMIN, confermare la password, quindi deselezionare Account bloccato.
-
Selezionare Applica modifiche.
-
-
Caricare lo schema e i dati di esempio di origine:
-
Nel menu Azioni database, in Sviluppo, selezionare SQL.
-
Copiare e incollare lo script da
OCIGGLL_OCIGGS_SETUP_USERS_ATP.sqlnel foglio di lavoro SQL. -
Selezionare Esegui script. Nella scheda Output script vengono visualizzati i messaggi di conferma.
-
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.
-
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:
-
Cancellare il foglio di lavoro SQL.
-
Immettere l'istruzione seguente, quindi selezionare Esegui istruzione:
ALTER PLUGGABLE DATABASE ADD SUPPLEMENTAL LOG DATA;
-
Impostazione dell'ambiente: Azure Synapse Analytics
-
Aprire Azure Synapse Analytics Workspace.
-
Selezionare Nuovo, quindi Script SQL.
-
Connettersi al pool sql e selezionare il database.
-
Per creare una cifratura della chiave master, immettere il comando seguente:
CREATE MASTER KEY ENCRYPTION BY PASSWORD='<password>'; -
Utilizzare il comando seguente per creare la credenziale con ambito database:
Assicurarsi di sostituire i segnaposto
<storage-account-name>e<storage-account-access-key>con i relativi valori effettivi.CREATE DATABASE SCOPED CREDENTIAL <credential name> WITH IDENTITY='<storage-account-name>', SECRET='<storage-account-access-key>'; -
Eseguire lo script di creazione tabella:
CREATE TABLE [dbo].[SRC_CUSTOMER] ( CUSTID NUMERIC(10) NOTNULL, DEAR NUMERIC(1), LAST_NAME VARCHAR(50), FIRST_NAME VARCHAR(50), ADDRESS VARCHAR(100), CITY_ID NUMERIC(10), PHONE VARCHAR(50), AGE NUMERIC(3), SALES_PERS_ID NUMERIC(10), constraint PK_SRC_CUSTOMER primarykeyNONCLUSTERED (CUSTID) NOT ENFORCED ) WITH(DISTRIBUTION=HASH ([CUSTID]), HEAP ) GO -
Verificare che la tabella
dbo.SRC_Customersia stata creata.
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 Azure Synapse Analytics di destinazione.
-
Creare una connessione all'elaborazione delle transazioni AI autonoma di origine.
-
Assegnare la connessione Autonomous AI Transaction Processing alla distribuzione Oracle di origine.
-
Assegnare la connessione di Azure Synapse Analytics 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.
Task 3: Aggiunta ed esecuzione del 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.
-
Nella console di distribuzione GoldenGate di origine, selezionare Connessioni percorso nella navigazione a sinistra.
-
Selezionare Aggiungi connessione percorso (icona più), quindi completare quanto riportato di seguito.
-
Per Alias credenziale, immettere
GGSNetwork. -
In ID utente, immettere il nome dell'utente creato nel Passo 1.
-
Immettere due volte la password dell'utente per la verifica.
-
-
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:
-
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.
-
-
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.
-
Nella console di distribuzione Big Data di destinazione selezionare Servizio ricevente.
-
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:
-
Nella pagina Informazioni Replicat, in Tipo Replicat, selezionare Replicat classico, immettere un nome di processo, quindi selezionare Successivo.
-
Nella pagina Opzioni replica:
-
Per Nome, immettere il nome dello trail dal task 2.
-
Per Dominio, selezionare un dominio.
-
Per Alias, selezionare la connessione di Azure Synapse Analytics creata nel task 1.
-
Per Tabella checkpoint, selezionare la tabella di checkpoint creata per la distribuzione di destinazione.
-
-
Nella pagina Parametri Replicat, sostituire
MAP *.*, TARGET *.*;con:MAP SRC_OCIGGLL.SRC_CUSTOMER, TARGET dbo.SRC_CUSTOMER; -
Nella pagina Proprietà Replicat, configurare le proprietà di Azure Synapse Analytics:
Nota: modificare le proprietà contrassegnate come
TODO.-
gg.eventhandler.abs.bucketMappingTemplateè il contenitore di storage di Azure associato a Azure Synapse Analytics Workspace -
gg.eventhandler.synapse.credentialè il nome della credenziale utilizzata per autenticare Azure Storage Container associato a Azure Synapse Analytics Workspace
-
-
-
Selezionare Crea ed esegui.
Si torna alla pagina Panoramica, 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 Azure Data Lake Storage.
-
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 Azioni database selezionare SQL.
-
Immettere quanto segue nel foglio di lavoro e selezionare Esegui script.
-
Nella console di distribuzione GoldenGate OCI di origine, selezionare il nome Extract, quindi selezionare Statistiche. Verificare che in SRC_OCIGGLL.SRC_CUSTOMER siano presenti 7 inserimenti.
Insert into SRC_OCIGGLL.SRC_CUSTOMER (CUSTID,DEAR,LAST_NAME,FIRST_NAME,ADDRESS,CITY_ID,PHONE,AGE,SALES_PERS_ID) values (1001,0,'Brendt','Paul','10 Jasper Blvd.',107,'(212) 555 2146',19,10); Insert into SRC_OCIGGLL.SRC_CUSTOMER (CUSTID,DEAR,LAST_NAME,FIRST_NAME,ADDRESS,CITY_ID,PHONE,AGE,SALES_PERS_ID) values (1002,0,'McCarthy','Robin','27 Pasadena Drive',11,'(214) 555 3075',29,11); Insert into SRC_OCIGGLL.SRC_CUSTOMER (CUSTID,DEAR,LAST_NAME,FIRST_NAME,ADDRESS,CITY_ID,PHONE,AGE,SALES_PERS_ID) values (1003,0,'Travis','Peter','7835 Hartford Drive',12,'(510) 555 4448',34,12); Insert into SRC_OCIGGLL.SRC_CUSTOMER (CUSTID,DEAR,LAST_NAME,FIRST_NAME,ADDRESS,CITY_ID,PHONE,AGE,SALES_PERS_ID) values (1004,0,'Larson','Joe','87 Carmel Blvd.',13,'(213) 555 5095',45,13); Insert into SRC_OCIGGLL.SRC_CUSTOMER (CUSTID,DEAR,LAST_NAME,FIRST_NAME,ADDRESS,CITY_ID,PHONE,AGE,SALES_PERS_ID) values (1005,0,'Goldschmidt','Tony','91 Torre drive',14,'(619) 555 6529',55,20); Insert into SRC_OCIGGLL.SRC_CUSTOMER (CUSTID,DEAR,LAST_NAME,FIRST_NAME,ADDRESS,CITY_ID,PHONE,AGE,SALES_PERS_ID) values (1006,0,'Baker','William','2890 Grant Avenue',15,'(312) 555 7040',64,21); Insert into SRC_OCIGGLL.SRC_CUSTOMER (CUSTID,DEAR,LAST_NAME,FIRST_NAME,ADDRESS,CITY_ID,PHONE,AGE,SALES_PERS_ID) values (1007,0,'Swenson','Jack','64 Imagination Drive',19,'(202) 555 8125',74,22) -
Nella console di distribuzione Big Data OCI GoldenGate di destinazione, selezionare il nome Replicat, quindi selezionare Statistiche. Verificare che in SRC_OCIGGLL.SRC_CUSTOMER siano presenti 7 inserimenti.
-
Nella console di Azure, passare alla console dell'area di lavoro di Azure Synapse Analytics. Eseguire Seleziona * da dbo.SRC_CUSTOMER e verificare che in SRC_OCIGGLL.SRC_CUSTOMER siano presenti 7 inserimenti.