Freigeben über


Lernprogramm: Abfragen einer gespiegelten Datenbank aus Cosmos DB in Microsoft Fabric

In diesem Lernprogramm führen Sie eine Abfrage an einer gespiegelten Fabric-Datenbank von einer bestehenden Cosmos DB innerhalb einer Fabric-Datenbank aus. Sie erfahren, wie Sie die Spiegelung in Ihrer Datenbank aktivieren, den Spiegelungsstatus überprüfen und dann sowohl die Quell- als auch die gespiegelten Daten für Analysen verwenden.

Voraussetzungen

Konfigurieren Sie Ihre Cosmos DB in der Fabric-Datenbank

Stellen Sie zunächst sicher, dass Ihre Cosmos DB in Fabric-Datenbank ordnungsgemäß konfiguriert ist und Daten für die Spiegelung enthält.

  1. Öffnen Sie das Fabric-Portal (https://app.fabric.microsoft.com).

  2. Navigieren Sie zu Ihrer vorhandenen Cosmos DB-Datenbank.

    Von Bedeutung

    Für dieses Lernprogramm sollte die vorhandene Cosmos DB-Datenbank den Beispieldatensatz bereits geladen haben. Bei den verbleibenden Schritten in diesem Lernprogramm wird davon ausgegangen, dass Sie denselben Datensatz für diese Datenbank verwenden.

  3. Stellen Sie sicher, dass Ihre Datenbank mindestens einen Container mit Daten enthält. Führen Sie diese Überprüfung aus, indem Sie den Container im Navigationsbereich erweitern und beobachten, ob Elemente vorhanden sind.

  4. Wählen Sie in der Menüleiste "Einstellungen" aus, um auf die Datenbankkonfiguration zuzugreifen.

  5. Navigieren Sie im Dialogfeld "Einstellungen " zum Abschnitt " Spiegelung ", um zu überprüfen, ob die Spiegelung für diese Datenbank aktiviert ist.

    Hinweis

    Die Spiegelung wird automatisch für alle Cosmos DB-Datenbanken in Fabric aktiviert. Dieses Feature erfordert keine zusätzliche Konfiguration und stellt sicher, dass Ihre Daten immer in OneLake analysebereit sind.

Herstellen einer Verbindung mit der Quelldatenbank

Vergewissern Sie sich als Nächstes, dass Sie eine Direkte Verbindung mit der Cosmos DB-Quelldatenbank herstellen und abfragen können.

  1. Navigieren Sie zurück zu Ihrer vorhandenen Cosmos DB-Datenbank im Fabric-Portal.

  2. Wählen Sie ihren vorhandenen Container aus, und erweitern Sie diesen, um dessen Inhalt anzuzeigen.

  3. Wählen Sie "Elemente" aus, um die Daten direkt in der Datenbank zu durchsuchen.

  4. Stellen Sie sicher, dass die Elemente in Ihrem Container angezeigt werden können. Wenn Sie z. B. das Beispieldatenset verwenden, sollten Sie Elemente mit Eigenschaften wie name, categoryund countryOfOrigin.

  5. Wählen Sie im Menü "Neue Abfrage" aus, um den NoSQL-Abfrage-Editor zu öffnen.

  6. Führen Sie eine Testabfrage aus, um die Konnektivität und Datenverfügbarkeit zu überprüfen:

    SELECT COUNT(1) AS itemCount FROM container
    

    Diese Abfrage sollte die Gesamtanzahl der Elemente in Ihrem Container zurückgeben.

Verbindung zur gespiegelten Datenbank herstellen

Greifen Sie nun über den SQL-Analyseendpunkt auf die gespiegelte Version Ihrer Datenbank zu, um dieselben Daten mit T-SQL abzufragen.

  1. Wählen Sie in der Menüleiste die Cosmos DB-Liste und dann den SQL-Analyseendpunkt aus, um zur gespiegelten Datenbankansicht zu wechseln.

  2. Überprüfen Sie, ob Ihr Container als Tabelle im SQL-Analyseendpunkt angezeigt wird. Die Tabelle sollte denselben Namen wie Ihr Container haben.

  3. Wählen Sie im Menü neue SQL-Abfrage aus, um den T-SQL-Abfrage-Editor zu öffnen.

  4. Führen Sie eine Testabfrage aus, um zu überprüfen, ob die Spiegelung ordnungsgemäß funktioniert:

    SELECT COUNT(*) AS itemCount FROM [dbo].[SampleData]
    

    Hinweis

    Ersetzen Sie [SampleData] durch den Namen Ihres Containers, wenn Sie den Beispieldatensatz nicht verwenden.

  5. Die Abfrage sollte die gleiche Anzahl wie Ihre NoSQL-Abfrage zurückgeben und bestätigen, dass die Spiegelung ihre Daten erfolgreich repliziert.

Abfragen der Quelldatenbank aus Fabric

Verwenden Sie das Fabric-Portal, um die Daten zu untersuchen, die bereits in Ihrem Azure Cosmos DB-Konto vorhanden sind, und fragen Sie Ihre Cosmos DB-Quelldatenbank ab.

  1. Navigieren Sie im Fabric-Portal zur gespiegelten Datenbank.

  2. Wählen Sie "Ansicht" und dann " Quelldatenbank" aus. Diese Aktion öffnet den Azure Cosmos DB-Daten-Explorer mit einer schreibgeschützten Ansicht der Quelldatenbank.

    Screenshot des Daten-Explorers mit einer schreibgeschützten Ansicht von NoSQL-Daten im Azure Cosmos DB-Konto.

  3. Wählen Sie einen Container aus, öffnen Sie dann das Kontextmenü, und wählen Sie "Neue SQL-Abfrage" aus.

  4. Führen Sie eine beliebige Abfrage aus. Verwenden Sie SELECT COUNT(1) FROM container z. B. zum Zählen der Anzahl der Elemente im Container.

    Hinweis

    Alle Lesevorgänge in der Quelldatenbank werden an Azure weitergeleitet und nutzen Anforderungseinheiten (Request Units, RUs), die dem Konto zugeordnet sind.

Analysieren der gespiegelten Zieldatenbank

Verwenden Sie nun T-SQL, um Ihre NoSQL-Daten abzufragen, die jetzt in Fabric OneLake gespeichert sind.

  1. Navigieren Sie im Fabric-Portal zur gespiegelten Datenbank.

  2. Wechseln Sie von Gespiegelter Azure Cosmos DB zu SQL-Analyseendpunkt.

    Screenshot des Selektors, um zwischen Elementen im Fabric-Portal zu wechseln.

  3. Jeder Container in der Quelldatenbank sollte im SQL-Analyseendpunkt als Lagertabelle dargestellt werden.

  4. Wählen Sie eine beliebige Tabelle aus, öffnen Sie das Kontextmenü, wählen Sie dann "Neue SQL-Abfrage" und schließlich " Top 100" aus.

  5. Die Abfrage wird ausgeführt und gibt 100 Datensätze in der ausgewählten Tabelle zurück.

  6. Öffnen Sie das Kontextmenü für dieselbe Tabelle, und wählen Sie "Neue SQL-Abfrage" aus. Schreiben Sie eine Beispielabfrage, die Aggregate wie SUM, COUNT, MIN oder MAX verwendet. Verknüpfen Sie mehrere Tabellen im Lager, um die Abfrage über mehrere Container hinweg auszuführen.

    Hinweis

    Diese Abfrage würde z. B. über mehrere Container hinweg ausgeführt:

    SELECT
        d.[product_category_name],
        t.[order_status],
        c.[customer_country],
        s.[seller_state],
        p.[payment_type],
        sum(o.[price]) as price,
        sum(o.[freight_value]) freight_value 
    FROM
        [dbo].[products] p 
    INNER JOIN
        [dbo].[OrdersDB_order_payments] p 
            on o.[order_id] = p.[order_id] 
    INNER JOIN
        [dbo].[OrdersDB_order_status] t 
            ON o.[order_id] = t.[order_id] 
    INNER JOIN
        [dbo].[OrdersDB_customers] c 
            on t.[customer_id] = c.[customer_id] 
    INNER JOIN
        [dbo].[OrdersDB_productdirectory] d 
            ON o.product_id = d.product_id 
    INNER JOIN
        [dbo].[OrdersDB_sellers] s 
            on o.seller_id = s.seller_id 
    GROUP BY
        d.[product_category_name],
        t.[order_status],
        c.[customer_country],
        s.[seller_state],
        p.[payment_type]
    

    In diesem Beispiel wird der Name Ihrer Tabelle und Ihrer Spalten vorausgesetzt. Verwenden Sie beim Schreiben ihrer SQL-Abfrage Ihre eigene Tabelle und Spalten.

  7. Wählen Sie die Abfrage und dann " Speichern unter" aus. Geben Sie der Ansicht einen eindeutigen Namen. Sie können jederzeit über das Fabric-Portal auf diese Ansicht zugreifen.

  8. Kehren Sie zurück zur gespiegelten Datenbank im Fabric-Portal zurück.

  9. Wählen Sie "Neue visuelle Abfrage" aus. Verwenden Sie den Abfrage-Editor, um komplexe Abfragen zu erstellen.

    Screenshot des Abfrage-Editors für textbasierte und visuelle Abfragen in Fabric.

Erstellen von BI-Berichten für die SQL-Abfragen oder -Ansichten

  1. Wählen Sie die Abfrage oder Ansicht aus, und wählen Sie dann "Diese Daten durchsuchen" (Vorschau) aus. Diese Aktion untersucht die Abfrage in Power BI direkt mithilfe von Direct Lake auf OneLake gespiegelten Daten.
  2. Bearbeiten Sie die Diagramme nach Bedarf, und speichern Sie den Bericht.

Tipp

Sie können auch optional Copilot oder andere Verbesserungen verwenden, um Dashboards und Berichte ohne weitere Datenverschiebung zu erstellen.