Quickstart: crea un lavoro di Stream Analytics in Visual Studio

In questo quickstart, crei un lavoro di Stream Analytics utilizzando gli strumenti Analisi di flusso di Azure per Visual Studio. Il lavoro di esempio legge i dati in streaming da un dispositivo hub IoT. Definisci un lavoro che calcola la temperatura media quando il valore è superiore a 27° e scrive gli eventi di output risultanti in un nuovo file in blob storage.

Prerequisiti

Prima di iniziare, assicurati di avere i seguenti prerequisiti.

Annotazioni

Per un'esperienza di sviluppo locale ottimale, usare gli strumenti di Analisi di flusso per Visual Studio Code. Gli strumenti di Stream Analytics per Visual Studio 2019 (versione 2.6.3000.0) presentano notevoli lacune di funzionalità e non ricevono ulteriori miglioramenti. Gli strumenti di Visual Studio e Visual Studio Code non supportano i processi nelle aree Cina orientale, Cina settentrionale, Germania centrale e Germania settentrionale.

Preparare i dati di input

Prima di definire il lavoro di Stream Analytics, prepara i dati che poi configurerai come input del lavoro. Per preparare i dati di input, completare i seguenti passaggi:

  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 Seleziona un nome per il tuo hub IoT.
    Area geografica <Seleziona la regione più vicina ai tuoi utenti> Seleziona una posizione geografica dove puoi ospitare il tuo 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. Esamina le informazioni del tuo hub IoT e seleziona Crea. Il tuo hub IoT potrebbe richiedere qualche minuto per essere creato. Monitorare lo stato di avanzamento nel riquadro Notifiche .

  5. Dopo il completamento del deployment, seleziona Vai alla risorsa per accedere alla pagina dell'hub IoT del tuo 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, aprilo dalla lista 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

In questa sezione crei un account Archiviazione di Azure e un contenitore blob per memorizzare gli eventi di output del tuo lavoro.

  1. Nell'angolo superiore sinistro 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 il tuo account di archiviazione, seleziona la tessera del servizio Blob nel pannello 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

Crea un progetto di Stream Analytics in Visual Studio per definire gli input, i output e la query del lavoro.

  1. Avvia Visual Studio.

  2. Selezionare File>Nuovo progetto.

  3. Nella lista dei modelli, seleziona Stream Analytics e poi Analisi di flusso di Azure Application.

  4. Inserisci il nome del progetto, la posizione e il nome della soluzione, e seleziona Crea.

    Screenshot che mostra la finestra di dialogo Crea un progetto Stream Analytics.

  5. Nota gli elementi in un progetto 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

Collega Visual Studio all'abbonamento Azure che contiene le risorse che hai creato.

  1. In Visual Studio scegliere Esplora server dal menu Visualizza.
  2. Seleziona e tieni premuto (o clicca destro) Azure, seleziona Collegati a Microsoft Azure Subscription, e poi accedi con il tuo account Azure.

Definire l'input

Configura l'input del lavoro per leggere i dati in streaming dall'hub IoT che hai creato.

  1. In Esplora soluzioni, espandi il nodo Inputs e apri Input.json.

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

    impostazione Valore consigliato Descrizione
    Alias di input Input Inserisci un nome per identificare l'input del lavoro.
    Tipo di origine Flusso di dati Scegliere l'origine di input appropriata: Flusso di dati o Dati di riferimento.
    Fonte hub IoT 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 l'abbonamento Azure che contiene l'hub IoT che hai creato.
    hub IoT MyASAIoTHub Scegli o inserisci il nome del tuo hub IoT. I nomi degli hub IoT appaiono automaticamente se li crei nello stesso abbonamento.

  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

Configura l'output del processo per scrivere i risultati nel contenitore di archiviazione BLOB.

  1. In Esplora soluzioni, espandi il nodo Outputs e apri Output.json.

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

    impostazione Valore consigliato Descrizione
    Alias di output Risultato Inserisci un nome per identificare l'output del lavoro.
    Lavandino Data Lake Storage Gen 2/gestione rete virtuale di Azure 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. Questo esempio presuppone che tu abbia creato un account di archiviazione nello stesso abbonamento.
    Account di archiviazione asaquickstartstorage Scegliere o immettere il nome dell'account di archiviazione. I nomi degli account di archiviazione appaiono automaticamente se li crei nello stesso abbonamento.
    Contenitore container1 Selezionare il contenitore esistente creato nell'account di archiviazione.
    Modello di percorso output Inserisci il nome di un percorso 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

Definisci una query che filtra i dati in streaming e invia i risultati all'output.

  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

Invia la query ad Azure per creare il lavoro di Stream Analytics.

  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. Seleziona la Posizione che hai usato all'inizio del quickstart.

  8. Selezionare Invia.

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

Eseguire il simulatore IoT

Esegui il simulatore Raspberry Pi per inviare i dati dei sensori di esempio al tuo hub 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 dovrebbe mostrare i dati dei sensori e i messaggi inviati al tuo hub IoT.

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

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

Avvia il lavoro e verifica che processi gli eventi di input e scriva l'output nello storage blob.

  1. Quando crei il tuo lavoro, la vista del lavoro si apre automaticamente. Seleziona il pulsante freccia verde per iniziare il lavoro.

    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. Lo stato del lavoro cambia in Esecuzione, e appaiono eventi di input e output. Questo cambiamento potrebbe richiedere qualche minuto. 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, nel menu Visualizza , seleziona Cloud Explorer e vai all'account di archiviazione nel tuo gruppo di risorse. Sotto Blob Containers, apri il contenitore 1 e poi il percorso del file di output.

    Screenshot che mostra i risultati di output nel container blob container1.

Pulire le risorse

Quando non ne hai più bisogno, elimina il gruppo di risorse, il lavoro di streaming e tutte le risorse correlate. Eliminare il lavoro interrompe la fatturazione per le unità di streaming che consuma. Se hai intenzione di usare il lavoro in futuro, fermalo e ricomincialo più tardi quando ne avrai bisogno. Se non prevedi di utilizzare di nuovo questo lavoro, usa i seguenti passaggi per eliminare tutte le risorse create da questo quickstart:

  1. Dal menu sinistro del portale Azure, seleziona Gruppi di risorse, poi seleziona il nome della risorsa che hai creato.
  2. Nella pagina del gruppo di risorse selezionare Elimina, digitare il nome della risorsa da eliminare nella casella di testo e quindi selezionare Elimina.

Contenuti correlati

  • Last updated on