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

  • Articolo

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 di flusso usando l'editor di codice senza editor di codice
  • Esaminare i dati di input e lo schema
  • Selezionare i campi per raggruppare e definire aggregazioni come count
  • Configurare Azure Synapse Analytics in cui verranno scritti i risultati
  • Eseguire il processo di Analisi di flusso
  • Visualizzazione dei dati in Power BI

Prerequisiti

Prima di iniziare, assicurarsi di aver completato 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 parametro 'interval' 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.

    Nota

    Se si vuole creare il dashboard di Power BI in tempo reale direttamente senza acquisire i dati nel database, è possibile ignorare il passaggio 3 e 4, quindi passare a questa guida per creare dashboard in tempo reale con il set di dati di Power BI prodotto dal processo di Analisi di flusso.

  4. Creare una tabella denominata carsummary usando il pool SQL dedicato. A tale scopo, eseguire lo script SQL seguente:

    CREATE TABLE carsummary   
(  
    Make nvarchar(20),  
    CarCount int,
	times datetime
)
WITH ( CLUSTERED COLUMNSTORE INDEX ) ;

Usare nessun editor di codice per creare un processo di Analisi di flusso

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

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

  3. Nella pagina Spazio dei nomi di Hub eventi selezionare Hub eventi in Entità nel menu a sinistra.

  4. Selezionare l'istanza entrystream .

    Screenshot che mostra la selezione dell'hub eventi.

  5. Passare a Elabora dati nella sezione Funzionalità e quindi selezionare Avvia nel modello Inizia con area di disegno vuota.

    Screenshot che mostra la selezione del pulsante Start nel riquadro Inizia con un'area di disegno vuota.

  6. Assegnare un nome al processo carsummary e selezionare 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 Connessione.

    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 Connessione ion String venga usato per connettersi all'hub eventi: stringa di Connessione ion.

      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 il tipo di dati, se necessario.

    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 Group by selezionato sulla barra dei comandi.

  10. Selezionare il riquadro Raggruppa per nell'area di disegno e connetterlo al riquadro dell'hub eventi.

    Screenshot che mostra il riquadro Gruppo 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 Raggruppa per configurazione.

    4. Nella sezione Impostazioni:

      1. Per Aggregazioni di gruppi in base a, selezionare Crea.

      2. Per Intervallo di tempo verificare che il valore sia impostato su a cascata.

      3. Per Durata immettere 3 minuti

      4. Selezionare Fine nella parte inferiore della pagina.

        Screenshot della pagina Raggruppa per configurazione.

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

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

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

  14. Connessione 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 il pulsante 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 a CarCount

    • Window_End_Time volte

      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 Output, Synapse selezionato.

  21. ConnessioneRiquadro di Synapse nel riquadro Gestisci campi nell'area di disegno.

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

    1. Se l'account di archiviazione processo non è già impostato, selezionare l'account di Archiviazione Azure Data Lake 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. Verranno visualizzati risultati di esempio che verranno 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 selezionato 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 Analisi di flusso.

  26. Verrà quindi visualizzato un elenco di tutti i processi di Analisi di flusso creati senza editor di codice. E, entro due minuti, il processo passa a uno stato In esecuzione . Selezionare il pulsante Aggiorna nella pagina per visualizzare lo stato che cambia da Creato -> Avvio -> In esecuzione.

    Screenshot che mostra l'elenco dei processi.

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. Connessione al database con 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 Destop 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 volte
    • Asse Y come CarCount
    • Legenda come Make You'll then see a chart that can be published. È 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

Ad eccezione di Azure Synapse SQL, è anche possibile usare il database SQL come output dell'editor senza codice per ricevere i dati di streaming. Usare quindi il connettore Power BI per connettere il database SQL al database con DirectQuery e creare il dashboard in tempo reale.

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

Pulire le risorse

  1. Individuare l'istanza di Hub eventi e visualizzare l'elenco dei processi di Analisi di flusso 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. Digitare il nome del gruppo di attività per confermare l'eliminazione.

Passaggi successivi

In questa esercitazione è stato creato un processo di Analisi di flusso usando l'editor di codice per definire le aggregazioni e scrivere risultati in 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