Daten aus Autonomous AI Transaction Processing in Microsoft Fabric Eventstream replizieren

Hier erfahren Sie, wie Sie Daten aus einer Autonomous AI Transaction Processing-Quelle mit OCI GoldenGate in Microsoft Fabric Eventstream replizieren.

Bevor Sie beginnen

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

Umgebung eingerichtet: Autonomous AI Transaction Processing

Wenn noch keine Quelldatenbank für die Replikation eingerichtet ist, können Sie mit den folgenden Schritten ein Beispielschema laden, das für diesen Schnellstart verwendet werden soll. Bei diesem Schnellstart wird Autonomous AI Transaction Processing für die Quelldatenbank verwendet.

So richten Sie die Autonomous AI Transaction Processing-Quelle ein:

  1. Laden Sie das Beispieldatenbankschema herunter, und dekomprimieren Sie es.
  2. Wählen Sie in der Oracle Cloud-Konsole auf der Seite Autonome KI-Datenbank die Autonomous AI Transaction Processing-(ATP-)Instanz aus, um die zugehörigen Details anzuzeigen und Database Actions aufzurufen.
  3. Entsperren Sie den GGADMIN-Benutzer:
    1. Klicken Sie auf Database Actions und dann auf Database Users.
    2. Suchen sie GGADMIN, klicken Sie dann auf das zugehörige Auslassungsmenü (drei Punkte), und wählen Sie Bearbeiten aus.
    3. Geben Sie im Bereich "Benutzer bearbeiten" das GGADMIN-Passwort ein, bestätigen Sie das Passwort, und heben Sie die Auswahl von Account ist gesperrt auf.
    4. Klicken Sie auf Änderungen anwenden.
  4. Laden Sie die Beispielschemas und -daten der Quelle:
    1. Klicken Sie im Menü "Datenbankaktionen" unter "Entwicklung" auf SQL.
    2. Kopieren Sie das Skript von OCIGGLL_OCIGGS_SETUP_USERS_ATP.sql, und fügen Sie das Skript in das SQL-Arbeitsblatt hinzu.
    3. Klicken Sie auf Skript ausführen. Auf der Registerkarte "Skriptausgabe" werden Bestätigungsmeldungen angezeigt.
    4. Löschen Sie das SQL-Arbeitsblatt, kopieren Sie das SQL-Skript aus OCIGGLL_OCIGGS_SRC_USER_SEED_DATA.sql., und fügen Sie es ein.

      Tipp:

      Möglicherweise müssen Sie jede Anweisung 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 in der Registerkarte "Navigator" nach dem Schema SRC_OCIGGLL, und wählen Sie dann Tabellen aus dem entsprechenden Dropdown-Listen.
  5. Aktivieren Sie zusätzliches Logging:
    1. Leeren Sie das SQL-Arbeitsblatt.
    2. Geben Sie die folgende Anweisung an, und klicken Sie auf Anweisung ausführen:
      ALTER PLUGGABLE DATABASE ADD SUPPLEMENTAL LOG DATA;

Aufgabe 2: Extract hinzufügen

  1. Wählen Sie auf der Seite "Deployments" das Autonomous AI Transaction Processing-Quell-Deployment aus.
  2. Klicken Sie auf der Seite "Deployment-Details" auf Konsole starten.
  3. Melden Sie sich mit dem Benutzernamen und Kennwort des Quell-Deployment-Administrators an.
  4. Fügen Sie Transaktionsinformationen hinzu.
  5. Fügen Sie eine Extract hinzu.

Aufgabe 3: Verteilungspfad hinzufügen

  1. Wenn Sie den GoldenGate-Zugangsdatenspeicher verwenden, erstellen Sie einen Benutzer für den Verteilungspfad im Big Data-Deployment des Ziels, oder fahren Sie mit Schritt 3 fort.
  2. Fügen Sie für den in Schritt 1 erstellten Benutzer in der GoldenGate-Deployment-Konsole der Quelle für die ATP-GoldenGate eine Pfadverbindung hinzu.
    1. Klicken Sie in der GoldenGate-Deployment-Konsole der ATP-Quelle in der linken Navigationsleiste auf Pfadverbindungen.
    2. Klicken Sie auf Pfadverbindung hinzufügen (Plussymbol), und führen Sie die folgenden Schritte aus:
      1. Geben Sie unter Zugangsdatenalias GGSNetwork ein.
      2. Geben Sie unter Benutzer-ID den Namen des in Schritt 1 erstellten Benutzers an.
      3. Geben Sie das Kennwort des Benutzers zur Bestätigung zweimal ein.
    3. Klicken Sie auf Weiterleiten.

      Die Pfadverbindung wird in der Liste "Pfadverbindungen" angezeigt.

  3. Fügen Sie in der ATP-Deployment-Konsole der Quelle einen Verteilungspfad mit den folgenden Werten hinzu:
    1. Auf der Seite Quelloptionen:
      • Wählen Sie unter Quell-Extract den in Aufgabe 2 erstellten Extract.
      • Geben Sie unter Trailname einen aus zwei Zeichen bestehendem Namen wie E1 ein.
    2. Auf der Seite Zieloptionen:
      • Geben Sie unter Zielhost die Hostdomain des Ziel-Deployments an.
      • Geben Sie unter Portnummer 443 ein.
      • Geben Sie unter Trailname einen aus zwei Zeichen bestehendem Namen wie E1 ein.
      • Geben Sie unter Alias den in Schritt 2 erstellten Zugangsdatenalias ein.
  4. Prüfen Sie in der Big Data-Deployment-Konsole des Ziels den Receiver Path, der als Ergebnis der Distribution Path erstellt wurde.
    1. Klicken Sie in der Big Data-Zielbereitstellungskonsole auf Receiver Service.
    2. Prüfen Sie die Pfaddetails. Dieser Pfad wurde als Ergebnis des im vorherigen Schritt erstellten Distribution Path erstellt.

Aufgabe 4: Replicat hinzufügen und ausführen

  1. Klicken Sie in der Big Data-Zielbereitstellungskonsole auf Replicats und dann auf Add Replicat (Plussymbol).
  2. Fügen Sie ein Replicat hinzu mit den folgenden Werten:
    1. Wählen Sie auf der Seite Replicat Information unter Typ Replicat die Option Classic Replicat aus, geben Sie einen Prozessnamen ein, und klicken Sie auf Weiter.
    2. Führen Sie auf der Seite "Replikationsoptionen" folgende Schritte aus:
      • Geben Sie unter Name den Namen des Trails aus Aufgabe 2 ein.
      • Wählen Sie unter Ziel die Option Microsoft Fabric Eventstream aus.
      • Wählen Sie unter Format das Format aus, das Sie in Microsoft Fabric Eventstream aufnehmen möchten. Der Standardwert ist JSON.
      • Wählen Sie unter Verfügbarer Alias in der Dropdown-Liste die Verbindung Microsoft Fabric Eventstream aus.
    3. Übernehmen Sie auf der Seite "Verwaltete Optionen" die Standardeinstellungen.
    4. Behalten Sie auf der Seite "Parameter" Replicat die Standardeinstellungen bei.
    5. Aktualisieren Sie auf der Seite "Eigenschaften" Replicat die Felder, die als #TODO markiert sind.
  3. Klicken Sie auf Erstellen und ausführen.
Sie kehren zur Seite "Replicats" zurück, auf der Sie die Replicat-Details prüfen können.

Aufgabe 5: Replikation prüfen

Nehmen Sie einige Änderungen an der Autonomous Transaction Processing-Quellinstanz vor, um zu prüfen, ob diese in Microsoft Fabric Lakehouse repliziert werden.
  1. Öffnen Sie in der Oracle Cloud-Konsole das Navigationsmenü, und wählen Sie Oracle AI Database aus. Wählen Sie dann Autonome KI-Transaktionsverarbeitung aus.
  2. Wählen Sie in der Liste der Autonomous AI Transaction Processing-Instanzen Ihre Quellinstanz aus, um deren Details anzuzeigen.
  3. Klicken Sie in der Seite "Datenbankdetails" auf Datenbankaktionen.

    Hinweis:

    Die Anmeldung sollte automatisch erfolgen. Andernfalls melden Sie sich mit den Datenbankzugangsdaten an.
  4. Wählen Sie SQL auf der Homepage von Database Actions aus.
  5. Geben Sie Folgendes in das Arbeitsblatt ein und klicken Sie auf Skript ausführen.
    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);
  6. Wählen Sie in der Quell-ATP-Deployment-Konsole den Namen Extract aus, und klicken Sie auf Statistiken. Stellen Sie sicher, dass SRC_OCIGGLL.SRC_CITY 10 Insert-Vorgänge vorhanden ist.
  7. Wählen Sie in der OCI GoldenGate-Deployment-Konsole für Big Data OCI den Namen Replicat aus, und klicken Sie auf Statistiken. Stellen Sie sicher, dass SRC_OCIGGLL.SRC_CITY 10 Insert-Vorgänge vorhanden ist.