Gespiegelte Datenbankquelle (Änderungsfeed) zu einem Ereignisstream hinzufügen

In diesem Artikel erfahren Sie, wie Sie einem Ereignisstream eine Quelle für eine gespiegelte Datenbank (Change Feed) hinzufügen.

Der Quellconnector „Mirrored Database“ (Änderungsfeed) für Microsoft Fabric-Ereignisstreams ermöglicht es Ihnen, Echtzeit-Änderungsereignisse aus einer Fabric Mirrored Database zu erfassen. Gespiegelte Datenbanken in Fabric stellen eine nahezu in Echtzeit verfügbare, schreibgeschützte Replik Ihrer externen Datenbankdaten bereit. Mit diesem Connector können Sie Einfügungen, Aktualisierungen und Löschvorgänge erfassen, sobald sie in der gespiegelten Datenbank geschehen, und sie in einen Ereignisstream für die Echtzeitverarbeitung, Analyse und Weiterleitung an verschiedene Fabric Ziele streamen.

Dieser Konnektor unterstützt alle gespiegelten Datenbanktypen, die in Fabric Mirroring verfügbar sind, einschließlich:

  • Azure SQL-Datenbank
  • Azure Cosmos DB (ein Microsoft-Datenbankdienst)
  • Snowflake
  • Offene Spiegelung

Note

Dieser Connector befindet sich derzeit in der Vorschau. Der Konnektor erfasst Rohereignisse des Änderungsfeeds aus der gespiegelten Datenbank. DeltaFlow (analysebereite Ereignistransformation) wird derzeit nicht mit diesem Connector unterstützt.

Voraussetzungen

  • Zugriff auf einen Arbeitsbereich im Fabric-Kapazitäts-Lizenzmodus oder im Testlizenzmodus, wenn Mitwirkende- oder höhere Berechtigungen vorliegen.
  • Eine vorhandene gespiegelte Datenbank in Ihrem Fabric Arbeitsbereich, die Daten aktiv aus der Quelldatenbank synchronisiert.
  • Die gespiegelte Datenbank muss den Change Feed aktiviert haben.
  • Wenn Sie keinen Eventstream haben, erstellen Sie einen Eventstream.

Starten des Assistenten zum Verbinden von Datenquellen

Wenn Sie Ihrem Eventstream noch keine Quelle hinzugefügt haben, wählen Sie die Kachel "Datenquellen verbinden" aus . Sie können auch "Quelle hinzufügen"> und "Datenquellen verbinden" auf dem "Ribbon" auswählen.

Screenshot, der die Auswahl der Kachel für die Verwendung einer externen Quelle zeigt.

Wenn Sie die Quelle zu einem bereits veröffentlichten Ereignisstream hinzufügen, wechseln Sie zum Bearbeitungsmodus . Wählen Sie im Menüband "Quelle hinzufügen; Datenquellen verbinden" aus.

Screenshot der Auswahl zum Hinzufügen externer Quellen.

Suchen Sie auf der Seite " Datenquelle auswählen " nach "Gespiegelte Datenbank " und wählen Sie "Verbinden " auf der Kachel " Gespiegelte Datenbank" (Feed ändern) aus.

Screenshot, der die Auswahl von „Gespiegelte Datenbank (Änderungsfeed)“ als Quelltyp im Assistenten „Ereignisse abrufen“ zeigt.

Konfigurieren und Herstellen einer Verbindung mit dem Change Feed für gespiegelte Datenbanken

Erfassen von Changefeed-Ereignissen in einen Eventstream aus einer gespiegelten Fabric-Datenbank Ihrer Wahl

  1. Wählen Sie auf der Seite "Verbinden " eine gespiegelte Datenbank aus, mit der eine Verbindung hergestellt werden soll.

    1. Für Arbeitsbereich navigieren Sie zu dem Fabric-Arbeitsbereich, der die gespiegelte Datenbank enthält, und wählen Sie ihn aus.

    2. Wählen Sie für die gespiegelte Datenbank die gespiegelte Datenbank aus der Liste der verfügbaren Datenbanken im ausgewählten Arbeitsbereich aus.

      Screenshot, der den Arbeitsbereich und das Auswahlfeld für gespiegelte Datenbanken auf der Seite „Verbinden“ zeigt.

  2. Wählen Sie alle Tabellen aus, oder geben Sie Tabellennamen ein, um anzugeben, welche Tabellen auf Änderungen überwacht werden sollen. Wenn Sie letzteres auswählen, geben Sie Tabellen mithilfe einer durch Trennzeichen getrennten Liste mit vollständigen Tabellenbezeichnern (schemaName.tableName) oder gültigen regulären Ausdrücken an. Beispiel:

    • Verwenden Sie dbo.Orders.*, um alle Tabellen auszuwählen, deren Namen mit dbo.Orders beginnen.
    • Verwenden Sie dbo\.(Orders|Customers), um dbo.Orders und dbo.Customers auszuwählen.

    Sie können beide Formate mithilfe von Kommas mischen. Die Gesamtzeichenbeschränkung für den gesamten Eintrag beträgt 102.400 Zeichen.

    Note

    In der aktuellen Vorschauversion ist nur die Option "Alle Tabellen " verfügbar.

  3. Überprüfen Sie auf der Seite "Überprüfen + Verbinden " die Zusammenfassung der Einstellungen, und wählen Sie dann "Hinzufügen" aus.

    Screenshot der Seite

  4. Sie können die Quelle „Gespiegelte Datenbank (Change Feed)“ sehen, die Ihrem Eventstream hinzugefügt wurde, während Sie sich noch im Bearbeitungsmodus befinden.

Aktualisierten Ereignisstream anzeigen

  1. Um diese neu hinzugefügte Quelle für gespiegelte Datenbank (Feed ändern) zu implementieren, wählen Sie "Veröffentlichen" aus. Nachdem Sie diese Schritte abgeschlossen haben, steht Ihre Quelle „Gespiegelte Datenbank (Change Feed)“ zur Visualisierung in der Liveansicht zur Verfügung.

    Screenshot des Streamings der Feedquelle für gespiegelte Datenbankänderungen in der Liveansicht.

Konfigurieren von Eventstream-Zielen für die Verwendung von Schemas

Derzeit werden nur die Eventhouse-, benutzerdefinierten endpunkt- und abgeleiteten Datenstromziele für Eventstreams mit zugeordneten Schemas unterstützt. In diesem Abschnitt wird gezeigt, wie Sie ein Eventhouse-Ziel hinzufügen und konfigurieren, wenn erweiterte Features (z. B. die Schemaunterstützung) für den Eventstream aktiviert sind.

Note

Wenn Sie DeltaFlow (Vorschau) mit einer unterstützten CDC-Quelle (Change Data Capture) verwenden, werden Zieltabellen im Eventhouse automatisch erstellt und verwaltet, um der Quelltabellenstruktur zu entsprechen. Sie müssen das Zieltabellenschema nicht manuell konfigurieren. DeltaFlow behandelt auch die Schemaentwicklung automatisch, wenn sich Quelltabellen ändern.

Konfigurieren eines Schemas für ein benutzerdefiniertes Endpunktziel

  1. Wählen Sie Transformationsereignisse aus, oder fügen Sie das Ziel hinzu, und wählen Sie dann "CustomEndpoint" aus.

  2. Geben Sie im Bereich "Benutzerdefinierter Endpunkt " einen Namen für das Ziel an.

  3. Wählen Sie für das Eingabeschema das Schema für Ereignisse aus. Sie treffen eine Auswahl in diesem Feld, wenn Sie die Schemaunterstützung für einen Eventstream aktivieren.

Screenshot des Bereichs zum Konfigurieren eines benutzerdefinierten Endpunkts.

Ausführliche Schritte zum Konfigurieren eines benutzerdefinierten Endpunktziels finden Sie unter Hinzufügen eines benutzerdefinierten Endpunkts oder benutzerdefinierten App-Ziels zu einem Eventstream.

Schemas für ein Eventhouse-Ziel konfigurieren

  1. Wählen Sie Transformationsereignisse aus, oder fügen Sie das Ziel hinzu, und wählen Sie dann Eventhouse aus.

  2. Konfigurieren Sie im Eventhouse-Bereich die folgenden schemabezogenen Einstellungen:

    1. Wählen Sie für das Eingabeschema ein oder mehrere Schemas aus der Dropdownliste aus.

      Screenshot des Ereignishauskonfigurationsbereichs mit ausgewähltem Eingabeschema.

      Note

      Wenn Sie das dynamische Schema über die Headeroption beim Konfigurieren einer Event Hubs-Quelle ausgewählt haben, haben Sie möglicherweise mehrere Schemas für die Quelle konfiguriert und sie verschiedenen Eigenschaften und deren Werten zugeordnet.

    2. Wählen Sie für die Tabellenerstellungsmethode entweder eine einzelne Tabelle, in der alle Schemata kombiniert werden, oder separate Tabellen für jedes einzelne Schema aus, je nach Ihren Anforderungen.

      Screenshot des Ereignishaus-Konfigurationsbereichs mit Tabellenerstellungsmethoden.

    3. Wählen Sie für Write data with eine der folgenden Optionen aus:

      • Nur Nutzlast: Schreiben extrahierter Nutzlastdaten in die Tabelle. Wenn mehrere Eingabeschemas vorhanden sind, werden Daten an mehrere Tabellen gesendet.
      • Metadaten und Nutzlast: Schreiben von Metadaten und Nutzlastdaten in eine einzelne Tabelle. Beispielspalten umfassen source , , subject, typeund data.

      Screenshot des Ereignishauskonfigurationsbereichs mit den Optionen zum Schreiben von Daten.

Ausführliche Schritte zum Konfigurieren eines Eventhouse-Ziels finden Sie unter Hinzufügen eines Eventhouse-Ziels zu einem Eventstream.

Verwandte Inhalte

Andere Konnektoren:

  • Last updated on