Quickstart: Een Azure Stream Analytics-taak maken met behulp van Visual Studio

  • Artikel

Deze snelstart laat zien hoe u een Stream Analytics-taak kunt maken en uitvoeren met Azure Stream Analytics-tools voor Visual Studio. De voorbeeldtaak leest streaminggegevens vanaf een IoT Hub-apparaat. U definieert een taak die de gemiddelde temperatuur bij meer dan 27° berekent en de resulterende uitvoergebeurtenissen naar een nieuw bestand in blobopslag schrijft.

Notitie

  • We raden u ten zeerste aan Stream Analytics-hulpprogramma's voor Visual Studio Code te gebruiken voor de beste lokale ontwikkelervaring. Er zijn bekende functieproblemen in Stream Analytics-hulpprogramma's voor Visual Studio 2019 (versie 2.6.3000.0) en dit wordt in de toekomst niet verbeterd.
  • De hulpprogramma's Visual Studio en Visual Studio Code bieden geen ondersteuning voor taken in de regio's China - oost, China - noord, Duitsland - centraal en Duitsland - noordoost.

Voordat u begint

  • Als u nog geen abonnement op Azure hebt, maakt u een gratis account aan.

  • Meld u aan bij de Azure-portal.

  • Installeer Visual Studio 2019, Visual Studio 2015 of Visual Studio 2013 Update 4. Enterprise- (Ultimate/Premium), Professional- en Community-edities worden ondersteund. De Express-editie wordt niet ondersteund.

  • Volg de installatie-instructies om Stream Analytics-hulpprogramma's voor Visual Studio te installeren.

De invoergegevens voorbereiden

Voordat u de Stream Analytics-taak definieert, moet u de gegevens voorbereiden die later worden geconfigureerd als de taakinvoer. Voltooi de volgende stappen om de invoergegevens voor te bereiden die zijn vereist voor de taak:

  1. Meld u aan bij de Azure-portal.

  2. Selecteer Een resource maken>Internet of Things>IoT Hub.

  3. Voer in het deelvenster IoT Hub de volgende informatie in:

    Instelling Voorgestelde waarde Beschrijving
    Abonnement <Uw abonnement> Selecteer het Azure-abonnement dat u wilt gebruiken.
    Resourcegroep asaquickstart-resourcegroup Selecteer Nieuwe maken en voer een naam voor de nieuwe resourcegroep voor uw account in.
    Naam van de IoT-hub MyASAIoTHub Selecteer een naam voor de IoT-hub.
    Regio <Selecteer de regio die het dichtst bij uw gebruikers is gelegen> Selecteer een geografische locatie waar u de IoT-hub kunt hosten. Gebruik de locatie die het dichtst bij uw gebruikers is.
    Laag Gratis Voor deze quickstart selecteert u Gratis als dit nog steeds beschikbaar is in uw abonnement. Als de categorie Gratis niet beschikbaar is, kiest u de laagste beschikbare categorie. Zie Prijsinformatie IoT Hub voor meer informatie.

    Schermopname van de wizard IoT Hub maken in de Azure Portal.

  4. Selecteer Controleren + maken. Controleer uw IoT Hub gegevens en selecteer Maken. Het kan enkele minuten duren voordat de IoT-hub is gemaakt. U kunt de voortgang bewaken via het deelvenster Meldingen.

  5. Nadat de implementatie is voltooid, selecteert u Ga naar resource om naar de pagina IoT Hub voor uw IoT-hub te navigeren.

  6. Selecteer op de pagina IoT Hubapparaten onder Apparaatbeheer in het navigatiemenu aan de linkerkant.

  7. Selecteer op de pagina Apparatende optie + Apparaat toevoegen op de werkbalk.

    Schermopname van de pagina Apparaten met Apparaat toevoegen geselecteerd.

  8. Voer op de pagina Een apparaat maken een naam in voor het apparaat en selecteer Opslaan.

    Schermopname van de pagina Een apparaat maken.

  9. Zodra het apparaat is gemaakt, wordt het geopend vanuit de lijst IoT-apparaten. Als u het apparaat nog niet ziet, vernieuwt u de pagina.

    Schermopname van de lijst met apparaten met het apparaat dat u hebt gemaakt.

  10. Kopieer de primaire connection string en sla deze op in een kladblok voor later gebruik.

Blob-opslag maken

  1. Selecteer in de linkerbovenhoek in Azure Portal Een resource maken>Storage>Storage-account.

  2. Voer in het deelvenster Opslagaccount maken een opslagaccountnaam, locatie en resourcegroep in. Kies dezelfde locatie en resourcegroep als de IoT-hub die u hebt gemaakt. Selecteer vervolgens Controleren en maken om het account te maken.

    Schermopname van de pagina Opslagaccount maken in de Azure Portal.

  3. Nadat uw opslagaccount is gemaakt, selecteert u de tegel Blob-service in het deelvenster Overzicht .

    Schermopname van de overzichtspagina van het opslagaccount met Blob-service geselecteerd.

  4. Selecteer op de pagina Blob service in de werkbalk de optie + Container.

  5. Voer op de pagina Nieuwe container een naam in voor de container, zoals container1. Laat openbare toegangsniveau staan op Privé (geen anonieme toegang) en selecteer Maken.

    Schermopname van de pagina Nieuwe container.

Een Stream Analytics-project maken

  1. Start Visual Studio.

  2. Selecteer Bestand > Nieuw project.

  3. Selecteer Stream Analyticsin de sjablonenlijst aan de linkerkant en selecteer vervolgens Azure Stream Analytics Application.

  4. Voer de projectnaam, locatie en oplossingsnaam in en selecteer Maken.

    Schermopname van het dialoogvenster Een Stream Analytics-project maken.

  5. Let op de elementen die zijn opgenomen in een Azure Stream Analytics-project.

    Schermopname van het Solution Explorer venster voor een voorbeeldproject van een Stream Analytics-toepassing in Visual Studio.

Kies het vereiste abonnement

  1. Selecteer in Visual Studio in het menu Beeld de optie Server Explorer.
  2. Klik met de rechtermuisknop op Azure, selecteer Verbinding maken met Microsoft Azure-abonnementen meld u aan met uw Azure-account.

Invoer definiëren

  1. Vouw in Solution Explorerhet knooppunt Inputs uit en dubbelklik op Input.json.

  2. Vul de Stream Analytics-invoerconfiguratie in met de volgende waarden:

    Instelling Voorgestelde waarde Beschrijving
    Invoeralias Invoer Voer een unieke naam in voor de invoer van de taak.
    Brontype Gegevensstroom Kies de juiste invoerbron: Gegevensstroom of Verwijzingsgegevens.
    Bron IoT Hub Kies de juiste invoerbron.
    Resource Kies gegevensbron van het huidige account Kies ervoor om gegevens handmatig in te voeren of selecteer een bestaand account.
    Abonnement <Uw abonnement> Selecteer het Azure-abonnement met de IoT-hub die u hebt gemaakt.
    IoT Hub MyASAIoTHub Kies uw IoT-hub, of voer de naam ervan in. IoT Hub namen worden automatisch gedetecteerd als ze in hetzelfde abonnement worden gemaakt.

  3. De andere opties kunnen de standaardwaarden behouden. Selecteer Opslaan om de instellingen op te slaan.

    Schermopname van de pagina Stream Analytics-invoerconfiguratie.

Uitvoer definiëren

  1. Vouw in Solution Explorerhet knooppunt Outputs uit en dubbelklik op Output.json.

  2. Vul de Stream Analytics-uitvoerconfiguratie in met de volgende waarden:

    Instelling Voorgestelde waarde Beschrijving
    Uitvoeralias Uitvoer Voer een unieke naam in voor de uitvoer van de taak.
    Sink Data Lake Storage Gen 2/Blob Storage Kies de juiste sink.
    Resource Gegevensbroninstellingen handmatig opgeven Kies ervoor om gegevens handmatig in te voeren of selecteer een bestaand account.
    Abonnement <Uw abonnement> Selecteer het Azure-abonnement met het opslagaccount dat u hebt gemaakt. Het opslagaccount kan voor hetzelfde of een ander abonnement gelden. Voor dit voorbeeld wordt aangenomen dat u een opslagaccount voor hetzelfde abonnement hebt gemaakt.
    Opslagaccount asaquickstartstorage Kies of typ de naam van het opslagaccount. Namen van opslagaccounts worden automatisch gedetecteerd als ze in hetzelfde abonnement worden gemaakt.
    Container container1 Selecteer de bestaande container die u in uw opslagaccount hebt gemaakt.
    Padpatroon output Voer de naam in van een bestandspad dat in de container moet worden gemaakt.

  3. De andere opties kunnen de standaardwaarden behouden. Selecteer Opslaan om de instellingen op te slaan.

    Schermopname van de pagina Stream Analytics-uitvoerconfiguratie.

De transformatiequery definiëren

  1. Open Script.asaql vanuit Solution Explorer in Visual Studio.

  2. Voeg de volgende query toe:

    SELECT *
INTO Output
FROM Input
WHERE Temperature > 27

Een Stream Analytics-query naar Azure verzenden

  1. Selecteer in de Query-editorVerzenden naar Azure in de scripteditor.

  2. Selecteer in het venster Taak verzendende optie Een nieuwe Azure Stream Analytics-taak maken.

  3. Voer een taaknaam in.

  4. Kies het Azure-abonnement.

  5. Kies de resourcegroep.

  6. Behoud de standaardwaarde voor Cluster.

  7. Selecteer de locatie die u aan het begin van de quickstart hebt gebruikt.

  8. Selecteer vervolgens Verzenden.

    Schermopname van het dialoogvenster Taak verzenden.

De IoT-simulator uitvoeren

  1. Open de Raspberry Pi Azure IoT Online Simulator in een nieuw browsertabblad of -venster.

  2. Vervang de tijdelijke aanduiding in regel 15 door de verbindingsreeks van het Azure IoT Hub-apparaat die u hebt opgeslagen in de vorige sectie.

  3. Selecteer Uitvoeren. De uitvoer geeft de sensorgegevens en berichten weer die worden verzonden naar de IoT-hub.

    Schermopname van de Raspberry Pi Azure IoT Online Simulator.

Stream Analytics-taak starten en uitvoer controleren

  1. Wanneer de taak is gemaakt, wordt de taakweergave automatisch geopend. Selecteer de knop met de groene pijl om de taak te starten.

    Schermopname van de knop Start om een Stream Analytics-taak te starten vanuit Visual Studio.

  2. Wijzig de startmodus voor de uitvoertaak in JobStartTime en selecteer Start.

    Schermopname van het dialoogvenster Stream Analytics Taakconfiguratie starten.

  3. Merk op dat de taakstatus is gewijzigd in Actiefen dat er invoer-/uitvoergebeurtenissen zijn. Dit kan enkele minuten duren. Selecteer de knop Vernieuwen op de werkbalk om metrische gegevens te vernieuwen.

    Schermopname van de taakstatus als actief en metrische gegevens voor de taak.

  4. Als u resultaten wilt bekijken, selecteert u in het menu BeeldCloud Exploreren navigeert u naar het opslagaccount in uw resourcegroep. Dubbelklik onder Blob Containersop container1en vervolgens op het uitvoerbestandspad.

    Resultaten weergeven

Resources opschonen

Wanneer u een resourcegroep niet meer nodig hebt, verwijdert u de resourcegroep, de streamingtaak en alle gerelateerde resources. Door de taak te verwijderen, voorkomt u dat de streaming-eenheden die door de taak worden verbruikt, in rekening worden gebracht. Als u denkt dat u de taak in de toekomst nog gaat gebruiken, kunt u deze stoppen en later opnieuw starten wanneer dat nodig is. Als u deze taak niet meer gaat gebruiken, verwijdert u alle resources die in deze quickstart zijn gemaakt met behulp van de volgende stappen:

  1. Selecteer in het menu aan de linkerkant in Azure Portal de optie Resourcegroepen en selecteer vervolgens de resource die u hebt gemaakt.
  2. Selecteer op de pagina van uw resourcegroep de optie Verwijderen, typ de naam van de resource die u wilt verwijderen in het tekstvak en selecteer vervolgens Verwijderen.

Volgende stappen

In deze snelstart hebt u een eenvoudige Stream Analytics-taak met behulp van Visual Studio geïmplementeerd. U kunt Stream Analytics-taken ook implementeren met behulp van de Azure-portal en PowerShell.

Ga voor meer informatie over Azure Stream Analytics-hulpprogramma's voor Visual Studio naar het volgende artikel:

Visual Studio gebruiken om Azure Stream Analytics-taken weer te geven