Daten von HeatWave auf OCI in Autonomous AI Lakehouse replizieren

Bevor Sie beginnen

Um diesen Schnellstart erfolgreich abzuschließen, benötigen Sie Folgendes:

OCI Bastion, um eine Verbindung zu HeatWave auf OCI herzustellen, die Beispieldatenbank zum Laden und Einfügevorgänge auszuführen
Eine HeatWave auf OCI-Datenbank, die als Quelldatenbank dient
Eine Autonomous AI Lakehouse-Instanz, die als Zieldatenbank dient

Umgebung eingerichtet: HeatWave auf OCI

So richten Sie die Umgebung für diesen Schnellstart ein:

Herunterladen Sie das Beispieldatenskript, und führen Sie das Skript in der OCI HeatWave-Datenbank aus, um die Datenbank zu erstellen und die Daten zum Laden zu laden.

Erstellen Sie einen ggadmin-Benutzer mit dem folgenden Skript. Ersetzen Sie <ggadmin-password> durch ein gültiges Kennwort:

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';

Öffnen Sie port 3306, über die OCI GoldenGate eine Verbindung herstellen kann.
1. Suchen Sie in der Oracle Cloud-Konsole das Subnetz, das von der HeatWave-auf-OCI-Datenbank verwendet werden.
2. Erstellen Sie in der Sicherheitsliste des Subnetzes eine Ingress-Regel für port TCP/3306.
Laden sie die Zielschemaskripte herunter, und führen Sie die Skripte in der Autonomous AI Lakehouse-Instanz aus. Mit dem SQL-Tool von Autonomous AI Lakehouse Database Actions können Sie die Skripte ausführen:
1. öffnen Sie in der Oracle Cloud-Konsole die Seite "Details" der Autonomous AI Lakehouse-Datenbank, und klicken Sie auf Datenbankaktionen.
2. Klicken Sie in den Datenbankaktionen unter Entwicklung auf SQL.
3. Klicken Sie im SQL-Tool auf Skript ausführen, und kopieren Sie das Skript aus OCIGGLL_OCIGGS_SETUP_USERS_ADW.sql. Wenn der Vorgang erfolgreich war, werden auf der Registerkarte "Skriptausgabe" Bestätigungsmeldungen angezeigt.
4. Löschen Sie das SQL-Arbeitsblatt, kopieren Sie die Skripte zum Erstellen von Tabellen aus OCIGGLL_OCIGGS_SRC_MIRROR_USER_SEED_DATA.sql, und fügen Sie sie ein. Die Daten werden in eine spätere Aufgabe geladen.
  
  Tipp:
  Möglicherweise müssen Sie jede Anweisung zum Erstellen von Tabellen separat ausführen, damit das SQL-Tool die Skripte erfolgreich ausführen kann.
5. Um zu prüfen, ob die Tabellen erfolgreich erstellt wurden, schließen Sie das SQL-Fenster, und öffnen Sie es erneut. Suchen Sie auf der Registerkarte "Navigator" nach dem Schema SRC_OCIGGLL, und wählen Sie die Tabellen in den entsprechenden Dropdown-Listen aus.

Aufgabe 1: OCI GoldenGate-Ressourcen erstellen

Für dieses Schnellstartbeispiel sind Deployments und Verbindungen sowohl für die Quelle als auch für das Ziel erforderlich.

Erstellen Sie ein Deployment für die HeatWave on OCI-Quelldatenbank.
Erstellen Sie ein Deployment für das Autonomous AI Lakehouse-Ziel.
Erstellen Sie eine Verbindung zur HeatWave on OCI-Quelldatenbank.
Erstellen Sie eine Verbindung für das Autonomous AI Lakehouse-Ziel.
Erstellen Sie eine Verbindung zu GoldenGate, und weisen Sie diese Verbindung dem Deployment der Quelle MySQL zu.
Weisen Sie die Quellverbindung dem MySQL-Quell-Deployment zu.
Weisen Sie die Zielverbindung dem Oracle-Ziel-Deployment zu.

Aufgabe 2: Extracts erstellen

Wählen Sie auf der Seite "Deployments" das MySQL-Deployment aus, das Sie in Aufgabe 1 erstellt haben.
Klicken Sie auf der Seite "Deployment" auf Konsole starten.
Melden Sie sich bei der MySQL-Deployment-Konsole der Quelle mit den Administratorzugangsdaten an, die beim Erstellen des Deployments in Aufgabe 1 angegeben wurden.
Wählen Sie im Navigationsmenü die Option DB-Verbindungen aus.
Prüfen Sie die Zugangsdaten für die Verbindung HeatWave auf OCI. Notieren Sie sich die Domain und den Alias.
Fügen Sie eine Change Data Capture Extract mit den folgenden Werten hinzu, und führen Sie sie aus:
- Wählen Sie unter Extract Type die Option Change Data Capture aus.
- Geben Sie unter Prozessname einen Namen für den Extract-Prozess ein.
- Wählen Sie unter Domain die Domain aus.
- Wählen Sie unter Alias den Alias aus.
- Geben Sie unter Extract Trailname einen Namen für die Traildatei ein.
- Fügen Sie auf der Seite "Parameterdatei" Folgendes hinzu:
```
TABLE SRC_OCIGGLL.*;
```
Fügen Sie einen Extract für das erstmalige Laden hinzu, und führen Sie ihn aus mit den folgenden Werten:
- Wählen Sie unter Extract Type die Option Initial Load Extract aus.
- Geben Sie unter Prozessname einen Namen ein.
- Fügen Sie auf der Seite "Parameterdatei" Folgendes hinzu:
```
TABLE SRC_OCIGGLL.*;
```

Aufgabe 3: Distribution Path für eine Initial Load Extract erstellen

Wählen Sie auf der Seite "Deployments" das Autonomous AI Database-Ziel-Deployment.
Klicken Sie auf der Seite "Deployment" auf Konsole starten, und melden Sie sich als Admin-Benutzer an.
Wenn Sie den IAM-Zugangsdatenspeicher verwenden, fahren Sie mit dem Schritt "Distribution Path erstellen" fort. Wenn Sie den Zugangsdatenspeicher GoldenGate verwenden, erstellen Sie einen Benutzer, mit dem die Quelle GoldenGate eine Verbindung zum Ziel GoldenGate herstellt.
1. Klicken Sie im Navigationsmenü auf Benutzerverwaltung.
2. Klicken Sie wie folgt auf Neuen Benutzer hinzufügen (Pluszeichen), füllen Sie die Felder aus, und klicken Sie auf Weiterleiten:
  - Geben Sie unter Benutzername ggsnet ein.
  - Wählen Sie unter Rolle die Option Operator aus.
  - Geben Sie das Kennwort zur Bestätigung zweimal ein.
Erstellen Sie auf der Source-Deployment-Konsole MySQL eine Pfadverbindung für den im vorherigen Schritt erstellten Benutzer.
1. Klicken Sie im Navigationsmenü auf Pfadverbindungen.
2. Klicken Sie auf Pfadverbindung hinzufügen (Pluszeichen), füllen Sie die Felder wie folgt aus, und klicken Sie auf Weiterleiten:
  - Geben Sie als Zugangsdatenalias dpuser ein.
  - Geben Sie unter "Benutzer-ID" ggsnet ein.
  - Geben Sie unter "Kennwort" dasselbe Kennwort ein, das im vorherigen Schritt verwendet wurde.
Distribution Path erstellen.
1. Klicken Sie in der Servicemenüleiste auf Distribution Service und dann auf Distribution Path hinzufügen (Plussymbol).
2. Füllen Sie das Formular "Pfad hinzufügen" wie folgt aus:
  - Auf der Seite "Pfadinformationen":
    1. Geben Sie unter Pfadname einen Namen für diesen Pfad ein.
    2. Klicken Sie auf Weiter.
  - Gehen Sie auf der Seite {\b Source Options} wie folgt vor:
    1. Lassen Sie das Feld Quelle Extract leer.
    2. Geben Sie unter Trailname den Trailnamen Initial Load Extract (I1) ein.
    3. Klicken Sie auf Weiter.
  - Gehen Sie auf der Seite "Zieloptionen" wie folgt vor:
    1. Wählen Sie unter Ziel die Option wss aus.
    2. Geben Sie unter Zielhost die Ziel-Deployment-URL ohne https:// oder abschließende Schrägstriche ein.
    3. Geben Sie unter Portnummer die Nummer 443 ein.
    4. Geben Sie unter Trailname I1 ein.
    5. Wählen Sie unter Zielauthentifizierungsmethode die Option UserID Alias aus.
    6. Geben Sie unter Domain den im vorherigen Schritt erstellten Domainnamen ein.
    7. Geben Sie unter Alias den im vorherigen Schritt erstellten Alias ein (dpuser).
    8. Klicken Sie auf Weiter.
3. Klicken Sie auf Erstellen und ausführen.
Sie kehren zur Seite Distribution Service zurück, auf der Sie den erstellten Pfad prüfen können.
Hier finden Sie die Distribution Path:
1. Klicken Sie auf Receiver Service.
2. Prüfen Sie die Details von Distribution Path.

Aufgabe 4: Replicat für Initial Load Extract hinzufügen

Fügen Sie in der OCI GoldenGate-Deployment-Konsole des Ziels eine Checkpoint-Tabelle hinzu.
1. Öffnen Sie das Navigationsmenü, und klicken Sie auf DB-Verbindungen.
2. Klicken Sie auf Verbindung zur Datenbank herstellen.
3. Klicken Sie im Navigationsmenü auf Checkpoint.
4. Klicken Sie auf der Seite "Checkpoint" auf Checkpoint hinzufügen (Plussymbol).
5. Geben Sie unter Checkpoint-Tabelle SRCMIRROR_OCIGGLL.CHECKTABLE ein.
6. Klicken Sie auf Weiterleiten.
  
  Tipp:
  Die Seite wird beim Weiterleiten nicht aktualisiert. Um zu prüfen, ob die Checkpoint-Tabelle hinzugefügt wurde, geben Sie SRCMIRROR_OCIGGLL.CHECKTABLE in das Suchfeld ein, und klicken Sie auf Suchen.
Fügen Sie die Replicat hinzu:
1. Klicken Sie auf Administrator Service und dann auf Replicat hinzufügen (Pluszeichen).
2. Geben Sie auf der Seite "Replicat hinzufügen" Werte in die folgenden Formularfelder ein, und klicken Sie auf Weiter.
  - Wählen Sie als Replicat-Typ Nonintegrated Replicat aus.
  - Geben Sie unter Prozessname einen Namen wie RIL ein.
3. Geben Sie auf der Seite Replicat Options die folgenden Formularfelder ein, und klicken Sie auf Next (Weiter):
  - Geben Sie unter Name den Namen des Trail aus Aufgabe 2 (I1) ein.
  - Wählen Sie unter Domain die Domain für die Autonomous AI Database-Verbindung aus.
  - Wählen Sie unter Alias den Alias der autonomen KI-Datenbankverbindung aus.
  - Wählen Sie unter Checkpoint-Tabelle die Checkpoint-Tabelle aus, die Sie in Schritt 1 erstellt haben.
4. Lassen Sie die Felder auf der Seite "Verwaltete Optionen" unverändert, und klicken Sie auf Weiter.
5. Fügen Sie auf der Seite Replicat "Parameter" die folgende Zuordnung hinzu, und klicken Sie auf Erstellen und ausführen:
```
MAP SRC_OCIGGLL.*, TARGET SRCMIRROR_OCIGGLL.*;
```
Sie sind zurück zur Seite "Überblick", auf der Sie die Replicat-Details prüfen können.
Wählen Sie die Replicat (RIL) aus, und zeigen Sie die zugehörigen Details an.
Klicken Sie auf Statistiken, und prüfen Sie die Anzahl der Einfügungen. Aktualisieren Sie die Seite.
- Wenn sich die Anzahl der Einfügungen nicht ändert, wurden alle Datensätze aus der Initial Load geladen. Sie können das Replicat (RIL) stoppen.
- Wenn die Anzahl der Einfügevorgänge weiter zunimmt, aktualisieren Sie die Seite so lange, bis alle Datensätze der erstmaligen Ladung geladen sind, bevor Sie fortfahren.

Aufgabe 5: Erstmalige Ladung prüfen

Öffnen Sie in der Oracle Cloud-Konsole auf der Seite "Details" der Autonomous AI Lakehouse-Datenbank die Datenbankaktionen.
Klicken Sie in den Datenbankaktionen unter Entwicklung auf SQL.
Geben Sie im SQL-Tool jede der folgenden Anweisungen in das Arbeitsblatt ein, und klicken Sie auf Anweisung ausführen:
```
SELECT * FROM SRCMIRROR_OCIGGLL.SRC_CITY;
SELECT * FROM SRCMIRROR_OCIGGLL.SRC_CUSTOMER;
```

Die Ausgabe sollte die Daten zurückgeben, die als Ergebnis des erstmaligen Ladevorgangs in die Zieldatenbanktabellen geladen wurden.

Aufgabe 6: Distribution Path für Change Data Capture erstellen

Klicken Sie in der Quell-Deployment-Konsole auf Distribution Service.
Klicken Sie auf Distribution Path hinzufügen.
Füllen Sie das Formular "Pfad hinzufügen" wie folgt aus:
1. Auf der Seite "Pfadinformationen":
  1. Geben Sie unter Pfadname einen Namen ein.
  2. Klicken Sie auf Weiter.
2. Gehen Sie auf der Seite {\b Source Options} wie folgt vor:
  1. Wählen Sie unter Quelle Extract die Option Change Data Capture Extract (ECDC)) aus.
  2. Wählen Sie unter Trailname die Traildatei Change Data Capture (C1) aus.
  3. Klicken Sie auf Weiter.
3. Gehen Sie auf der Seite "Zieloptionen" wie folgt vor:
  1. Wählen Sie unter Ziel die Option wss aus.
  2. Geben Sie unter Zielhost die Ziel-Deployment-Konsolen-URL ein (diese finden Sie auf der Seite mit den Deployment-Details, ohne https:// oder abschließende Schrägstriche).
  3. Geben Sie unter Portnummer die Nummer 443 ein.
  4. Geben Sie unter Trailname C1 ein.
  5. Wählen Sie unter Zielauthentifizierungsmethode die Option UserID Alias aus.
  6. Geben Sie unter Domain den Domainnamen ein.
  7. Geben Sie unter Alias den Alias ein.
4. Klicken Sie auf Pfad erstellen und ausführen.
Klicken Sie in der Ziel-Deployment-Konsole auf Receiver Service, und prüfen Sie den erstellten Receiver path.

Aufgabe 7: Replicat für Change Data Capture hinzufügen

Fügen Sie die Replicat mit den folgenden Werten hinzu:
1. Auf der Seite Replicat-Informationen:
  - Wählen Sie unter Replicat Type die Option Coordinated Replicat aus.
  - Geben Sie unter Prozessname einen Namen wie RCDC ein.
2. Auf der Seite Replicat Optionen:
  - Geben Sie unter Replicat Trail den Namen des Trails aus Aufgabe 2 (C1) ein.
  - Wählen Sie unter Domain die Domain für die Autonomous AI Database-Verbindung aus.
  - Geben Sie unter Alias den Zugangsdatenalias ein.
  - Wählen Sie unter Checkpoint-Tabelle die von Ihnen erstellte Checkpoint-Tabelle aus.
3. Fügen Sie auf der Seite Replicat "Parameter" die folgende Zuordnung hinzu, und klicken Sie auf Erstellen und ausführen:
```
MAP SRC_OCIGGLL.*, TARGET SRCMIRROR_OCIGGLL.*;
```
Wählen Sie auf der Seite "Überblick" Administration Service die Replicat für Initial Load (RIL) aus, und zeigen Sie die zugehörigen Details an.
Klicken Sie auf Statistiken, und prüfen Sie die Anzahl der Einfügungen. Aktualisieren Sie die Seite.
- Wenn sich die Anzahl der Einfügungen nicht ändert, wurden alle Datensätze aus der erstmaligen Ladung geladen. Sie können das Replicat (RIL) stoppen.
- Wenn die Anzahl der Einfügevorgänge weiter zunimmt, aktualisieren Sie die Seite so lange, bis alle Datensätze der erstmaligen Ladung geladen sind, bevor Sie fortfahren.
Kehren Sie zur Seite "Überblick" des Administrationsservice zurück, und starten Sie Coordinated Replicat (RCDC).
Nachdem Sie die Coordinated Replicat gestartet haben, prüfen Sie die zugehörigen Details und Statistiken, um die Anzahl der Einfügungen anzuzeigen.

Aufgabe 8: Prüfen Sie Change Data Capture.

Führen Sie Updates an der Quelldatenbank HeatWave auf OCI aus, um die Replikation in Autonomous AI Lakehouse zu prüfen.

Erstellen Sie in OCI Bastion eine SSH-Portweiterleitungssession mit der IP von MySQL und Port 3306. Fügen Sie den öffentlichen SSH-Schlüssel hinzu.
Stellen Sie mit Ihrem Private Key und Port 3306 eine Verbindung zu MySQL in Cloud-Shell her.
Führen Sie nach dem erfolgreichen Herstellen einer Verbindung den folgenden Befehl aus:
```
mysqlsh admin@localhost:3306 --sql
```

Führen Sie das folgende Skript aus, um Einfügungen in die HeatWave on OCI-Datenbank auszuführen:

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;

Wählen Sie in der Deployment-Konsole der Quelle MySQL den Namen Change Data Capture Extract aus, und klicken Sie auf Statistiken. Stellen Sie sicher, dass unter SRC_OCIGGLL.SRC_CITY 10 Einfügungen vorhanden sind.

Hinweis:
Wenn die Extract keine Einfügungen erfasst hat, starten Sie die Extract neu.