Bearbeta data från din händelsehubb med Hjälp av Azure Stream Analytics

Azure Stream Analytics-tjänsten gör det enkelt att mata in, bearbeta och analysera strömmande data från Azure Event Hubs, vilket möjliggör kraftfulla insikter för att driva realtidsåtgärder. 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 få 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. Frågespråksyntaxen finns i Dokumentation om Frågespråk för Stream Analytics .
• Distribuera frågan till produktion – Du kan distribuera frågan till produktion genom att skapa och starta ett Azure Stream Analytics-jobb.

Flöde från slutpunkt till slutpunkt

Viktigt

Om du inte är medlem i ägar- eller deltagarroller på Azure-prenumerationsnivå måste du vara medlem i Stream Analytics Query Tester-rollen på Azure-prenumerationsnivå för att slutföra stegen i det här avsnittet. Med den här rollen kan du utföra testfrågor utan att skapa ett stream analytics-jobb först. Anvisningar om hur du tilldelar en roll till en användare finns i Tilldela AD-roller till användare.

1. Logga in på Azure-portalen.

2. Navigera till Event Hubs-namnområdet och navigera sedan till händelsehubben, som har inkommande data.

3. Välj Bearbeta data på händelsehubbens sida eller välj Bearbeta data på den vänstra menyn.

   

4. Välj Starta på panelen Aktivera realtidsinsikter från händelser .

   

5. Du ser en frågesida med värden som redan har angetts för följande fält:

   1. Din händelsehubb som indata för frågan.

   2. Exempel på SQL-fråga med SELECT-instruktion.

   3. Ett utdataalias som refererar till dina frågetestresultat.

      

      Anteckning

      När du använder den här funktionen för första gången ber den här sidan om din behörighet att skapa en konsumentgrupp och en princip för händelsehubben för att förhandsgranska inkommande data.

6. Välj Skapa i fönstret Indataförhandsgranskning enligt föregående bild.

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

     

8. Välj Testa fråga för att se ögonblicksbilden av testresultatet för frågan på fliken Testresultat . Du kan också ladda ned resultaten.

   

9. Skriv en egen fråga för att transformera data. Se Referens för Stream Analytics-frågespråk.

10. När du har testat frågan och vill flytta den till produktion väljer du Skapa Stream Analytics-jobb.

    

11. Följ dessa steg på sidan Nytt Stream Analytics-jobb :

    1. Ange ett namn för jobbet.

    2. Välj din Azure-prenumeration där du vill att jobbet ska skapas.

    3. Välj resursgruppen för Stream Analytics-jobbresursen.

    4. Välj platsen för jobbet.

    5. För händelsehubbens principnamn skapar du en ny princip eller väljer en befintlig.

    6. För Event Hubs-konsumentgruppen skapar du en ny konsumentgrupp eller väljer en befintlig konsumentgrupp.

    7. Välj Skapa för att skapa Stream Analytics-jobbet.

       

       Anteckning

       Vi rekommenderar att du skapar en konsumentgrupp och en princip för varje nytt Azure Stream Analytics-jobb som du skapar från sidan Event Hubs. 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 din nyckel eller återkalla behörigheter utan att påverka andra resurser.

12. Stream Analytics-jobbet skapas nu där frågan är densamma som du testade och indata är din händelsehubb.

    

13. Lägg till valfria utdata .

14. Gå tillbaka till Stream Analytics-jobbsidan genom att klicka på namnet på jobbet i länken breadcrumb.

15. Välj Redigera fråga ovanför frågefönstret .

16. Uppdatera [OutputAlias] med utdatanamnet och välj Länken Spara fråga ovanför frågan. Stäng sidan Fråga genom att välja X i det övre högra hörnet.

17. På sidan Stream Analytics-jobb väljer du Starta i verktygsfältet för att starta jobbet.

    

Access

Problem : Användaren kan inte komma åt förhandsgranskningsdata eftersom de inte har rätt behörigheter för prenumerationen.

Alternativ 1: Den användare som vill förhandsgranska inkommande data måste läggas till som deltagare i prenumerationen.

Alternativ 2: Användaren måste läggas till som Stream Analytics Query-testarroll i prenumerationen. Gå till Åtkomstkontroll för prenumerationen. Lägg till en ny rolltilldelning för användaren som rollen "Stream Analytics Query Tester".

Alternativ 3: Användaren kan skapa Azure Stream Analytics-jobb. Ange indata som den här händelsehubben och gå till "Fråga" för att förhandsgranska inkommande data från den här händelsehubben.

Alternativ 4: Administratören kan skapa en anpassad roll för prenumerationen. Lägg till följande behörigheter i den anpassade rollen och lägg sedan till användaren i den nya anpassade rollen.

Strömningsenheter

Ditt Azure Stream Analytics-jobb är som standard tre strömningsenheter (SUS). Om du vill justera den här inställningen väljer du Skala på den vänstra menyn på Stream Analytics-jobbsidan i Azure Portal. Mer information om strömningsenheter finns i Förstå och justera enheter för direktuppspelning.

Nästa steg

Mer information om Stream Analytics-frågor finns i Stream Analytics Query Language