Samouczek: konfigurowanie dublowanej bazy danych usługi Microsoft Fabric dla usługi Azure Cosmos DB

W tym samouczku skonfigurujesz bazę danych dublowaną w Fabric na podstawie istniejącego konta usługi Azure Cosmos DB for NoSQL.

Mirroring przyrostowo replikuje dane usługi Azure Cosmos DB do usługi Fabric OneLake niemal w czasie rzeczywistym, bez wpływu na wydajność obciążeń transakcyjnych ani zużywania jednostek żądań (RU). Raporty usługi Power BI można tworzyć bezpośrednio na danych w usłudze OneLake przy użyciu trybu DirectLake. Zapytania ad hoc można uruchamiać w języku SQL lub Spark, tworzyć modele danych przy użyciu notesów i używać wbudowanych funkcji Copilot i zaawansowanych funkcji sztucznej inteligencji w usłudze Fabric do analizowania danych.

Wymagania wstępne

Wskazówka

Zaleca się użycie kopii testowej lub programistycznej istniejących danych usługi Azure Cosmos DB, które można szybko odzyskać z kopii zapasowej.

Skonfiguruj konto usługi Azure Cosmos DB

Najpierw upewnij się, że źródłowe konto usługi Azure Cosmos DB jest poprawnie skonfigurowane do użycia z dublowaniem w usłudze Fabric.

  1. Przejdź do konta usługi Azure Cosmos DB w witrynie Azure Portal.

  2. Upewnij się, że włączono ciągłą kopię zapasową. Jeśli nie jest włączona, postępuj zgodnie z przewodnikiem migrowanie istniejącego konta usługi Azure Cosmos DB do ciągłej kopii zapasowej, aby włączyć ciągłą kopię zapasową. Ta funkcja może nie być dostępna w niektórych scenariuszach. Aby uzyskać więcej informacji, zobacz ograniczenia bazy danych i konta.

  3. Jeśli twoje konto usługi Azure Cosmos DB używa sieci wirtualnych lub prywatnych punktów końcowych, musisz skonfigurować Network ACL Bypass, aby umożliwić Fabric workspace dostęp do konta. Więcej informacji można znaleźć w artykule Konfigurowanie dublowania dla kont usługi Azure Cosmos DB z ograniczeniami sieciowymi. Jeśli twoje konto jest skonfigurowane pod kątem dostępu do sieci publicznej dla wszystkich sieci, możesz przejść do następnej sekcji.

Utwórz lustrzaną bazę danych

Teraz utwórz bazę lustrzaną, która jest obiektem docelowym replikowanych danych. Aby uzyskać więcej informacji, zobacz Czego można oczekiwać od kopiowania lustrzanego.

  1. Przejdź do strony głównej Fabric portal.

  2. Otwórz istniejący obszar roboczy lub utwórz nowy obszar roboczy.

  3. W menu nawigacji wybierz pozycję Utwórz.

  4. Wybierz pozycję Utwórz, znajdź sekcję Magazyn danych , a następnie wybierz pozycję Dublowane w usłudze Azure Cosmos DB.

  5. Podaj nazwę lustrzanej bazy danych, a następnie wybierz pozycję Utwórz.

Połącz z bazą źródłową

Następnie połącz źródłową bazę danych z lustrzaną bazą danych.

  1. W sekcji Nowe połączenie wybierz pozycję Azure Cosmos DB for NoSQL.

  2. Podaj poświadczenia dla konta usługi Azure Cosmos DB for NoSQL, w tym następujące elementy:

    Poświadczenia konta Wartość
    Punkt końcowy usługi Azure Cosmos DB Punkt końcowy adresu URL dla konta źródłowego.
    Nazwa połączenia Unikatowa nazwa połączenia.
    Rodzaj uwierzytelniania Wybierz pozycję Klucz dostępu do konta lub Konto organizacyjne.
    Klucz konta Klucz odczytu i zapisu dla konta źródłowego.
    Konto organizacyjne Token dostępu z Microsoft Entra ID.

    Zrzut ekranu przedstawiający okno dialogowe nowego połączenia z poświadczeniami dla konta usługi Azure Cosmos DB for NoSQL.

    Uwaga / Notatka

    W przypadku uwierzytelniania Microsoft Entra ID wymagane są następujące uprawnienia RBAC:

    • Microsoft.DocumentDB/databaseAccounts/readMetadata
    • Microsoft.DocumentDB/databaseAccounts/readAnalytics

    Aby uzyskać więcej informacji, zobacz dokumentację kontroli dostępu opartej na rolach płaszczyzny danych.

    Przykładowy skrypt do automatycznego stosowania niestandardowej roli kontroli dostępu opartej na rolach można znaleźć rbac-cosmos-mirror.sh w temacie azure-samples/azure-cli-samples.

  3. Wybierz i podłącz. Następnie wybierz bazę danych do replikacji. Opcjonalnie wybierz określone kontenery do replikacji.

Rozpoczynanie procesu mirrorowania

  1. Wybierz pozycję Dublowanie bazy danych. Rozpoczyna się tworzenie kopii lustrzanej.

  2. Poczekaj od dwóch do pięciu minut. Następnie wybierz pozycję Monitoruj replikację , aby wyświetlić stan akcji replikacji.

  3. Po kilku minutach stan powinien ulec zmianie na Uruchomiony, co oznacza, że kontenery są synchronizowane.

    Wskazówka

    Jeśli nie możesz znaleźć kontenerów i odpowiedniego stanu replikacji, zaczekaj kilka sekund, a następnie odśwież okienko. W rzadkich przypadkach mogą pojawić się komunikaty o błędach przejściowych. Można je bezpiecznie zignorować i kontynuować odświeżanie.

  4. Po zakończeniu początkowego kopiowania kontenerów przez replikację lustrzaną data zostanie wyświetlona w kolumnie ostatnie odświeżenie. Jeśli dane zostały pomyślnie zreplikowane, kolumna łączna liczba wierszy będzie zawierać liczbę replikowanych elementów.

Monitorowanie replikacji tkaniny

Teraz, gdy Twoje dane są gotowe do działania, dostępne są różne scenariusze analityczne we wszystkich usługach Fabric.

  1. Po skonfigurowaniu funkcji Fabric Mirroring nastąpi automatyczne przejście do okienka Stan replikacji.

  2. W tym miejscu monitoruj bieżący stan replikacji. Aby uzyskać więcej informacji i szczegóły na temat stanów replikacji, zobacz Monitorowanie replikacji dublowanej bazy danych w Fabric.

Wykonywanie zapytań względem źródłowej bazy danych z Fabric

Użyj portalu Fabric, aby eksplorować dane, które już istnieją na koncie usługi Azure Cosmos DB, odpytując źródłową bazę danych Cosmos DB.

  1. Przejdź do bazy danych w kopii lustrzanej w portalu Fabric.

  2. Wybierz pozycję Widok, a następnie źródłową bazę danych. Ta akcja powoduje otwarcie eksploratora danych usługi Azure Cosmos DB z widokiem tylko do odczytu źródłowej bazy danych.

    Zrzut ekranu przedstawiający eksploratora danych z widokiem tylko do odczytu danych NoSQL na koncie usługi Azure Cosmos DB.

  3. Wybierz kontener, a następnie otwórz menu kontekstowe i wybierz pozycję Nowe zapytanie SQL.

  4. Uruchom dowolne zapytanie. Na przykład użyj polecenia SELECT COUNT(1) FROM container , aby zliczyć liczbę elementów w kontenerze.

    Uwaga / Notatka

    Wszystkie operacje odczytu w źródłowej bazie danych są kierowane do Azure i konsumują jednostki żądań (RUs) przydzielone na koncie.

Analizowanie docelowej lustrzanej bazy danych

Teraz użyj języka T-SQL, aby wykonywać zapytania względem danych NoSQL, które są teraz przechowywane w usłudze Fabric OneLake.

  1. Przejdź do bazy danych dublowanej w portalu Fabric.

  2. Przełącz się z Mirrored Azure Cosmos DB do punktu końcowego analizy SQL.

    Zrzut ekranu przedstawiający selektor do przełączania między elementami w portalu Fabric.

  3. Każdy kontener w źródłowej bazie danych powinien być reprezentowany w punkcie końcowym analizy SQL jako tabela magazynu.

  4. Wybierz dowolną tabelę, otwórz menu kontekstowe, a następnie wybierz pozycję Nowe zapytanie SQL, a na koniec wybierz pozycję Wybierz 100 najlepszych.

  5. Zapytanie jest wykonywane i zwraca 100 rekordów w wybranej tabeli.

  6. Otwórz menu kontekstowe dla tej samej tabeli i wybierz pozycję Nowe zapytanie SQL. Napisz przykładowe zapytanie, które używa agregacji, takich jak SUM, COUNT, MINlub MAX. Połącz wiele tabel w hurtowni danych, aby wykonać zapytanie obejmujące wiele kontenerów.

    Uwaga / Notatka

    Na przykład to zapytanie będzie wykonywane w wielu kontenerach:

    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]
    

    W tym przykładzie przyjęto założenie, że chodzi o nazwę Twojej tabeli i kolumn. Użyj własnej tabeli i kolumn podczas pisania zapytania SQL.

  7. Wybierz zapytanie, a następnie wybierz pozycję Zapisz jako widok. Nadaj widokowi unikatową nazwę. Dostęp do tego widoku można uzyskać w dowolnym momencie w portalu Fabric.

  8. Wróć do bazy danych dublowanej w portalu Fabric.

  9. Wybierz pozycję Nowe zapytanie wizualne. Użyj edytora zapytań, aby tworzyć złożone zapytania.

    Zrzut ekranu przedstawiający edytor zapytań zarówno dla zapytań tekstowych, jak i wizualnych w usłudze Fabric.

Twórz raporty BI dotyczące zapytań lub widoków SQL

  1. Wybierz zapytanie lub widok, a następnie wybierz pozycję Eksploruj te dane (wersja zapoznawcza). Ta akcja eksploruje zapytanie w usłudze Power BI bezpośrednio przy użyciu usługi Direct Lake na danych lustrzanych w usłudze OneLake.
  2. Edytuj wykresy zgodnie z potrzebami i zapisz raport.

Wskazówka

Opcjonalnie możesz również użyć Copilot lub innych ulepszeń do tworzenia pulpitów i raportów bez dalszego przenoszenia danych.

Więcej przykładów

Dowiedz się więcej na temat uzyskiwania dostępu do dublowanych danych usługi Azure Cosmos DB i wykonywania na nich zapytań w usłudze Microsoft Fabric: