Delen via

Snelstart: Een Stream Analytics-taak maken via Azure Portal

  • Artikel

In deze quickstart maakt u een Stream Analytics-taak in Azure Portal. U definieert een Stream Analytics-taak die realtime streaminggegevens leest en berichten filtert met een temperatuur die groter 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.

Vereisten

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 het Azure-portaal.

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

    Schermopname van het menu IoT Hub op de pagina Een resource maken.

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

    Schermopname van de IoT Hub-pagina voor het maken.

  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 resource (IoT Hub) is gemaakt, selecteert u Ga naar de resource om naar de ioT Hub-pagina te navigeren.

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

    Schermopname van de knop Apparaat toevoegen op de pagina Apparaten.

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

    Schermopname van de pagina Een apparaat maken.

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

    Schermopname van de lijst met apparaten.

  9. Selecteer uw apparaat in de lijst.

  10. Selecteer op de apparaatpagina de kopieerknop naast primaire verbindingsreeks en sla deze op in een kladblok om later te gebruiken.

    Schermopname van de knop Kopiëren naast apparaat verbindingsreeks.

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.

    Schermopname van de pagina **Raspberry Pi Azure IoT Online Simulator** met de voorbeeldquery.

Blob-opslag maken

  1. Selecteer in de linkerbovenhoek van Azure Portal de optie Een resource maken. Selecteer Opslag onder Categorieën in het linkermenu en selecteer vervolgens Opslagaccount.

  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.

    Schermopname van de pagina Een opslagaccount maken.

  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.

    Schermopname van het menu Container toevoegen op de pagina Containers.

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

    Schermopname van de pagina **Container toevoegen**.

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 Alle services in het linkermenu. Selecteer Analyse onder Categorieën. Beweeg de muisaanwijzer over Stream Analytics-taken en selecteer of selecteer + + Maken in het pop-upvenster.

    Schermopname van het menu Stream Analytics-taak.

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

      Schermopname van de pagina **Nieuwe Stream Analytics-taak**.

  4. Controleer de instellingen op de pagina Beoordelen en maken en selecteer Maken om een Stream Analytics-pagina te maken.

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

    Schermopname van de pagina **Invoer** met het menu **Stroominvoer toevoegen** > **IoT Hub** geselecteerd.**.

  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.

      Schermopname van de pagina Nieuwe invoer voor het invoeren van ioT-hubgegevens.

Taakuitvoer configureren

  1. Selecteer nu Uitvoer onder Taaktopologie in het linkermenu.

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

    Schermopname van de pagina **Outputs** met de optie **Add** -> **Blob Storage** geselecteerd in het 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 de verbindingsreeks.

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

      Schermopname van de pagina **Nieuwe uitvoer** om invoergegevens van het Azure-opslagaccount in te voeren.

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.

    Schermopname van de pagina **Query** met de voorbeeldquery.

Stream Analytics-taak starten en uitvoer controleren

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

    Schermopname van de pagina **Overzicht** met de knop **Start** geselecteerd.

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

    Schermopname van de pagina **Taak starten**.

  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.

    Schermopname van de pagina **Container** met het voorbeelduitvoerbestand.

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

    Schermopname van het voorbeelduitvoerbestand.

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.
  3. Selecteer in de Raspberry Pi Azure IoT Online Simulator-app Opnieuw instellen naast Uitvoeren in het onderste deelvenster aan de rechterkant.

Volgende stap

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