Condividi tramite


Esercitazione: Eseguire query sul database specchio di Microsoft Fabric da Cosmos DB

In questa esercitazione, esegui una query su un database con mirroring Fabric da un database Cosmos DB esistente in Fabric. Si apprenderà come abilitare il mirroring nel database, verificare lo stato del mirroring e quindi usare sia i dati di origine che i dati con mirroring per l'analisi.

Prerequisiti

Configura il tuo Cosmos DB nel database di Fabric

Assicurarsi prima di tutto che Cosmos DB nel database di Fabric sia configurato correttamente e contenga i dati per il mirroring.

  1. Apri il portale Fabric (https://app.fabric.microsoft.com).

  2. Vai al database Cosmos DB esistente.

    Importante

    Per questa esercitazione, il database Cosmos DB esistente deve avere già caricato il set di dati di esempio . I passaggi rimanenti di questa esercitazione presuppongono che si stia usando lo stesso set di dati per questo database.

  3. Verificare che il database contenga almeno un contenitore con dati. Eseguire questa verifica espandendo il contenitore nel riquadro di spostamento e osservando che gli elementi sono presenti.

  4. Nella barra dei menu selezionare Impostazioni per accedere alla configurazione del database.

  5. Nella finestra di dialogo Impostazioni passare alla sezione Mirroring per verificare che il mirroring sia abilitato per questo database.

    Annotazioni

    Il mirroring viene abilitato automaticamente per tutti i database Cosmos DB in Fabric. Questa funzionalità non richiede alcuna configurazione aggiuntiva e garantisce che i dati siano sempre pronti per l'analisi in OneLake.

Connettersi al database di origine

Verificare quindi di potersi connettere ed eseguire query direttamente sul database Cosmos DB di origine.

  1. Torna al database Cosmos DB esistente nel portale di Fabric.

  2. Selezionare ed espandere il contenitore esistente per visualizzarne il contenuto.

  3. Selezionare Elementi per esplorare i dati direttamente nel database.

  4. Verificare che sia possibile visualizzare gli elementi nel contenitore. Ad esempio, se si usa il set di dati di esempio, dovrebbero essere visualizzati elementi con proprietà come name, categorye countryOfOrigin.

  5. Selezionare Nuova query dal menu per aprire l'editor di query NoSQL.

  6. Eseguire una query di test per verificare la connettività e la disponibilità dei dati:

    SELECT COUNT(1) AS itemCount FROM container
    

    Questa query deve restituire il numero totale di elementi nel contenitore.

Connettersi al database con mirroring

A questo punto, accedere alla versione con mirroring del database tramite l'endpoint di analisi SQL per eseguire query sugli stessi dati usando T-SQL.

  1. Nella barra dei menu selezionare l'elenco Cosmos DB e quindi selezionare endpoint di analisi SQL per passare alla vista del database specchiato.

  2. Verificare che il contenitore venga visualizzato come tabella nell'endpoint di analisi SQL. La tabella deve avere lo stesso nome del contenitore.

  3. Selezionare Nuova query SQL dal menu per aprire l'editor di query T-SQL.

  4. Eseguire una query di test per verificare che il mirroring funzioni correttamente:

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

    Annotazioni

    Sostituire [SampleData] con il nome del contenitore se non si usa il set di dati di esempio.

  5. La query deve restituire lo stesso conteggio della query NoSQL, confermando che il mirroring esegue correttamente la replica dei dati.

Eseguire query sul database di origine da Fabric

Usare il portale di Infrastruttura per esplorare i dati già esistenti nell'account Azure Cosmos DB ed eseguire query sul database Cosmos DB di origine.

  1. Passare al database con mirroring nel portale di Infrastruttura.

  2. Selezionare Visualizza, quindi Database di origine. Questa azione apre Esplora dati di Azure Cosmos DB con una visualizzazione di sola lettura del database di origine.

    Screenshot di Esplora dati con una visualizzazione di sola lettura dei dati NoSQL nell'account Azure Cosmos DB.

  3. Selezionare un contenitore, quindi aprire il menu di scelta rapida e selezionare Nuova query SQL.

  4. Eseguire qualsiasi query. Ad esempio, usare SELECT COUNT(1) FROM container per contare il numero di elementi nel contenitore.

    Annotazioni

    Tutte le letture nel database di origine vengono instradate ad Azure e usano unità richiesta (UR) allocate nell'account.

Analizzare il database con mirroring di destinazione

Usare ora T-SQL per eseguire query sui dati NoSQL archiviati in Fabric OneLake.

  1. Passare al database con mirroring nel portale di Infrastruttura.

  2. Passare da Azure Cosmos DB con mirroringall'endpoint di analisi SQL.

    Screenshot del selettore per passare da un elemento all'altro nel portale di Fabric.

  3. Ogni contenitore nel database di origine deve essere rappresentato nell'endpoint di analisi SQL come tabella warehouse.

  4. Selezionare una tabella, aprire il menu di scelta rapida, quindi selezionare Nuova query SQL e infine selezionare Seleziona primi 100.

  5. La query viene eseguita e restituisce 100 record nella tabella selezionata.

  6. Aprire il menu di scelta rapida per la stessa tabella e selezionare Nuova query SQL. Scrivere una query di esempio che usa aggregazioni come SUM, COUNT, MINo MAX. Unire più tabelle nel warehouse per eseguire la query in più contenitori.

    Annotazioni

    Ad esempio, questa query viene eseguita in più contenitori:

    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 questo esempio si presuppone il nome della tabella e delle colonne. Usare tabelle e colonne personalizzate durante la scrittura della query SQL.

  7. Selezionare la query e quindi selezionare Salva come visualizzazione. Assegnare alla visualizzazione un nome univoco. È possibile accedere a questa visualizzazione in qualsiasi momento dal portale di Fabric.

  8. Tornare al database con mirroring nel portale di Infrastruttura.

  9. Selezionare Nuova query visiva. Usare l'editor di query per compilare query complesse.

    Screenshot dell'editor di query per le query basate su testo e visivo in Fabric.

Creare report BI sulle query o sulle viste SQL

  1. Selezionare la query o la vista e quindi selezionare Esplora questi dati (anteprima).Select the query or view and then select Explore this data (preview). Questa azione esplora la query in Power BI direttamente usando Direct Lake nei dati con mirroring di OneLake.
  2. Modificare i grafici in base alle esigenze e salvare il report.

Suggerimento

Facoltativamente, è anche possibile usare Copilot o altri miglioramenti per creare dashboard e report senza ulteriori spostamenti dei dati.