Condividi tramite

Creare dashboard di Power BI in tempo reale con Analisi di flusso senza editor di codice

Questa esercitazione illustra come usare Analisi di flusso senza editor di codice per calcolare aggregazioni su flussi di dati in tempo reale e archiviarli in Azure Synapse Analytics.

In questa esercitazione apprenderai a:

  • Distribuire un generatore di eventi che invia dati all'hub eventi
  • Creare un processo di Analisi dei flussi di dati usando l'editor senza codice
  • Esaminare i dati di input e lo schema
  • Selezionare i campi di cui eseguire il raggruppamento e definire aggregazioni come conteggio
  • Configurare Azure Synapse Analytics in cui vengono scritti i risultati
  • Eseguire il processo di Analisi di flusso
  • Visualizzare i dati in Power BI

Prerequisiti

Prima di iniziare, assicurarsi di completare i passaggi seguenti:

  1. Se non hai una sottoscrizione di Azure, crea un account gratuito.
  2. Distribuire il generatore di eventi TollApp in Azure. Usare questo collegamento per distribuire il modello di Azure TollApp. Impostare il interval parametro su 1. Usare un nuovo gruppo di risorse per questo passaggio.
  3. Creare un'area di lavoro di Azure Synapse Analytics con un pool SQL dedicato.
  4. Creare una tabella denominata carsummary usando il pool SQL dedicato. Eseguire lo script SQL seguente: 
    CREATE TABLE carsummary   
(  
    Make nvarchar(20),  
    CarCount int,
	times datetime
)
WITH ( CLUSTERED COLUMNSTORE INDEX ) ;

Usare un editor senza codice per creare un processo di Stream Analytics

  1. Individuare il gruppo di risorse in cui è stato distribuito il generatore di eventi TollApp.

  2. Selezionare lo spazio dei nomi di Hub eventi di Azure.

  3. Nella pagina Spazio dei Nomi di Hub Eventi, selezionare Hub Eventi sotto Entità nel menu a sinistra.

  4. Selezionare l'istanza entrystream .

    Screenshot che mostra la selezione dell'hub eventi.

  5. Nella sezione Funzionalità, passare a Elabora dati e quindi selezionare avvia nel modello Inizia con tela vuota.

    Screenshot che mostra la selezione del pulsante Start nel riquadro Inizia con un canvas vuoto.

  6. Nomina la tua attività carsummary e seleziona Crea.

    Screenshot della pagina Nuovo processo di Analisi di flusso.

  7. Nella pagina di configurazione dell'hub eventi verificare le impostazioni seguenti e quindi selezionare Connetti.

    1. In Gruppo di consumer selezionare Usa esistente e quindi selezionare Predefinito.

    2. Per Tipo di serializzazione verificare che sia selezionato JSON .

    3. Per la Modalità di autenticazione, verificare che la Stringa di connessione venga usata per connettersi all'hub eventi: Stringa di connessione.

      Screenshot della pagina di configurazione per l'hub eventi.

  8. Entro pochi secondi vengono visualizzati i dati di input di esempio e lo schema. È possibile scegliere di eliminare campi, rinominare i campi o modificare i tipi di dati.

    Screenshot che mostra l'anteprima dei dati nell'hub eventi e nei campi.

  9. Selezionare Operazioni sulla barra dei comandi e quindi selezionare Raggruppa per.

    Screenshot che mostra il menu Operazioni con l'opzione Raggruppa per selezionata nella barra dei comandi.

  10. Selezionare il riquadro Raggruppa per nel canvas e connetterlo al riquadro dell'hub eventi.

    Screenshot che mostra il riquadro Raggruppa per connesso al riquadro Hub eventi.

  11. Configurare il riquadro Raggruppa per specificando:

    1. Aggregazione come Conteggio.

    2. Campo come Make, che è un campo annidato all'interno di CarModel.

    3. Selezionare Aggiungi.

      Screenshot dell'impostazione Aggregazioni nella pagina di configurazione Raggruppa per.

    4. Nella sezione Impostazioni :

      1. Per Aggregazioni di gruppi per, selezionare Marca.

      2. Per l'Intervallo di tempo verificare che il valore sia impostato su Tumbling.

      3. Per Durata immettere 3 minuti.

      4. Selezionare Fine nella parte inferiore della pagina.

        Screenshot della pagina di configurazione Raggruppa per.

  12. Selezionare Raggruppa per e notare i dati raggruppati nella scheda Anteprima dati nella parte inferiore della pagina.

    Screenshot che mostra la scheda Anteprima dei dati per l'operazione Raggruppa per.

  13. Sulla barra dei comandi selezionare Operazioni e quindi Gestisci campi.

  14. Connettere i riquadri Raggruppa per e Gestisci campi.

  15. Nella pagina Gestisci campi seguire questa procedura:

    1. Aggiungere il campo Crea come illustrato nell'immagine seguente e quindi selezionare Aggiungi.

      Screenshot che mostra l'aggiunta del campo Crea.

    2. Selezionare Aggiungi.

      Screenshot che mostra il pulsante Aggiungi nella pagina Gestisci campi.

  16. Selezionare Aggiungi tutti i campi nella pagina di configurazione Gestisci campi .

    Screenshot della pagina Gestisci campi.

  17. Selezionare ... accanto ai campi e selezionare Modifica per rinominarli.

    • COUNT_make in CarCount

    • Window_End_Time in orari

      Screenshot della pagina Gestisci campi con i campi rinominati.

  18. Selezionare Fine nella pagina Gestisci campi . La pagina Gestisci campi dovrebbe essere simile a quella illustrata nell'immagine seguente.

    Screenshot della pagina Gestisci campi con tre campi.

  19. Selezionare il riquadro Gestisci campi e visualizzare il flusso di dati nell'operazione nella scheda Anteprima dati nella parte inferiore della pagina.

    Screenshot che mostra la scheda Anteprima dati per l'operazione Campi gestiti.

  20. Sulla barra dei comandi selezionare Output e quindi Synapse.

    Screenshot della barra dei comandi con Outputs e Synapse selezionati.

  21. Connettere il riquadro Synapse al riquadro Gestisci campi nell'area di disegno.

  22. Nella pagina delle impostazioni di Synapse seguire questa procedura:

    1. Se l'account di archiviazione Job non è già impostato, selezionare l'account Azure Data Lake Storage nel gruppo di risorse. Si tratta dell'account di archiviazione usato da Synapse SQL per caricare i dati nel data warehouse.

      Screenshot che mostra Synapse con la selezione dell'account di archiviazione.

    2. Selezionare la sottoscrizione di Azure in cui si trova Azure Synapse Analytics.

    3. Selezionare il database del pool SQL dedicato usato per creare la carsummary tabella nella sezione precedente.

    4. Immettere nome utente e password per l'autenticazione.

    5. Immettere il nome della tabella come carsummary.

    6. Selezionare Connetti. Vengono visualizzati risultati di esempio scritti nella tabella Synapse SQL.

      Screenshot delle impostazioni del riquadro di Synapse.

  23. Selezionare il riquadro Synapse e visualizzare la scheda Anteprima dati nella parte inferiore della pagina. Viene visualizzato il flusso di dati nel pool SQL dedicato.

    Screenshot che mostra l'anteprima dei dati per il riquadro Synapse.

  24. Selezionare Salva nella barra multifunzione superiore per salvare il processo e quindi selezionare Avvia. Screenshot che mostra il pulsante Start sulla barra dei comandi.

  25. Nella pagina Avvia processo di Analisi di flusso, selezionare Avvia per eseguire il processo.

    Screenshot della pagina Avvia processo di Stream Analytics.

  26. Verrà quindi visualizzato un elenco di tutti i processi di Analisi di flusso creati senza editor di codice. Entro due minuti, il processo passa a uno stato In esecuzione. Selezionare il pulsante Aggiorna nella pagina per visualizzare la modifica dello stato da Created - Starting - Running (Creato -> Avvio -> In esecuzione).

    Screenshot che mostra l'elenco delle attività.

Creare una visualizzazione di Power BI

  1. Scaricare la versione più recente di Power BI Desktop.

  2. Usare il connettore Power BI per Azure Synapse SQL.

    Screenshot che mostra Power BI Desktop con Azure e Synapse Analytics SQL selezionato.

  3. Connettersi al database usando DirectQuery e usare questa query per recuperare i dati dal database

    SELECT [Make],[CarCount],[times]
FROM [dbo].[carsummary]
WHERE times >= DATEADD(day, -1, GETDATE())

    Screenshot che mostra la configurazione di Power BI Desktop per connettersi ad Azure Synapse database SQL.

    Passare alla scheda Database e immettere le credenziali (nome utente e password) per connettersi al database ed eseguire la query.

  4. Selezionare Carica per caricare i dati in Power BI.

  5. È quindi possibile creare un grafico a linee con

    • Asse X come orari
    • Asse Y come CarCount
    • Legenda come fare in modo che venga visualizzato un grafico pubblicabile. È possibile configurare l'aggiornamento automatico della pagina e impostarlo su 3 minuti per ottenere una visualizzazione in tempo reale. Screenshot del dashboard di Power BI che mostra i dati di riepilogo delle automobili.

Altre opzioni

Oltre ad Azure Synapse SQL, è anche possibile usare il database SQL come output dell'editor senza codice per ricevere i dati di streaming. Utilizzare quindi il connettore Power BI per connettersi al database SQL con il proprio database usando DirectQuery per costruire il dashboard live.

È anche una buona opzione per creare il dashboard in tempo reale con i dati di streaming. Per ulteriori informazioni sull'output SQL Database, vedere Trasformare e inserire in SQL Database.

Pulire le risorse

  1. Individuare l'istanza di Event Hubs e visualizzare l'elenco dei processi di Stream Analytics nella sezione Elabora dati. Arrestare tutti i processi in esecuzione.
  2. Passare al gruppo di risorse usato durante la distribuzione del generatore di eventi TollApp.
  3. Selezionare Elimina gruppo di risorse. Per confermare l'eliminazione, digitare il nome del gruppo di risorse.

Passaggi successivi

In questa esercitazione, è stato creato un processo di Analisi di flusso utilizzando l'editor senza codice per definire le aggregazioni e inviare i risultati ad Azure Synapse Analytics. È stato quindi usato Power BI per creare un dashboard in tempo reale per visualizzare i risultati generati dal processo.

Nessuna elaborazione del flusso di codice con Analisi di flusso di Azure

  • Last updated on