Gegevens van uw Event Hub verwerken met behulp van Azure Stream Analytics
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 kunnen worden gebruikt om realtime-acties uit te voeren. Met deze integratie kunt u snel een hot-path-analysepijplijn maken. U kunt de Azure Portal gebruiken om binnenkomende gegevens te visualiseren en een query Stream Analytics schrijven. Zodra uw query gereed is, kunt u deze in slechts enkele klikken naar productie verplaatsen.
Belangrijkste voordelen
Dit zijn de belangrijkste voordelen van Azure Event Hubs en Azure Stream Analytics integratie:
- Voorbeeld van gegevens: 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 querytaaldocumentatie voor Stream Analytics querytaal voor de syntaxis van de querytaal.
- Uw query implementeren in productie: u kunt de query in productie implementeren door een nieuwe Azure Stream Analytics starten.
End-to-end-stroom
Meld u aan bij de Azure-portal.
Navigeer naar Event Hubs naamruimte en navigeer vervolgens naar de Event Hub, die de binnenkomende gegevens heeft.
Selecteer Gegevens verwerken op de pagina Event Hub.
Selecteer Verkennen op de tegel Realtime inzichten inschakelen op basis van gebeurtenissen.
U ziet een querypagina met waarden die al zijn ingesteld voor de volgende velden:
Uw Event Hub als invoer voor de query.
Voorbeeld van SQL query met select-instructie.
Een uitvoeralias om te verwijzen naar de resultaten van uw querytest.
Notitie
Wanneer u deze functie voor het eerst gebruikt, vraagt deze pagina om uw toestemming om een consumentengroep en een beleid voor uw Event Hub te maken om een voorbeeld van binnenkomende gegevens te bekijken.
Selecteer Maken in het deelvenster Voorbeeld van invoer, zoals wordt weergegeven in de voorgaande afbeelding.
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 bekijken van binnenkomende gegevens in de tabelindeling of onbewerkte indeling.
Als uw weergegeven gegevens niet actueel zijn, selecteert u Vernieuwen om de meest recente gebeurtenissen weer te geven.
Hier is een voorbeeld van gegevens in de tabelindeling:
Hier is een voorbeeld van gegevens in de onbewerkte indeling:
Selecteer Testquery om de momentopname van de testresultaten van uw query weer te geven op het tabblad Testresultaten. U kunt ook de resultaten downloaden.
Schrijf uw eigen query om de gegevens te transformeren. Zie Stream Analytics Query Language reference (Naslag voor querytaal).
Nadat u de query hebt getest en u deze naar productie wilt verplaatsen, selecteert u Query implementeren. Als u de query wilt implementeren, maakt Azure Stream Analytics taak waarin u uitvoer voor uw taak kunt instellen en de taak kunt starten. Als u een Stream Analytics wilt maken, geeft u een naam op voor de taak en selecteert u Maken.
Notitie
U wordt aangeraden een consumentengroep en beleid te maken voor elke nieuwe Azure Stream Analytics die u maakt op de Event Hubs pagina. Consumentengroepen staan slechts vijf gelijktijdige lezers toe, dus als u een specifieke consumentengroep voor elke taak biedt, voorkomt u fouten die het gevolg kunnen zijn van het overschrijden van die limiet. Met een toegewezen beleid kunt u uw sleutel roteren of machtigingen intrekken zonder dat dit van invloed is op andere resources.
Uw Stream Analytics taak is nu gemaakt, waarbij uw query dezelfde is die u hebt getest en invoer uw Event Hub is.
Als u de pijplijn wilt voltooien, stelt u de uitvoer van de query in en selecteert u Starten om de taak te starten.
Notitie
Vergeet niet om de uitvoeralias te vervangen door de uitvoernaam die u hebt gemaakt in Azure Stream Analytics voordat u de taak start.
Bekende beperkingen
Tijdens het testen van uw query duurt het ongeveer 6 seconden om de testresultaten te laden. We werken aan het verbeteren van de prestaties van het testen. Wanneer de machine echter in productie wordt geïmplementeerd, Azure Stream Analytics een latentie van minder dan een seconde.
Streaming-eenheden
Uw Azure Stream Analytics wordt standaard ingesteld op drie streaming-eenheden (SUS's). Als u deze instelling wilt aanpassen, selecteert u Schalen in het menu links op Stream Analytics taakpagina in de Azure Portal. Zie Streaming-eenheden begrijpen en aanpassen voor meer informatie over streaming-eenheden.
Volgende stappen
Zie querytaal voor Stream Analytics meer informatie over Stream Analytics query's