Gegevens uit uw Event Hub verwerken met behulp van Azure Stream Analytics

  • Artikel

De Azure Stream Analytics-service maakt het eenvoudig om streaminggegevens van Azure Event Hubs op te nemen, te verwerken en te analyseren, waardoor krachtige inzichten mogelijk zijn om realtime acties te stimuleren. U kunt de Azure Portal gebruiken om binnenkomende gegevens te visualiseren en een Stream Analytics-query te schrijven. Zodra uw query klaar is, kunt u deze met slechts een paar klikken naar productie verplaatsen.

Belangrijkste voordelen

Dit zijn de belangrijkste voordelen van de integratie van Azure Event Hubs en Azure Stream Analytics:

  • Voorbeeld van gegevens bekijken: u kunt een voorbeeld bekijken van binnenkomende gegevens van een Event Hub in de Azure Portal.
  • Uw query testen: bereid een transformatiequery voor en test deze rechtstreeks in de Azure Portal. Zie de documentatie voor Stream Analytics Query Language voor de syntaxis van de querytaal.
  • Uw query implementeren in productie : u kunt de query in productie implementeren door een Azure Stream Analytics-taak te maken en te starten.

End-to-end-stroom

Belangrijk

Als u geen lid bent van de rol Eigenaar of Inzender op het niveau van het Azure-abonnement, moet u lid zijn van de stream analytics-querytesterrol op het niveau van het Azure-abonnement om de stappen in deze sectie te voltooien. Met deze rol kunt u testquery's uitvoeren zonder eerst een Stream Analytics-taak te maken. Zie AD-rollen toewijzen aan gebruikers voor instructies over het toewijzen van een rol aan een gebruiker.

  1. Meld u aan bij de Azure-portal.

  2. Navigeer naar uw Event Hubs-naamruimte en navigeer vervolgens naar de Event Hub, die de inkomende gegevens bevat.

  3. Selecteer Procesgegevens op de event hub-pagina of selecteer Gegevens verwerken in het menu aan de linkerkant.

    Schermopname van de pagina Gegevens verwerken voor de Event Hub.

  4. Selecteer Start op de tegel Realtime inzichten van gebeurtenissen inschakelen .

    Schermopname van de pagina Gegevens verwerken met de tegel Realtime-inzichten van gebeurtenissen inschakelen geselecteerd.

  5. U ziet een querypagina met waarden die al zijn ingesteld voor de volgende velden:

    1. Uw Event Hub als invoer voor de query.

    2. Sql-voorbeeldquery met SELECT-instructie.

    3. Een uitvoeralias die verwijst naar de resultaten van uw querytest.

      Schermopname van de Query-editor voor uw Stream Analytics-query.

      Notitie

      Wanneer u deze functie voor het eerst gebruikt, vraagt deze pagina om uw toestemming om een consumentengroep te maken en een beleid voor uw Event Hub om een voorbeeld van binnenkomende gegevens te bekijken.

  6. Selecteer Maken in het voorbeeldvenster Invoer , zoals wordt weergegeven in de voorgaande afbeelding.

  7. Op dit tabblad ziet u onmiddellijk een momentopname van de meest recente binnenkomende gegevens.

    • Het serialisatietype in uw gegevens wordt automatisch gedetecteerd (JSON/CSV). U kunt deze ook handmatig wijzigen in JSON/CSV/AVRO.

    • U kunt een voorbeeld van binnenkomende gegevens bekijken in de tabelindeling of onbewerkte indeling.

    • Als de weergegeven gegevens niet actueel zijn, selecteert u Vernieuwen om de meest recente gebeurtenissen weer te geven.

      Hier volgt een voorbeeld van gegevens in de tabelindeling:

      Schermopname van het voorbeeldvenster Invoer in het resultaatvenster van de pagina Gegevens verwerken in een tabelindeling.

      Hier volgt een voorbeeld van gegevens in de onbewerkte indeling:

      Schermopname van het voorbeeldvenster Invoer in het resultaatvenster van de pagina Gegevens verwerken in de onbewerkte indeling.

  8. Selecteer Testquery om de momentopname van de testresultaten van uw query weer te geven op het tabblad Testresultaten . U kunt de resultaten ook downloaden.

    Schermopname van het voorbeeldvenster Invoer in het resultaatvenster met testresultaten.

  9. Schrijf uw eigen query om de gegevens te transformeren. Zie Naslaginformatie voor Stream Analytics-querytaal.

  10. Nadat u de query hebt getest en u deze naar productie wilt verplaatsen, selecteert u Stream Analytics-taak maken.

    Schermopname van de pagina Query met de koppeling Stream Analytics-taak maken geselecteerd.

  11. Voer op de pagina Nieuwe Stream Analytics-taak de volgende stappen uit:

    1. Geef een naam op voor de taak.

    2. Selecteer uw Azure-abonnement waarin u de taak wilt maken.

    3. Selecteer de resourcegroep voor de Stream Analytics-taakresource.

    4. Selecteer de locatie voor de taak.

    5. Maak voor de naam van het Event Hubs-beleid een nieuw beleid of selecteer een bestaand beleid.

    6. Maak voor de Event Hubs-consumentengroep een nieuwe consumentengroep of selecteer een bestaande consumentengroep.

    7. Selecteer Maken om de Stream Analytics-taak te maken.

      Schermopname van het venster Nieuwe Stream Analytics-taak.

      Notitie

      U wordt aangeraden een consumentengroep en een beleid te maken voor elke nieuwe Azure Stream Analytics-taak die u maakt op de pagina Event Hubs. Consumentengroepen staan slechts vijf gelijktijdige lezers toe, dus als u voor elke taak een toegewezen consumentengroep biedt, voorkomt u fouten die kunnen optreden als u deze limiet overschrijdt. Met een toegewezen beleid kunt u uw sleutel roteren of machtigingen intrekken zonder dat dit van invloed is op andere resources.

  12. Uw Stream Analytics-taak wordt nu gemaakt waarbij uw query dezelfde is die u hebt getest en invoer uw Event Hub is.

    Schermopname van de stream analytics-taakpagina met een koppeling om uitvoer toe te voegen.

  13. Voeg een uitvoer van uw keuze toe.

  14. Ga terug naar de stream analytics-taakpagina door op de naam van de taak in de breadcrumb-koppeling te klikken.

  15. Selecteer Query bewerken boven het venster Query .

  16. Werk bij [OutputAlias] met de naam van uw uitvoer en selecteer De koppeling Query opslaan boven de query. Sluit de pagina Query door X te selecteren in de rechterbovenhoek.

  17. Selecteer nu op de pagina Stream Analytics-taak de optie Start op de werkbalk om de taak te starten.

    Schermopname van het venster Taak starten voor een Stream Analytics-taak.

Access

Probleem : gebruikers hebben geen toegang tot preview-gegevens omdat ze niet de juiste machtigingen hebben voor het abonnement.

Optie 1: De gebruiker die een voorbeeld van binnenkomende gegevens wil bekijken, moet worden toegevoegd als inzender voor het abonnement.

Optie 2: De gebruiker moet worden toegevoegd als stream analytics-testerrol voor query's in het abonnement. Navigeer naar Toegangsbeheer voor het abonnement. Voeg een nieuwe roltoewijzing voor de gebruiker toe als de rol Stream Analytics-querytester.

Optie 3: De gebruiker kan een Azure Stream Analytics-taak maken. Stel invoer in als deze Event Hub en navigeer naar 'Query' om een voorbeeld van binnenkomende gegevens van deze Event Hub te bekijken.

Optie 4: De beheerder kan een aangepaste rol maken voor het abonnement. Voeg de volgende machtigingen toe aan de aangepaste rol en voeg vervolgens de gebruiker toe aan de nieuwe aangepaste rol.

Schermopnamen van de pagina Microsoft.StreamAnalytics-machtigingen.

Streaming-eenheden

Uw Azure Stream Analytics-taak is standaard ingesteld op drie streaming-eenheden (SUs). Als u deze instelling wilt aanpassen, selecteert u Schaal in het linkermenu op de pagina Stream Analytics-taak in de Azure Portal. Zie Streaming-eenheden begrijpen en aanpassen voor meer informatie over streaming-eenheden.

Schermopnamen met de pagina Schaal voor een Stream Analytics-taak.

Volgende stappen

Zie Stream Analytics-querytaal voor meer informatie over Stream Analytics-query's