Filtrare e inserire in Azure Synapse SQL usando Analisi di flusso senza editor di codice

Questo articolo descrive come usare l'editor senza codice per creare con facilità un processo di Stream Analytics. Legge continuamente da Hub eventi, filtra i dati in ingresso e quindi scrive i risultati in modo continuo nella tabella Synapse SQL.

Prerequisiti

• Le risorse Hub eventi di Azure devono essere accessibili pubblicamente e non possono essere protette da un firewall o protette in un'Rete virtuale di Azure.
• I dati negli hub eventi devono essere serializzati in formato JSON, CSV o Avro.

Sviluppare un processo di Analisi di flusso per filtrare e inserire dati

Usare la procedura seguente per sviluppare un processo di Analisi di flusso per filtrare e inserire dati in tempo reale in una tabella Synapse SQL.

1. Nel portale di Azure, individuare e selezionare l'istanza di Hub eventi di Azure.

2. Selezionare Funzionalità>Elabora dati, e selezionare Avvia sulla scheda Filtro e inserimento in Synapse SQL.
   

3. Immettere un nome per identificare il processo di Analisi di flusso e quindi selezionare Crea.
   

4. Specificare il tipo di serializzazione dei dati nella finestra hub eventi e il metodo di autenticazione che verrà usato dal processo per connettersi a Hub eventi. Selezionare Connetti.
   

5. Quando la connessione viene stabilita correttamente e si hanno flussi di dati che passano all'istanza di Hub eventi, verranno immediatamente visualizzati due elementi:

   • Campi presenti nei dati di input. È possibile scegliere Aggiungi campo oppure selezionare il simbolo a tre punti accanto a un campo per rimuovere, rinominare o modificarne il tipo.
     
   • Anteprima in tempo reale di dati in ingresso nella tabella Anteprima dati nella vista del diagramma. Viene aggiornato automaticamente periodicamente. È possibile selezionare Sospendi anteprima streaming per visualizzare una visualizzazione statica dei dati di input di esempio.
     

6. Nell'area Filtro selezionare un campo per filtrare i dati in ingresso con una condizione.
   

7. Selezionare la tabella Synapse SQL per inviare i dati filtrati:

   1. Selezionare sottoscrizione, database (nome pool SQL dedicato) e metodo di autenticazione dal menu a discesa.
   2. Immettere Nome tabella in cui verranno inseriti i dati filtrati. Selezionare Connetti.
      

   Nota

   Lo schema della tabella deve corrispondere esattamente al numero di campi e ai relativi tipi generati dall'anteprima dei dati.

8. Facoltativamente, selezionare Recupera anteprima statica/Aggiorna anteprima statica per visualizzare l'anteprima dei dati che verrà inserita nella tabella Synapse SQL selezionata.
   

9. Selezionare Salva e quindi avviareil processo di Analisi di flusso.
   

10. Per avviare il processo, specificare:

    • Numero di unità di streaming (SUs) con cui viene eseguito il lavoro. Le unità di streaming rappresentano la quantità di calcolo e memoria allocata al processo. È consigliabile iniziare con tre e quindi regolare in base alle esigenze.
    • Gestione degli errori dei dati di output – Consente di specificare il modo in cui si desidera gestire l'output di un processo quando non riesce a raggiungere la destinazione a causa di errori nei dati. Per impostazione predefinita, il processo ritenta fino a quando l'operazione di scrittura non riesce. È anche possibile scegliere di eliminare tali eventi di output.
      

11. Dopo aver selezionato Avvia, il processo viene avviato entro due minuti e le metriche verranno aperte nella sezione della scheda seguente.

    È anche possibile visualizzare il processo nella sezione Elabora dati nella scheda Processi di Analisi di flusso. Selezionare Apri metriche per monitorarlo o arrestarlo e riavviarlo in base alle esigenze.

    

Considerazioni sull'uso della funzionalità di replica geografica di Hub eventi

Gli hub eventi di Azure hanno recentemente lanciato la funzionalità di replica geografica in anteprima pubblica. Questa funzionalità è diversa dalla funzionalità ripristino di emergenza geografico di Hub eventi di Azure.

Quando il tipo di failover è Forzato e la coerenza della replica è asincrona, il processo Stream Analytics non garantisce l'output esattamente una volta su un output Hub eventi di Azure.

Analisi di flusso di Azure, come producer con un output di un hub eventi, potrebbe osservare un ritardo limite nel processo durante la durata del failover e durante la limitazione da parte di Hub eventi nel caso in cui il ritardo di replica tra primario e secondario raggiunga il ritardo massimo configurato.

Analisi di flusso di Azure, come consumer con Hub eventi come input, potrebbe osservare un ritardo del watermark nel processo durante il failover e potrebbe saltare alcuni dati o trovare dati duplicati al termine del failover.

A causa di queste avvertenze, riavviare il processo di Analisi di flusso con l'ora di inizio appropriata subito dopo il completamento del failover di Hub eventi. Inoltre, poiché la funzionalità di replica geografica di Hub eventi è in anteprima pubblica, non usare questo modello per i processi di Analisi di flusso di produzione a questo punto. Il comportamento corrente di Stream Analytics migliorerà prima che la funzionalità di replica geografica di Event Hubs diventi generalmente disponibile e possa essere usata nei processi di produzione di Stream Analytics.

Passaggi successivi

Ulteriori informazioni su Analisi di flusso di Azure e su come monitorare il processo che hai creato.

• Introduzione ad Analisi dei flussi di Azure
• Monitorare il job di Stream Analytics con il portale di Azure