Filtrare e inserire in Azure Esplora dati usando l'editor di codice di Analisi di flusso senza editor di codice

Articolo
06/01/2023

Questo articolo descrive come usare l'editor di codice senza creare facilmente un processo di Analisi di flusso. Legge continuamente da Hub eventi, filtra i dati in ingresso e quindi scrive i risultati in modo continuo in Azure Esplora dati.

Prerequisiti

Le risorse di Hub eventi di Azure e Azure Esplora dati devono essere accessibili pubblicamente e non essere dietro un firewall o protetto in un Rete virtuale di Azure
I dati nell'hub eventi devono essere serializzati in formato JSON, CSV o Avro.

Sviluppare un processo di Analisi di flusso per filtrare e inserire dati in tempo reale

Nella portale di Azure individuare e selezionare l'istanza di Hub eventi di Azure.
Selezionare Funzionalità>Elabora dati e quindi selezionare Avvia nel filtro e archiviare i dati nella scheda Esplora dati di Azure.
Immettere un nome per il processo di Analisi di flusso e quindi selezionare Crea.
Specificare il tipo di serializzazione dei dati nella finestra Hub eventi e il metodo Authentication che il processo userà per connettersi agli Hub eventi. Selezionare Connetti.
Quando la connessione viene stabilita correttamente e si dispone di flussi di dati che passano all'istanza di Hub eventi, verranno immediatamente visualizzate due cose:
- Campi presenti nei dati di input. È possibile scegliere Aggiungi campo o selezionare il simbolo a tre punti accanto a un campo per rimuovere, rinominare o modificare il relativo tipo.
- Esempio live di dati in ingresso nella tabella Anteprima dati nella visualizzazione diagramma. Viene aggiornato automaticamente periodicamente. È possibile selezionare Sospendi anteprima streaming per visualizzare una visualizzazione statica dei dati di input di esempio.
Selezionare il riquadro Filtro per aggregare i dati. Nell'area Filtro selezionare un campo per filtrare i dati in ingresso con una condizione.
Selezionare il riquadro Gestisci . Nel pannello Gestisci campi di configurazione scegliere i campi da restituire nell'hub eventi. Per aggiungere tutti i campi, selezionare Aggiungi tutti i campi.
Selezionare riquadro di Azure Esplora dati. Nel pannello di configurazione compilare parametri necessari e connettersi.

Nota

La tabella deve esistere nel database selezionato e lo schema della tabella deve corrispondere esattamente al numero di campi e ai relativi tipi generati dall'anteprima dei dati.
Facoltativamente, selezionare Recupera anteprima statica/Aggiorna anteprima statica per visualizzare l'anteprima dei dati che verrà inserita nell'hub eventi.
Selezionare Salva e quindi avviare il processo di Analisi di flusso.
Per avviare il processo, specificare:
- Numero di unità di streaming (UNITÀ di streaming) con cui viene eseguito il processo. Le unità ssd rappresentano la quantità di calcolo e memoria allocata al processo. È consigliabile iniziare con tre e quindi modificare in base alle esigenze.
- Gestione degli errori di output dei dati : consente di specificare il comportamento desiderato quando l'output di un processo alla destinazione non riesce a causa di errori di dati. Per impostazione predefinita, il processo esegue il tentativo fino a quando l'operazione di scrittura ha esito positivo. È anche possibile scegliere di eliminare tali eventi di output.
Dopo aver selezionato Start, il processo viene avviato entro due minuti e le metriche verranno aperte nella sezione scheda seguente.

È anche possibile visualizzare il processo nella sezione Elabora dati nella scheda Processi di Analisi di flusso . Selezionare Apri metriche per monitorare o arrestarla e riavviarla, in base alle esigenze.