Snelstart: Een Stream Analytics-taak maken via Azure Portal

  • Artikel

In deze quickstart ziet u hoe u een Stream Analytics-taak maakt in Azure Portal. In deze quickstart definieert u een Stream Analytics-taak waarmee streaminggegevens in realtime worden gelezen, en berichten worden gefilterd over een temperatuur die hoger is dan 27. De Stream Analytics-taak leest gegevens uit IoT Hub, transformeert de gegevens en schrijft de uitvoergegevens naar een container in een Azure-blobopslag. De invoergegevens in deze quickstart worden gegenereerd via een Raspberry Pi Online Simulator.

Voordat u begint

Als u nog geen Azure-abonnement hebt, maakt u een gratis account.

De invoergegevens voorbereiden

Voordat u de Stream Analytics-taak definieert, moet u de invoergegevens voorbereiden. De real-time sensorgegevens worden opgenomen in IoT Hub en later 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.

    Screenshot showing the Create a resource menu.

  3. Selecteer op de pagina Een resource maken de optie Internet of Things>IoT Hub.

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

  4. Voer op de pagina IoT Hub de volgende stappen uit:

    1. Selecteer bij Abonnement uw Azure-abonnement.
    2. Selecteer voor resourcegroep een bestaande resourcegroep of maak een nieuwe resourcegroep.
    3. Voer voor de naam van de IoT-hub een naam in voor uw IoT-hub.
    4. Selecteer voor Regio de regio die zich het dichtst bij u bevindt.
    5. voor Laag selecteert u Gratis als deze nog steeds beschikbaar is voor uw abonnement. Zie Prijsinformatie IoT Hub voor meer informatie.
    6. Behoud voor de dagelijkse berichtlimiet de standaardwaarde.
    7. Selecteer Volgende: Netwerken onder aan de pagina.

    Screenshot showing the IoT Hub page for creation.

  5. 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.

  6. Nadat de resource (IoT Hub) is gemaakt, selecteert u Ga naar de resource om naar de ioT Hub-pagina te navigeren.

  7. Selecteer Apparaten in het linkermenu op de pagina IoT Hub en selecteer vervolgens + Apparaat toevoegen.

    Screenshot showing the Add device button on the Devices page.

  8. Voer een apparaat-id in en selecteer Opslaan.

    Screenshot showing the Create a device page.

  9. Zodra het apparaat is gemaakt, ziet u het apparaat in de lijst met IoT-apparaten . Selecteer de knop Vernieuwen op de pagina als u deze niet ziet.

    Screenshot showing the list of devices.

  10. Selecteer uw apparaat in de lijst.

  11. Selecteer op de apparaatpagina de knop Kopiëren naast Primaire Verbinding maken ionTekenreeks en sla deze op in een kladblok om later te gebruiken.

    Screenshot showing the copy button next to device connection string.

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 onder aan de pagina.

    Screenshot showing the Create a storage account page.

  3. Controleer uw instellingen op de pagina Controleren en selecteer Maken om het account te maken.

  4. Nadat de resource is gemaakt, selecteert u Ga naar de resource om naar de pagina Opslagaccount te navigeren.

  5. Selecteer op de pagina Opslagaccount containers in het menu links en selecteer vervolgens + Container.

    Screenshot showing the Add container menu on the Containers page.

  6. Geef op de pagina Nieuwe container een naam op voor uw container , zoals container1, en selecteer Maken.

    Screenshot showing the **Add container** page.

Een Stream Analytics-taak maken

  1. Meld u aan bij Azure Portal op een afzonderlijk tabblad van hetzelfde browservenster of in een afzonderlijk browservenster.
  2. Selecteer in de linkerbovenhoek van Azure Portal Een resource maken.
  3. Selecteer Analytics>Stream Analytics job in de lijst met resultaten. Als u de Stream Analytics-taak niet in de lijst ziet, zoekt u een Stream Analytics-taak met behulp van het zoekvak in het onderwerp en selecteert u deze in de zoekresultaten.
  4. Voer op de pagina Nieuwe Stream Analytics-taak de volgende stappen uit:

    1. Selecteer bij Abonnement uw Azure-abonnement.

    2. Selecteer voor resourcegroep dezelfde resource die u eerder in deze quickstart hebt gebruikt.

    3. Voer bij Naam een naam in voor de taak. De naam van een Stream Analytics-taak mag alleen alfanumerieke tekens, afbreekstreepjes en onderstrepingstekens bevatten en moet tussen de 3 en 63 tekens lang zijn.

    4. Voor de hostingomgeving controleert u of Cloud is geselecteerd. Stream Analytics-taken kunnen worden geïmplementeerd in Cloud of in Edge. Met de cloud kunt u implementeren in de Azure-cloud en met de Edge-optie kunt u implementeren op een IoT Edge-apparaat.

    5. Selecteer 1 voor Stream-eenheden. Streaming-eenheden vertegenwoordigen de computerresources die nodig zijn om een taak uit te voeren. Zie het artikel Streaming-eenheden begrijpen en aanpassen voor meer informatie over het schalen van streaming-eenheden.

    6. Selecteer Controleren en maken onderaan de pagina.

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

  5. Controleer de instellingen op de pagina Beoordelen en maken en selecteer Maken om een Stream Analytics-pagina te maken.
  6. Selecteer op de implementatiepagina Naar de resource gaan om naar de pagina Stream Analytics-taak te navigeren.

Taakinvoer configureren

In deze sectie configureert u een IoT Hub-apparaatinvoer voor de Stream Analytics-taak. Gebruik de IoT-hub die u hebt gemaakt in de vorige sectie van de quickstart.

  1. Selecteer Invoer onder Taaktopologie in het linkermenu op de pagina Stream Analytics-taak.

  2. Selecteer Invoer>toevoegen op de pagina Invoer.

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

  3. Voer op de pagina IoT Hub de volgende stappen uit:

    1. Voer Voor invoeralias IoTHubInput in.

    2. Selecteer voor Abonnement het abonnement met de IoT-hub die u eerder hebt gemaakt. In deze quickstart wordt ervan uitgegaan dat u de IoT-hub in hetzelfde abonnement hebt gemaakt.

    3. Selecteer uw IoT-hub voor IoT Hub.

    4. Selecteer Opslaan om de invoerinstellingen voor de Stream Analytics-taak op te slaan.

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

Taakuitvoer configureren

  1. Selecteer nu Uitvoer onder Taaktopologie in het linkermenu.

  2. Selecteer Op de pagina Uitvoer de optie Uitvoerblobopslag>/ADLS Gen2 toevoegen.

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

  3. Voer op de pagina Nieuwe uitvoer voor Blob Storage/ADLS Gen2 de volgende stappen uit:

    1. Voer voor uitvoeralias BlobOutput in.

    2. Selecteer voor Abonnement het abonnement met het Azure-opslagaccount dat u eerder hebt gemaakt. In deze quickstart wordt ervan uitgegaan dat u het opslagaccount in hetzelfde abonnement hebt gemaakt.

    3. Selecteer uw Opslagaccount voor het Opslagaccount.

    4. Selecteer voor Container uw blobcontainer als deze nog niet is geselecteerd.

    5. Selecteer voor de verificatiemodus Verbinding maken iontekenreeks.

    6. Selecteer Opslaan onder aan de pagina om de uitvoerinstellingen op te slaan.

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

De transformatiequery definiëren

  1. Selecteer nu Query onder Taaktopologie in het linkermenu.

  2. Voer de volgende query in het queryvenster in. In dit voorbeeld worden via de query de gegevens uit IoT Hub gelezen en gekopieerd naar een nieuw bestand in de blob.

    SELECT *
INTO BlobOutput
FROM IoTHubInput
WHERE Temperature > 27

  3. Selecteer De query Opslaan op de werkbalk.

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

De IoT-simulator uitvoeren

  1. Open de Raspberry Pi Azure IoT Online Simulator.

  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.

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

Stream Analytics-taak starten en uitvoer controleren

  1. Ga terug naar de overzichtspagina van de taak in Azure Portal en selecteer Taak starten.

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

  2. Controleer op de pagina Starttaak of Nu is geselecteerd voor begintijd van taakuitvoer en selecteer vervolgens Starten onderaan de pagina.

    Screenshot showing the **Start job** page.

  3. Zoek na enkele minuten in de portal het opslagaccount en de container die u hebt geconfigureerd als uitvoer voor de taak. U ziet nu het uitvoerbestand in de container. Het duurt enkele minuten voordat de taak voor het eerst wordt gestart. Nadat deze is gestart, blijft deze worden uitgevoerd wanneer de gegevens binnenkomen.

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

  4. Selecteer het bestand en selecteer vervolgens op de blobpagina Bewerken om de inhoud in het bestand weer te geven.

    Screenshot showing the sample output file.

Resources opschonen

Wanneer u een resourcegroep niet meer nodig hebt, verwijdert u de resourcegroep, de Stream Analytics-taak 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 wilt blijven gebruiken, verwijdert u alle resources die in deze quickstart zijn gemaakt door de volgende stappen uit te voeren:

  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 de Azure-portal geïmplementeerd. U kunt Stream Analytics-taken ook implementeren met behulp van PowerShell, Visual Studio en Visual Studio Code.

Voor informatie over het configureren van andere invoerbronnen en het uitvoeren van detectie in realtime gaat u door naar het volgende artikel:

Fraudedetectie in realtime met Azure Stream Analytics