Hinzufügen von Azure Cosmos DB CDC als Quelle im Echtzeithub (Vorschau)

Dieser Artikel beschreibt, wie Sie Azure Cosmos DB for NoSQL Change Data Capture (CDC) als Ereignisquelle im Fabric-Echtzeithub hinzufügen.

Mit dem Azure Cosmos DB Change Data Capture (CDC)-Quellen-Konnektor können Sie eine Momentaufnahme der aktuellen Daten in einer Azure Cosmos DB-Datenbank erfassen. Künftige Änderungen an diesen Daten auf Zeilenebene werden dann vom Konnektor überwacht und aufgezeichnet. Sobald die Änderungen in einem Stream erfasst sind, können Sie diese CDC-Daten in Echtzeit verarbeiten und an verschiedene Ziele innerhalb von Fabric zur weiteren Verarbeitung oder Analyse senden.

Voraussetzungen

• Zugriff auf einen Fabric-Premium-Arbeitsbereich mit Berechtigungen als Mitwirkender oder höher.
• Zugriff auf ein Azure Cosmos DB for NoSQL-Konto und eine Datenbank.
• Ihre Azure Cosmos DB for NoSQL-Datenbank muss öffentlich zugänglich sein und darf sich nicht hinter einer Firewall oder in einem Virtual Network befinden.

Abrufen von Details zur Verbindung aus dem Azure-Portal

Die Bezeichnungen für die Artikel, die Sie aus dem Azure-Portal sammeln müssen, werden in den folgenden Schritten gezeigt. Sie benötigen immer den Endpunkt-URI in einem Format wie https://<account>.<api>.azure.com:<port>/dem Primärschlüssel und den Datenbanknamen und Artikel-IDs, für die Sie Daten sammeln möchten.

1. Wählen Sie auf der Seite des Azure-Portals für Ihr Azure Cosmos DB-Konto im linken Navigationsbereich die Option Schlüssel unter Einstellungen aus.

2. Kopieren Sie auf der Seite Schlüssel die URI- und Primärschlüssel-Werte, die zum Einrichten der Eventstream-Verbindung verwendet werden sollen.

   

3. Notieren Sie sich auf der Azure-Portal-Übersicht für Ihr Azure Cosmos DB-Konto die Datenbank und Artikel-ID, für die Sie Daten sammeln möchten.

   

Abrufen von Ereignissen aus einem Azure Cosmos DB CDC

Sie können Ereignisse von einer Azure Cosmos DB CDC auf eine der folgenden Arten in den Echtzeithub erhalten:

• Verwenden der Benutzeroberfläche " Quelle hinzufügen"
• Verwenden der Seite " Microsoft-Quellen "

Starten der Oberfläche "Quelle hinzufügen"

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 Echtzeit-Hubseite in der oberen rechten Ecke der Seite +Quelle hinzufügen aus.

   

Halten Sie sich an die Anweisungen aus dem Abschnitt Hinzufügen von Azure Cosmos DB CDC als Quelle.

Seite "Microsoft-Quellen"

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

2. Wählen Sie in der Einblendliste Quelle Azure Cosmos DB (CDC) aus.

3. Wählen Sie für Abonnement ein Azure-Abonnement aus, das über die Ressourcengruppe mit Ihrem Cosmos DB-Konto verfügt.

4. Wählen Sie unter Ressourcengruppe eine Ressourcengruppe für Ihr Cosmos DB-Konto aus.

5. Wählen Sie für Region einen Standort aus, an dem sich Ihr Cosmos DB befindet.

6. Bewegen Sie nun die Maus über den Namen der Cosmos DB-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 Add Azure Cosmos DB CDC als Quelle aus. Überspringen Sie den ersten Schritt der Auswahl von Azure Cosmos DB CDC als Quelltyp im Assistenten zum Hinzufügen von Quellen.

Azure Cosmos DB (CDC) als eine Quelle hinzufügen

1. Auf der Anzeige Datenquelle auswählen, wählen Sie Azure Cosmos DB (CDC) aus.

   

2. Wählen Sie den Link Zur Ressource gehen, wenn Sie zum Azure Cosmos DB-Konto im Azure-Portal navigieren möchten.

   

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

   

4. Geben Sie im Abschnitt Verbindungseinstellungen den Cosmos DB-Endpunkt an. Geben Sie den URI oder Endpunkt für Ihr Cosmos DB-Konto ein, das Sie aus dem Azure-Portal kopiert haben.

   

5. Erweitern Sie erweiterte Optionen und führen Sie die folgenden Schritte aus:

   1. Geben Sie für die Anzahl der Wiederholungen die maximale Anzahl an Wiederholungen an, mit denen der Konnektor eine Anforderung an die Cosmos DB-Datenbank erneut übermitteln soll, wenn die Anforderung von einem behebbareren Fehler ausfällt.

   2. Geben Sie für AVERAGE-Funktion nach unten durchreichen aktivieren an, ob der Konnektor die AVG-Aggregatfunktion an die Cosmos DB-Datenbank weitergeben soll.

   3. Geben Sie für SORT-Pass Down für mehrere Spalten aktivieren an, ob der Konnektor erlauben soll, dass mehrere Spalten an die Cosmos DB-Datenbank weitergegeben werden, wenn sie in der ORDER BY-Klausel der SQL-Abfrage angegeben sind.

      

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

   1. Wählen Sie eine bestehende Verbindung aus und behalten Sie die Standardoption Neue Verbindung erstellen bei.
   2. Um eine Verbindung zu erstellen, geben Sie die folgenden Werte ein:

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

      2. Wählen Sie unter Art der Authentifizierung die Option Kontoschlüssel.

      3. Geben Sie für den Kontoschlüssel den zuvor gespeicherten Schlüsselwert ein.

      4. Wählen Sie Verbinden.

         

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

   1. Geben Sie die Container-ID des Containers in Ihrem Azure Cosmos DB-Konto an.

   2. Wählen Sie im Abschnitt Stream-Details rechts den Fabric-Arbeitsbereich aus, in dem Sie den Eventstream speichern möchten, den der Assistent erstellt.

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

   4. Der Stream-Name wird automatisch generiert, indem sie -stream an den Namen des Eventstreams anhängen. Sie können diesen Datenstrom auf der Seite "Alle Datenströme" im Echtzeithub sehen, wenn der Assistent abgeschlossen ist.

   5. Wählen Sie Weiter aus.

      

8. Überprüfen Sie auf der Anzeige Überprüfen und erstellen die Zusammenfassung und wählen Sie dann Quelle erstellen aus.

   

Stream-Details anzeigen

1. Wenn Sie "Eventstream öffnen" auswählen, öffnet der Assistent auf der Seite "Überprüfen und Erstellen" den Ereignisstream, den er für Sie mit dem ausgewählten Azure Cosmos DB CDC als Quelle erstellt hat. Um den Assistenten zu schließen, wählen Sie in der oberen rechten Ecke der Seite Schließen oder X* aus.

   

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

   

   Ausführliche Schritte finden Sie unter Anzeigen von Details zu Streams im Fabric-Echtzeithub.

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