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

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 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 nell'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 nella scheda Filtro e inserimento nella scheda 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 dispone di 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 o selezionare il simbolo a tre puntini accanto a un campo per rimuovere, rinominare o modificare il tipo.
     
   • Esempio in tempo reale dei 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.
     

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 avviare il processo di Analisi di flusso.
   

10. Per avviare il processo, specificare:

    • Numero di unità di streaming (UNITÀ di streaming) con cui viene eseguito il processo. 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 comportamento desiderato quando l'output di un processo nella destinazione ha esito negativo a causa di errori di 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 monitorarla o arrestarla e riavviarla in base alle esigenze.

    

Passaggi successivi

Altre informazioni su Analisi di flusso di Azure e su come monitorare il processo creato.

• Introduzione ad Analisi dei flussi di Azure
• Monitorare il processo di Analisi di flusso con portale di Azure