Hinzufügen von Postgre SQL Datenbank CDC als Quelle im Echtzeithub

Dieser Artikel beschreibt die Vorgehensweise zum Hinzufügen von Postgre SQL-Datenbank Change Data Capture (CDC) als Ereignisquelle im Fabric-Echtzeithub.

Der Change Data Capture (CDC)-Quellkonnektor einer Postgre SQL-Datenbank für Microsoft Fabric-Eventstreams ermöglicht es Ihnen, eine Momentaufnahme der aktuellen Daten in einer PostgreSQL-Datenbank zu erfassen. Künftige Änderungen an diesen Daten auf Zeilenebene werden dann vom Konnektor überwacht und aufgezeichnet.

Voraussetzungen

• Zugriff auf einen Arbeitsbereich im Fabric-Kapazitätslizenzmodus (oder) im Testlizenzmodus mit Mitwirkenden oder höheren Berechtigungen.

• Zugriff als registrierter Benutzer in der PostgreSQL-Datenbank.

• CDC in der PostgreSQL-Datenbank aktiviert.

  Wenn Sie über Azure Database for PostgreSQL verfügen, gehen Sie zum Aktivieren von CDC nach den Schritten im nächsten Abschnitt vor. Ausführliche Informationen finden Sie unter Logische Replikation und logische Decodierung – Azure Database for PostgreSQL – Flexible Server.

  Informationen zu anderen PostgreSQL-Datenbanken finden Sie unter Debezium-Connector für PostgreSQL :: Debezium-Dokumentation.

Hinweis

CDC für mehrere Tabellen wird nicht unterstützt.

Aktivieren von CDC in Azure Database for PostgreSQL

Gehen Sie zum Aktivieren von CDC in Ihrem Azure Database for PostgreSQL entsprechend Ihrem Bereitstellungstyp nach den folgenden Schritten vor.

Azure Database for PostgreSQL – Einzelserver

1. Gehen Sie zur Seite Replikation im Azure-Portal.

2. Ändern Sie die Replikationsregel in Logisch.

   

Azure Database for PostgreSQL: Flexible Server

1. Wählen Sie im Azure-Portal auf der Seite für Ihren flexiblen Azure Database for PostgreSQL-Server im Navigationsmenü Serverparameter aus.

2. Auf der Seite Serverparameter:

   • Setzen Sie wal_level auf logisch.

   • Aktualisieren Sie max_worker_processes auf mindestens 16.

     

3. Speichern Sie die Änderungen, und starten Sie den Server neu.

4. Vergewissern Sie sich, dass Ihre flexible Azure Database for PostgreSQL-Serverinstanz den öffentlichen Netzwerkdatenverkehr zulässt.

5. Erteilen Sie dem Administratorbenutzer Replikationsberechtigungen durch Ausführen der folgenden SQL-Anweisung.

   SQL

   ALTER ROLE <admin user> WITH REPLICATION;
   

Abrufen von Ereignissen aus einer Azure-Datenbank für PostgreSQL CDC

Sie können Ereignisse aus einer Azure-Datenbank für PostgreSQL CDC auf eine der folgenden Arten in Echtzeit abrufen:

• Nutzen der Seite Datenquellen.
• Verwenden der Seite Microsoft-Quellen

Datenquellenseite

1. Melden Sie sich bei Microsoft Fabric an.

2. Wählen Sie auf der linken Navigationsleiste den Echtzeithub aus.

3. Wählen Sie auf der Seite Echtzeit-Hub die Option +Datenquellen unter Verbinden mit im linken Navigationsmenü aus. Sie können auch über Alle Datenströme oder Meine Datenströme -Seiten zur Seite Datenquelle gelangen, indem Sie in der oberen rechten Ecke die Schaltfläche +Datenquelle verbinden auswählen.

   

4. Wählen Sie auf der Seite Datenquellen die Kategorie Microsoft-Quellen oben aus, und wählen Sie dann Verbinden auf der Kachel Azure DB für PostgreSQL (CDC) aus.

   

   Halten Sie sich an die Anweisungen aus dem Abschnitt Hinzufügen von Postgre SQL Datenbank CDC als Quelle.

Seite Microsoft-Quellen

1. Wählen Sie im Echtzeithub Microsoft-Quellen aus.

2. Wählen Sie in der Einblendliste Quelle die Option PostgreSQL (CDC) aus.

3. Wählen Sie für Abonnement einAzure-Abonnement aus, das über die Ressourcengruppe mit Ihrem PostgreSQL-Datenbankkonto verfügt.

4. Wählen Sie unter Ressourcengruppe eine Ressourcengruppe mit der Datenbank aus.

5. Wählen Sie für Region einen Standort aus, an dem sich Ihre Datenbank befindet.

6. Bewegen Sie nun die Maus über den Namen der Postgre SQL Datenbank-CDC-Quelle, die Sie in der Liste der Datenbanken mit dem Echtzeithub verbinden möchten, und wählen Sie die Schaltfläche Verbinden aus, oder wählen Sie ... (Auslassungspunkte), und wählen Sie dann die Schaltfläche Verbinden aus.

   

   Um Verbindungsinformationen zu konfigurieren, führen Sie die Schritte aus dem Abschnitt Hinzufügen von Azure-Datenbank für PostgreSQL CDC als Quellabschnitt aus.

Hinzufügen von Azure-Datenbank für PostgreSQL CDC als Quelle

1. Wählen Sie auf der Seite Verbinden die Option Neue Verbindung aus.

   

   Wenn Sie über eine vorhandene Verbindung mit Ihrer Azure-Datenbank für PostgreSQL CDC-Quelle verfügen, können Sie sie in der Dropdownliste Verbindung auswählen und mit der Konfiguration von Port und Tabellen fortfahren.

   

2. Geben Sie im Abschnitt Verbindungseinstellungen die folgende Informationen ein.

   • Server: Die Serveradresse Ihrer PostgreSQL-Datenbank, z. B. my-pgsql-server.postgres.database.azure.com.

   • Datenbank: Der Datenbankname, z. B. my_database.

     

3. Scrollen Sie nach unten und gehen Sie im Abschnitt Anmeldedaten für die Verbindung folgendermaßen vor:

   1. Geben Sie für Verbindungsname einen Namen für die Verbindung ein.

   2. Wählen Sie für Authentifizierungsart die Option Standard aus.

      Hinweis

      Derzeit unterstützen Fabric-Eventstreams nur die Standardauthentifizierung.

   3. Geben Sie den Benutzernamen und das Kennwort für die Datenbank ein.

   4. Wählen Sie Verbinden.

      

4. Gehen Sie nun auf der Seite Verbinden folgendermaßen vor:

   1. Geben Sie für Tabelle einen Tabellennamen ein.

   2. Geben Sie für Port die Portnummer ein oder belassen Sie den Standardwert: 5432.

   3. Geben Sie für den Eventstream-Namen einen Namen für den Eventstream ein. Der Assistent erstellt einen Eventstream mit dem ausgewählten Postgre SQL Datenbank CDC als Quelle.

   4. Der Stream-Name wird automatisch generiert, indem sie -stream an den Namen des Eventstreams anhängen. Dieser Datenstrom wird auf der Seite Alle Datenströme angezeigt, wenn der Assistent abgeschlossen ist.

   5. Wählen Sie unten auf der Seite die Option Weiter aus.

      

5. Überprüfen Sie auf der Seite Überprüfen + Verbinden die Zusammenfassung, und wählen Sie dann Verbinden aus.

   

Stream-Details anzeigen

1. Wenn Sie auf der Seite Überprüfen + Verbinden den Ereignisstream öffnen, öffnet der Assistent den Ereignisstream, den er für Sie mit dem ausgewählten PostgreSQL-Datenbank-CDC als Quelle erstellt hat. Um den Assistenten zu schließen, wählen Sie unten auf der Seite Fertig stellen aus.

   

2. Wählen Sie im Echtzeithub die Option Meine Datenströme aus. Aktualisieren Sie die Seite, um den neuen Datenstrom anzuzeigen.

   

Zugehöriger Inhalt

Weitere Informationen zum Konsumieren von Streams finden Sie in den folgenden Artikeln:

• Verarbeiten von Streams
• Analysieren von Streams
• Einstellen von Warnungen für Streams