Bearbeta data från din händelsehubb med Azure Stream Analytics
Tjänsten Azure Stream Analytics gör det enkelt att mata in, bearbeta och analysera strömmande data från Azure Event Hubs, vilket ger kraftfulla insikter för att driva realtidsåtgärder. Med den här integreringen kan du snabbt skapa en analyspipeline med heta sökvägar. Du kan använda Azure Portal för att visualisera inkommande data och skriva en Stream Analytics fråga. När frågan är klar kan du flytta den till produktion med bara några klick.
Viktiga fördelar
Här är de viktigaste fördelarna med Azure Event Hubs och Azure Stream Analytics integrering:
- Förhandsgranska data – Du kan förhandsgranska inkommande data från en händelsehubb i Azure Portal.
- Testa frågan – Förbered en transformeringsfråga och testa den direkt i Azure Portal. Syntaxen för frågespråket finns i Stream Analytics Query Language.
- Distribuera din fråga till produktion – Du kan distribuera frågan till produktion genom att skapa och starta ett Azure Stream Analytics jobb.
Flöde från end-to-end
Logga in på Azure-portalen.
Navigera till ditt Event Hubs och navigera sedan till händelsehubben, som innehåller inkommande data.
Välj Bearbeta data på händelsehubbens sida.
Välj Utforska på panelen Aktivera insikter i realtid från händelser.
Du ser en frågesida med värden som redan har angetts för följande fält:
Din händelsehubb som indata för frågan.
Exempel SQL fråga med SELECT-instruktion.
Ett utdataalias som refererar till dina frågetestresultat.
Anteckning
När du använder den här funktionen för första gången frågar den här sidan om din tillåtelse att skapa en konsumentgrupp och en princip för din händelsehubb för att förhandsgranska inkommande data.
Välj Skapa i fönstret Förhandsgranskning av indata enligt föregående bild.
Du ser omedelbart en ögonblicksbild av de senaste inkommande data på den här fliken.
Serialiseringstypen i dina data identifieras automatiskt (JSON/CSV). Du kan även ändra det manuellt till JSON/CSV/AVRO.
Du kan förhandsgranska inkommande data i tabellformat eller rådataformat.
Om dina data som visas inte är aktuella väljer du Uppdatera för att se de senaste händelserna.
Här är ett exempel på data i tabellformat:
Här är ett exempel på data i rådataformat:
Välj Testfråga för att se ögonblicksbilden av testresultaten för frågan på fliken Testresultat. Du kan också ladda ned resultatet.
Skriv en egen fråga för att transformera data. Se Stream Analytics Query Language.
När du har testat frågan och vill flytta den till produktion väljer du Distribuera fråga. Distribuera frågan genom att skapa ett Azure Stream Analytics där du kan ange utdata för jobbet och starta jobbet. Om du vill Stream Analytics ett jobb anger du ett namn för jobbet och väljer Skapa.
Anteckning
Vi rekommenderar att du skapar en konsumentgrupp och en princip för varje nytt Azure Stream Analytics jobb som du skapar från Event Hubs sidan. Konsumentgrupper tillåter endast fem samtidiga läsare, så om du tillhandahåller en dedikerad konsumentgrupp för varje jobb undviker du eventuella fel som kan uppstå när gränsen överskrids. Med en dedikerad princip kan du rotera nyckeln eller återkalla behörigheter utan att påverka andra resurser.
Nu Stream Analytics jobbet där frågan är samma som du testade och där indata är din händelsehubb.
Slutför pipelinen genom att ange utdata för frågan och välja Starta för att starta jobbet.
Anteckning
Innan du startar jobbet ska du inte glömma att ersätta outputalias med det utdatanamn som du skapade i Azure Stream Analytics.
Kända begränsningar
När du testar frågan tar det cirka 6 sekunder att läsa in testresultaten. Vi arbetar på att förbättra testningens prestanda. När de distribueras i produktion Azure Stream Analytics dock en svarstid på undersekunder.
Strömningsenheter
Ditt Azure Stream Analytics som standard tre enheter för strömning (SUS). Om du vill justera den här inställningen väljer du Skala på den vänstra Stream Analytics på sidan för Azure Portal. Mer information om strömningsenheter finns i Förstå och justera strömningsenheter.
Nästa steg
Mer information om Stream Analytics finns i Stream Analytics Query Language