Condividi tramite

Avvio rapido: creare un processo di Analisi di flusso di Azure tramite il portale di Azure

  • Articolo

Questa guida introduttiva illustra come creare un processo di Analisi di flusso nel portale di Azure. In questa guida introduttiva si definirà un processo di Analisi di flusso che legge dati di streaming in tempo reale e filtra i messaggi con una temperatura maggiore di 27. Il processo di Analisi di flusso legge i dati da hub IoT, trasforma i dati e scrive i dati di output in un contenitore in un archivio BLOB di Azure. I dati di input usati in questa guida introduttiva sono generati da un simulatore online Raspberry Pi.

Operazioni preliminari

Se non hai una sottoscrizione di Azure, crea un account gratuito.

Preparare i dati di input

Prima di definire il processo di Analisi di flusso, è necessario preparare i dati di input. I dati del sensore in tempo reale vengono inseriti nell'hub IoT, che viene in seguito configurato come input del processo. Per preparare i dati di input richiesti dal processo, completare questa procedura:

  1. Accedere al portale di Azure.

  2. Selezionare Crea una risorsa.

    Screenshot showing the Create a resource menu.

  3. Nella pagina Crea una risorsa selezionare Internet delle cose> hub IoT.

    Screenshot showing the IoT Hub menu on the Create a resource page.

  4. Nella pagina hub IoT seguire questa procedura:

    1. Per Sottoscrizione selezionare la sottoscrizione di Azure.
    2. Per Gruppo di risorse selezionare un gruppo di risorse esistente o creare un nuovo gruppo di risorse.
    3. Per Nome hub IoT immettere un nome per l'hub IoT.
    4. In Area selezionare l'area più vicina.
    5. per Livello selezionare Gratuito, se è ancora disponibile nella sottoscrizione. Per altre informazioni, vedere i prezzi dell'hub IoT.
    6. Per Limite messaggi giornalieri mantenere il valore predefinito.
    7. Selezionare Avanti: Rete nella parte inferiore della pagina.

    Screenshot showing the IoT Hub page for creation.

  5. Selezionare Rivedi e crea. Esaminare le informazioni hub IoT e selezionare Crea. La creazione dell'hub IoT può richiedere alcuni minuti. È possibile monitorare lo stato di avanzamento nel riquadro Notifiche.

  6. Dopo aver creato la risorsa (hub IoT), selezionare Vai alla risorsa per passare alla pagina hub IoT.

  7. Nella pagina hub IoT selezionare Dispositivi nel menu a sinistra e quindi selezionare + Aggiungi dispositivo.

    Screenshot showing the Add device button on the Devices page.

  8. Immettere un ID dispositivo e selezionare Salva.

    Screenshot showing the Create a device page.

  9. Dopo aver creato il dispositivo, verrà visualizzato l'elenco dei dispositivi IoT. Selezionare il pulsante Aggiorna nella pagina se non viene visualizzato.

    Screenshot showing the list of devices.

  10. Selezionare il dispositivo dall'elenco.

  11. Nella pagina del dispositivo selezionare il pulsante copia accanto a Stringa di Connessione primaria e salvarlo in un Blocco note da usare in un secondo momento.

    Screenshot showing the copy button next to device connection string.

Creare l'archiviazione BLOB

  1. Nell'angolo superiore sinistro del portale di Azure selezionare Crea risorsa>Archiviazione>Account di archiviazione.

  2. Nel riquadro Crea account di archiviazione immettere un nome, una posizione e un gruppo di risorse per l'account di archiviazione. Scegliere la stessa posizione e lo stesso gruppo di risorse dell'hub IoT creato. Selezionare quindi Rivedi nella parte inferiore della pagina.

    Screenshot showing the Create a storage account page.

  3. Nella pagina Verifica esaminare le impostazioni e selezionare Crea per creare l'account.

  4. Dopo aver creato la risorsa, selezionare Vai alla risorsa per passare alla pagina Archiviazione account.

  5. Nella pagina Archiviazione account selezionare Contenitori nel menu a sinistra e quindi selezionare + Contenitore.

    Screenshot showing the Add container menu on the Containers page.

  6. Nella pagina Nuovo contenitore specificare un nome per il contenitore, ad esempio container1, e selezionare Crea.

    Screenshot showing the **Add container** page.

Creare un processo di Analisi di flusso.

  1. In una scheda separata della stessa finestra del browser o in una finestra separata del browser accedere al portale di Azure.
  2. Selezionare Crea risorsa nell'angolo superiore sinistro del portale di Azure.
  3. Selezionare Analisi>Processo di Analisi di flusso nell'elenco risultati. Se nell'elenco non viene visualizzato il processo di Analisi di flusso, cercare processo di Analisi di flusso usando la casella di ricerca nell'argomento e selezionarla nei risultati della ricerca.
  4. Nella pagina Nuovo processo di Analisi di flusso seguire questa procedura:

    1. Per Sottoscrizione selezionare la sottoscrizione di Azure.

    2. In Gruppo di risorse selezionare la stessa risorsa usata in precedenza in questa guida introduttiva.

    3. In Nome immettere un nome per il processo. Il nome del processo di Analisi di flusso può contenere solo caratteri alfanumerici, trattini e caratteri di sottolineatura e deve avere una lunghezza compresa tra 3 e 63 caratteri.

    4. Per Ambiente di hosting verificare che Cloud sia selezionato. Per la distribuzione dei processi di Analisi di flusso è possibile scegliere tra Cloud o Edge. Il cloud consente di eseguire la distribuzione nel cloud di Azure e l'opzione Edge consente di eseguire la distribuzione in un dispositivo IoT Edge.

    5. Per Unità di flusso selezionare 1. Le unità di streaming rappresentano le risorse di calcolo necessarie per eseguire un processo. Per informazioni sul ridimensionamento delle unità di streaming, vedere l'articolo Informazioni sulle unità di streaming.

    6. Selezionare Rivedi e crea nella parte inferiore della pagina.

      Screenshot showing the **New Stream Analytics job** page.

  5. Nella pagina Rivedi e crea rivedere le impostazioni e selezionare Crea per creare una pagina di Analisi di flusso.
  6. Nella pagina di distribuzione selezionare Vai alla risorsa per passare alla pagina del processo di Analisi di flusso.

Configurare l'input del processo

In questa sezione viene configurato un input del dispositivo hub IoT per il processo di Analisi di flusso. Usare l'hub IoT creato nella sezione precedente della guida introduttiva.

  1. Nella pagina processo di Analisi di flusso selezionare Input in Topologia processo nel menu a sinistra.

  2. Nella pagina Input selezionare Aggiungi input> hub IoT.

    Screenshot showing the **Inputs** page with **Add stream input** > **IoT Hub** menu selected.**.

  3. Nella pagina hub IoT seguire questa procedura:

    1. Per Alias di input immettere IoTHubInput.

    2. Per Sottoscrizione selezionare la sottoscrizione con l'hub IoT creato in precedenza. Questa guida introduttiva presuppone che l'hub IoT sia stato creato nella stessa sottoscrizione.

    3. Per hub IoT selezionare l'hub IoT.

    4. Selezionare Salva per salvare le impostazioni di input per il processo di Analisi di flusso.

      Screenshot showing the New input page to enter input IoT hub information.

Configurare l'output del processo

  1. Selezionare ora Output in Topologia processo nel menu a sinistra.

  2. Nella pagina Output selezionare Aggiungi archiviazione BLOB di output>/ADLS Gen2.

    Screenshot showing the **Outputs** page with **Add** -> **Blob storage** option selected on the menu.

  3. Nella pagina Nuovo output per Archiviazione BLOB/ADLS Gen2 seguire questa procedura:

    1. Per Alias di output immettere BlobOutput.

    2. Per Sottoscrizione selezionare la sottoscrizione con l'account di archiviazione di Azure creato in precedenza. Questa guida introduttiva presuppone che sia stato creato l'account Archiviazione nella stessa sottoscrizione.

    3. Per Archiviazione account selezionare l'account Archiviazione.

    4. Per Contenitore selezionare il contenitore BLOB, se non è già selezionato.

    5. Per Modalità di autenticazione selezionare Connessione stringa di Connessione ion.

    6. Selezionare Salva nella parte inferiore della pagina per salvare le impostazioni di output.

      Screenshot showing the **New output** page to enter input Azure storage account information.

Definire la query di trasformazione

  1. Selezionare ora Query in Topologia processo nel menu a sinistra.

  2. Immettere la query seguente nella finestra di query. In questo esempio la query legge i dati dall'hub IoT e li copia in un nuovo file nel BLOB.

    SELECT *
INTO BlobOutput
FROM IoTHubInput
WHERE Temperature > 27

  3. Selezionare Salva query sulla barra degli strumenti.

    Screenshot showing the **Query** page with the sample query.

Eseguire il simulatore IoT

  1. Aprire il simulatore online Azure IoT Raspberry Pi.

  2. Sostituire il segnaposto nella riga 15 con la stringa di connessione del dispositivo hub IoT di Azure salvato in una sezione precedente.

  3. Selezionare Esegui. L'output mostra i dati del sensore e i messaggi inviati all'hub IoT.

    Screenshot showing the **Raspberry Pi Azure IoT Online Simulator** page with the sample query.

Avviare il processo di Analisi di flusso e controllare l'output

  1. Tornare alla pagina di panoramica del processo nella portale di Azure e selezionare Avvia processo.

    Screenshot showing the **Overview** page with **Start** button selected.

  2. Nella pagina Avvia processo verificare che l'opzione Ora sia selezionata per Ora di inizio dell'output del processo e quindi selezionare Avvia nella parte inferiore della pagina.

    Screenshot showing the **Start job** page.

  3. Dopo alcuni minuti, nel portale trovare l'account di archiviazione e il contenitore configurato come output per il processo. È ora possibile visualizzare il file di output nel contenitore. L'avvio del processo richiede alcuni minuti per la prima volta, dopo l'avvio, continuerà a essere eseguito man mano che arrivano i dati.

    Screenshot showing the **Container** page with the sample output file.

  4. Selezionare il file e quindi nella pagina BLOB selezionare Modifica per visualizzare il contenuto nel file.

    Screenshot showing the sample output file.

Pulire le risorse

Quando non sono più necessari, eliminare il gruppo di risorse, il processo di Analisi di flusso e tutte le risorse correlate. Eliminando il processo si evita di pagare per le unità di streaming usate dal processo. Se si prevede di usare il processo in futuro, è possibile arrestarlo e riavviarlo in un secondo momento, quando è necessario. Se non si intende continuare a usare questo processo, eliminare tutte le risorse create da questa guida introduttiva attenendosi alla procedura seguente:

  1. Scegliere Gruppi di risorse dal menu a sinistra del portale di Azure e quindi selezionare il nome della risorsa creata.

  2. Nella pagina del gruppo di risorse selezionare Elimina, digitare il nome della risorsa da eliminare nella casella di testo e quindi selezionare Elimina.

Passaggi successivi

In questa guida introduttiva è stato distribuito un semplice processo di Analisi di flusso con il portale di Azure. È anche possibile distribuire processi di Analisi di flusso usando PowerShell, Visual Studio e Visual Studio Code.

Per informazioni sulla configurazione di altre origini di input e sull'esecuzione del rilevamento in tempo reale, continuare con l'articolo seguente:

Rilevamento delle frodi in tempo reale tramite Analisi di flusso di Azure