Condividi tramite

Guida introduttiva: Creare un job di Azure Stream Analytics utilizzando Visual Studio

Questa guida introduttiva illustra come creare ed eseguire un processo di Analisi di flusso usando gli strumenti di Analisi di flusso di Azure per Visual Studio. Il processo di esempio legge i dati in streaming da un dispositivo dell'hub IoT. Si definisce un job che calcola la temperatura media quando è superiore a 27° e scrive gli eventi di output risultanti in un nuovo file nel BLOB storage.

Annotazioni

  • È consigliabile usare gli strumenti di Analisi di flusso per Visual Studio Code per un'esperienza di sviluppo locale ottimale. Esistono lacune nelle funzionalità note negli strumenti di Analisi di flusso per Visual Studio 2019 (versione 2.6.3000.0) e non verrà migliorata in futuro.
  • Gli strumenti di Visual Studio e Visual Studio Code non supportano i processi nelle aree Cina orientale, Cina settentrionale, Germania centrale e Germania settentrionale.

Prima di iniziare

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

  • Accedi al portale di Azure.

  • Installare Visual Studio 2019, Visual Studio 2015 o Visual Studio 2013 Update 4. Sono supportate le edizioni Enterprise (Ultimate/Premium), Professional e Community. L'edizione Express non è supportata.

  • Seguire le istruzioni di installazione per installare gli strumenti di Analisi di flusso per Visual Studio.

Preparare i dati di input

Prima di definire il processo di Analisi di flusso, è necessario preparare i dati, che verranno successivamente configurati come input del processo. Per preparare i dati di input richiesti dal processo, completare i passaggi seguenti:

  1. Accedi al portale di Azure.

  2. Selezionare Crea una risorsa>Internet delle cose>hub IoT.

  3. Nel riquadro Hub IoT immettere le informazioni seguenti:

    impostazione Valore consigliato Descrizione
    Subscription <Sottoscrizione> Selezionare la sottoscrizione di Azure da usare.
    Gruppo di risorse asaquickstart-resourcegroup Selezionare Crea nuovo e immettere un nuovo nome del gruppo di risorse per l'account.
    Nome hub IoT MyASAIoTHub Selezionare un nome per l'hub IoT.
    Area geografica <Selezionare l'area più vicina agli utenti> Selezionare una posizione geografica in cui è possibile ospitare l'hub IoT. Usare la posizione più vicina agli utenti.
    Tier Gratuito Per questa guida introduttiva, selezionare Gratuito se è ancora disponibile nella sottoscrizione. Se il livello gratuito non è disponibile, scegliere il livello più basso disponibile. Per altre informazioni, vedere Prezzi dell'hub IoT.

    Screenshot che mostra la procedura guidata Crea hub IoT nel portale di Azure.

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

  5. Al termine della distribuzione, selezionare Vai alla risorsa per accedere alla pagina dell'hub IoT.

  6. Nella pagina Hub IoT selezionare Dispositivi in Gestione dei dispositivi nel menu di spostamento a sinistra.

  7. Nella pagina Dispositivi selezionare + Aggiungi dispositivo sulla barra degli strumenti.

    Screenshot che mostra la pagina Dispositivi con l'opzione Aggiungi dispositivo selezionata.

  8. Nella pagina Crea un dispositivo immettere un nome per il dispositivo e selezionare Salva.

    Screenshot che mostra la pagina Crea un dispositivo.

  9. Dopo aver creato il dispositivo, aprire il dispositivo dall'elenco dei dispositivi IoT . Se non vedi ancora il dispositivo, aggiorna la pagina.

    Screenshot che mostra l'elenco dei dispositivi con il dispositivo creato.

  10. Copiare la stringa di connessione primaria e salvarla in un Blocco note da usare in un secondo momento.

Creare un archivio Blob

  1. Nell'angolo in alto a sinistra del portale di Azure, selezionare Crea una risorsa>Archiviazione>Account di archiviazione.

  2. Nel riquadro Crea account di archiviazione immettere un nome, una posizione e un gruppo di risorse dell'account di archiviazione. Scegliere la stessa località e lo stesso gruppo di risorse dell'hub IoT creato. Selezionare Rivedi + crea per creare l'account.

    Screenshot che mostra la pagina Crea account di archiviazione nel portale di Azure.

  3. Dopo aver creato l'account di archiviazione, selezionare il riquadro Servizio BLOB nel riquadro Panoramica .

    Screenshot che mostra la pagina di panoramica dell'account di archiviazione con il servizio BLOB selezionato.

  4. Nella pagina Servizio BLOB selezionare + Contenitore sulla barra degli strumenti.

  5. Nella pagina Nuovo contenitore immettere un nome per il contenitore, ad esempio container1. Lasciare il livello di accesso Pubblicoprivato (nessun accesso anonimo) e selezionare Crea.

    Screenshot che mostra la pagina Nuovo contenitore.

Creare un progetto di Analisi di flusso

  1. Avvia Visual Studio.

  2. Selezionare File > Nuovo progetto.

  3. Nell'elenco dei modelli a sinistra selezionare Analisi di flusso e quindi applicazione Analisi di flusso di Azure.

  4. Immettere il nome del progetto, il percorso e il nome della soluzione e selezionare Crea.

    Screenshot che mostra la finestra di dialogo Crea un progetto di Analisi di flusso.

  5. Si notino gli elementi inclusi in un progetto di Analisi di flusso di Azure.

    Screenshot che mostra la finestra Esplora soluzioni per un progetto di applicazione di Analisi di flusso di esempio in Visual Studio.

Scegliere la sottoscrizione richiesta

  1. In Visual Studio scegliere Esplora server dal menu Visualizza.
  2. Fare clic con il pulsante destro del mouse su Azure, scegliere Connetti alla sottoscrizione di Microsoft Azure e quindi accedere con l'account Azure.

Definire l'input

  1. In Esplora soluzioni espandere il nodo Input e fare doppio clic su Input.json.

  2. Compilare la Configurazione di Input di Stream Analytics con i valori seguenti:

    impostazione Valore consigliato Descrizione
    Alias di input Input Immettere un nome per identificare l'input del processo.
    Tipo di origine Flusso di dati Scegliere l'origine di input appropriata: Flusso di dati o Dati di riferimento.
    Fonte IoT Hub Scegliere l'origine di input appropriata.
    Risorsa Scegliere l'origine dati dall'account corrente Scegliere di immettere i dati manualmente o selezionare un account esistente.
    Subscription <Sottoscrizione> Seleziona la sottoscrizione di Azure che contiene l'hub IoT che hai creato.
    IoT Hub MyASAIoTHub Scegliere o immettere il nome dell'hub IoT. I nomi dell'hub IoT vengono rilevati automaticamente se vengono creati nella stessa sottoscrizione.

  3. Lascia le altre opzioni ai valori predefiniti e seleziona Salva per salvare le impostazioni.

    Screenshot che mostra la pagina di configurazione dell'input di Stream Analytics.

Definire l'output

  1. In Esplora soluzioni espandere il nodo Output e fare doppio clic su Output.json.

  2. Compilare la configurazione dell'output di Stream Analytics con i valori seguenti:

    impostazione Valore consigliato Descrizione
    Alias di output Risultato Immettere un nome per identificare l'output del processo.
    Lavandino Data Lake Storage Gen 2/Blob Storage Scegliere il sink appropriato.
    Risorsa Specificare manualmente le impostazioni dell'origine dati Scegliere di immettere i dati manualmente o selezionare un account esistente.
    Subscription <Sottoscrizione> Selezionare la sottoscrizione di Azure con l'account di archiviazione creato. L'account di archiviazione può trovarsi nella stessa sottoscrizione o in una sottoscrizione diversa. In questo esempio si presuppone che l'account di archiviazione sia stato creato nella stessa sottoscrizione.
    Account di archiviazione asaquickstartstorage Scegliere o immettere il nome dell'account di archiviazione. I nomi degli account di archiviazione vengono rilevati automaticamente se vengono creati nella stessa sottoscrizione.
    Contenitore container1 Selezionare il contenitore esistente creato nell'account di archiviazione.
    Modello di percorso output Immettere il nome di un percorso di file da creare all'interno del contenitore.

  3. Lascia le altre opzioni ai valori predefiniti e seleziona Salva per salvare le impostazioni.

    Screenshot che mostra la pagina di configurazione dell'output di Stream Analytics.

Definire la query di trasformazione

  1. Apri Script.asaql da Esplora Soluzioni in Visual Studio.

  2. Aggiungere la query seguente:

    SELECT *
INTO Output
FROM Input
WHERE Temperature > 27

Inviare ad Azure una query di Analisi di flusso

  1. Nell'editor di query selezionare Invia ad Azure nell'editor di script.

  2. Nella finestra Invia processo selezionare Crea un nuovo processo di Analisi di flusso di Azure.

  3. Immettere un nome del job.

  4. Scegliere la sottoscrizione di Azure.

  5. Scegliere il gruppo di risorse.

  6. Mantenere il valore predefinito per Cluster.

  7. Selezionare la posizione usata all'inizio dell'avvio rapido.

  8. Selezionare quindi Invia.

    Screenshot che mostra la finestra di dialogo di invio attività.

Eseguire il simulatore IoT

  1. Aprire il simulatore online Raspberry Pi Azure IoT in una nuova scheda o finestra del browser.

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

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

    Screenshot che mostra il simulatore online di Azure IoT Raspberry Pi.

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

  1. Quando il job viene creato, la visualizzazione del job viene aperta automaticamente. Selezionare il pulsante freccia verde per avviare il processo.

    Screenshot che mostra il pulsante Start per avviare un processo di Analisi di flusso da Visual Studio.

  2. Modificare la Modalità di avvio dell'output del processo in JobStartTime e selezionare Avvia.

    Screenshot che mostra la finestra di dialogo per la configurazione di avvio del processo di Stream Analytics.

  3. Si noti che lo stato del processo è stato modificato in In esecuzione e sono presenti eventi di input/output. L'operazione potrebbe richiedere alcuni minuti. Selezionare il pulsante Aggiorna sulla barra degli strumenti per aggiornare le metriche.

    Screenshot che mostra lo stato del processo in esecuzione e le metriche del processo.

  4. Per visualizzare i risultati, scegliere Cloud Explorer dal menu Visualizza e passare all'account di archiviazione nel gruppo di risorse. In Contenitori BLOB fare doppio clic su container1 e quindi sul percorso del file di output.

    Visualizzazione dei risultati

Pulire le risorse

Quando non sono più necessari, eliminare il gruppo di risorse, il processo di streaming 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 job in futuro, è possibile arrestarlo e riavviarlo in un secondo momento quando ne hai bisogno. Se non si intende continuare a usare questo processo, eliminare tutte le risorse create da questa guida introduttiva attenendosi alla procedura seguente:

  1. Nel menu a sinistra nel portale di Azure selezionare Gruppi di risorse 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 questo avvio rapido, hai distribuito un semplice job di Stream Analytics usando Visual Studio. È anche possibile distribuire processi di Analisi di flusso usando il portale di Azure e PowerShell.

Per informazioni sugli strumenti di Analisi di flusso di Azure per Visual Studio, continuare con l'articolo seguente:

Usare Visual Studio per visualizzare i processi di Analisi di flusso di Azure

  • Last updated on