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. Questa integrazione consente di creare rapidamente una pipeline di analisi del percorso critico. È 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.
Accedere al portale di Azure.
Passare allo spazio dei nomi di Hub eventi e quindi passare all'hub eventi con i dati in ingresso.
Selezionare Elabora dati nella pagina dell'hub eventi.
Selezionare Esplora nel riquadro Abilita informazioni dettagliate in tempo reale dagli eventi .
Viene visualizzata una pagina di query con valori già impostati per i campi seguenti:
Hub eventi come input per la query.
Query SQL di esempio con istruzione SELECT.
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.
Selezionare Crea nel riquadro Anteprima input , come illustrato nell'immagine precedente.
Verrà visualizzato immediatamente uno snapshot dei dati in ingresso più recenti in questa scheda.
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.
Di seguito è riportato un esempio di dati nel formato tabella:
Di seguito è riportato un esempio di dati nel formato non elaborato:
Selezionare Test query per visualizzare lo snapshot dei risultati dei test della query nella scheda Risultati test . È anche possibile scaricare i risultati.
Scrivere una query personalizzata per trasformare i dati. Vedere Informazioni di riferimento sul linguaggio di query di Analisi di flusso.
Dopo aver testato la query e averla spostata nell'ambiente di produzione, selezionare Distribuisci query. Per distribuire la query, creare un processo di Analisi di flusso di Azure in cui è possibile impostare un output per il processo e avviare il processo. Per creare un processo di Analisi di flusso, specificare un nome per il processo e selezionare Crea.
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.
Il processo di Analisi di flusso viene ora creato in cui la query è la stessa testata e l'input è l'hub eventi.
Per completare la pipeline, impostare l'output della query e selezionare Avvia per avviare il processo.
Nota
Prima di avviare il processo, non dimenticare di sostituire outputalias con il nome di output creato in Analisi di flusso di Azure.
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