Elaborare i dati dall'hub eventi usando Analisi di flusso di Azure

Il servizio Analisi di flusso di Azure semplifica l'inserimento, l'elaborazione e l'analisi dei dati di streaming da Hub eventi di Azure, consentendo informazioni dettagliate avanzate per eseguire azioni in tempo reale. È possibile usare il portale di Azure per visualizzare i dati in ingresso e scrivere una query di Analisi di flusso. Quando la query è pronta, è possibile spostarla nell'ambiente di produzione in pochi clic.

Vantaggi principali

Ecco i vantaggi principali dell'integrazione di Hub eventi di Azure e Analisi di flusso di Azure:

• Anteprima dei dati: è possibile visualizzare in anteprima i dati in ingresso da un hub eventi nel portale di Azure.
• Testare la query: preparare una query di trasformazione e testarla direttamente nel portale di Azure. Per la sintassi del linguaggio di query, vedere la documentazione del linguaggio di query di Analisi di flusso.
• Distribuire la query nell'ambiente di produzione : è possibile distribuire la query nell'ambiente di produzione creando e avviando un processo di Analisi di flusso di Azure.

Flusso end-to-end

Importante

Se non si è membri di ruoli di proprietario o collaboratore a livello di sottoscrizione di Azure, è necessario essere membri del ruolo Tester di query di Analisi di flusso a livello di sottoscrizione di Azure per completare correttamente i passaggi descritti in questa sezione. Questo ruolo consente di eseguire prima le query di test senza creare un processo di analisi di flusso. Per istruzioni sull'assegnazione di un ruolo a un utente, vedere Assegnare ruoli di Active Directory agli utenti.

1. Accedere al portale di Azure.

2. Passare allo spazio dei nomi di Hub eventi e quindi passare all'hub eventi con i dati in ingresso.

3. Selezionare Elabora dati nella pagina dell'hub eventi o selezionare Elabora dati nel menu a sinistra.

   

4. Selezionare Avvia nel riquadro Abilita informazioni dettagliate in tempo reale dagli eventi .

   

5. Viene visualizzata una pagina di query con valori già impostati per i campi seguenti:

   1. Hub eventi come input per la query.

   2. Query SQL di esempio con istruzione SELECT.

   3. Alias di output per fare riferimento ai risultati del test della query.

      

      Nota

      Quando si usa questa funzionalità per la prima volta, questa pagina richiede l'autorizzazione per creare un gruppo di consumer e un criterio per l'hub eventi per visualizzare in anteprima i dati in ingresso.

6. Selezionare Crea nel riquadro Anteprima input , come illustrato nell'immagine precedente.

7. In questa scheda viene visualizzato immediatamente uno snapshot dei dati in ingresso più recenti.

   • Il tipo di serializzazione nei dati viene rilevato automaticamente (JSON/CSV). È possibile modificarlo manualmente anche in JSON/CSV/AVRO.

   • È possibile visualizzare in anteprima i dati in ingresso nel formato tabella o in formato non elaborato.

   • Se i dati visualizzati non sono aggiornati, selezionare Aggiorna per visualizzare gli eventi più recenti.

     Ecco un esempio di dati nel formato tabella:

     

     Ecco un esempio di dati nel formato non elaborato:

     

8. Selezionare Test query per visualizzare lo snapshot dei risultati dei test della query nella scheda Risultati test . È anche possibile scaricare i risultati.

   

9. Scrivere una query personalizzata per trasformare i dati. Vedere Informazioni di riferimento sul linguaggio di query di Analisi di flusso.

10. Dopo aver testato la query e averla spostata in produzione, selezionare Crea processo di Analisi di flusso.

    

11. Nella pagina Nuovo processo di Analisi di flusso seguire questa procedura:

    1. Specificare un nome per il processo.

    2. Selezionare la sottoscrizione di Azure in cui si vuole creare il processo.

    3. Selezionare il gruppo di risorse per la risorsa processo di Analisi di flusso.

    4. Selezionare il percorso per il processo.

    5. Per il nome del criterio di Hub eventi, creare un nuovo criterio o selezionare uno esistente.

    6. Per il gruppo di consumer di Hub eventi, creare un nuovo gruppo di consumer o selezionare un gruppo di consumer esistente.

    7. Selezionare Crea per creare il processo di Analisi di flusso.

       

       Nota

       È consigliabile creare un gruppo di consumer e un criterio per ogni nuovo processo di Analisi di flusso di Azure creato dalla pagina Hub eventi. I gruppi di consumer consentono solo cinque lettori simultanei, quindi fornire un gruppo di consumer dedicato per ogni processo eviterà eventuali errori che potrebbero verificarsi dal superamento di tale limite. Un criterio dedicato consente di ruotare la chiave o revocare le autorizzazioni senza influire sulle altre risorse.

12. Il processo di Analisi di flusso viene ora creato in cui la query è la stessa testata e l'input è l'hub eventi.

    

13. Aggiungere un output di propria scelta.

14. Tornare alla pagina del processo di Analisi di flusso facendo clic sul nome del processo nel collegamento di navigazione.

15. Selezionare Modifica query sopra la finestra Query .

16. Aggiornare [OutputAlias] con il nome di output e selezionare Salva collegamento query sopra la query. Chiudere la pagina Query selezionando X nell'angolo superiore destro.

17. Nella pagina processo di Analisi di flusso selezionare Avvia sulla barra degli strumenti per avviare il processo.

    

Access

Problema : l'utente non può accedere ai dati di anteprima perché non dispone delle autorizzazioni appropriate per la sottoscrizione.

Opzione 1: l'utente che vuole visualizzare in anteprima i dati in ingresso deve essere aggiunto come Collaboratore nella sottoscrizione.

Opzione 2: l'utente deve essere aggiunto come ruolo tester di query di Analisi di flusso nella sottoscrizione. Passare a Controllo di accesso per la sottoscrizione. Aggiungere una nuova assegnazione di ruolo per l'utente come ruolo "Tester query di Analisi di flusso".

Opzione 3: l'utente può creare un processo di Analisi di flusso di Azure. Impostare l'input come hub eventi e passare a "Query" per visualizzare in anteprima i dati in ingresso da questo hub eventi.

Opzione 4: l'amministratore può creare un ruolo personalizzato nella sottoscrizione. Aggiungere le autorizzazioni seguenti al ruolo personalizzato e quindi aggiungere l'utente al nuovo ruolo personalizzato.

Unità di streaming

Per impostazione predefinita, il processo di Analisi di flusso di Azure è costituito da tre unità di streaming (UNITÀ di streaming). Per modificare questa impostazione, selezionare Scalabilità nel menu a sinistra nella pagina del processo di Analisi di flusso nel portale di Azure. Per altre informazioni sulle unità di streaming, vedere Informazioni e modifica delle unità di streaming.

Passaggi successivi

Per altre informazioni sulle query di Analisi di flusso, vedere Linguaggio di query di Analisi di flusso