Använda Azure Stream Analytics-redigeraren utan kod för att transformera och lagra data i Azure SQL databas

Artikel
06/14/2023

Den här artikeln beskriver hur du kan använda kodredigeraren utan kod för att enkelt skapa ett Stream Analytics-jobb, som kontinuerligt läser data från en Event Hubs-instans (händelsehubb), transformerar data och sedan skriver resultat till en Azure SQL databas.

Förutsättningar

Dina Azure Event Hubs- och Azure SQL Database-resurser måste vara offentligt tillgängliga och inte vara bakom en brandvägg eller skyddas i en Azure-Virtual Network. Data i dina Event Hubs måste serialiseras i antingen JSON-, CSV- eller Avro-format.

Följ dessa steg om du vill prova stegen i den här artikeln.

Skapa en händelsehubb om du inte redan har en. Generera data i händelsehubben. På sidan Event Hubs-instans väljer du Generera data (förhandsversion) på den vänstra menyn, väljer Lagerdata för Datauppsättning och väljer sedan Skicka för att skicka exempeldata till händelsehubben. Det här steget krävs om du vill testa stegen i den här artikeln.
Skapa en Azure SQL databas. Här är några viktiga punkter att tänka på när du skapar databasen.
1. På sidan Grundläggande väljer du Skapa ny för server. På sidan Skapa SQL Database server väljer du Sedan Använd SQL-autentisering och anger administratörsanvändar-ID och lösenord.
2. Följ dessa steg på sidan Nätverk :
  1. Aktivera offentlig slutpunkt.
  2. Välj Ja för Tillåt att Azure-tjänster och resurser får åtkomst till den här servern.
  3. Välj Ja för Lägg till aktuell klient-IP-adress.
3. På sidan Ytterligare inställningar väljer du Ingen för Använd befintliga data.
4. I artikeln hoppar du över stegen i avsnitten Fråga databasen och Rensa resurser .
5. Om du vill testa steg skapar du en tabell i SQL-databasen med hjälp av frågeredigeraren (förhandsversion).
```
create table stocks (
    symbol varchar(4),
    price decimal
)
```

Skapa ett Stream Analytics-jobb med redigeringsprogrammet utan kod

I det här avsnittet skapar du ett Azure Stream Analytics-jobb med redigeringsprogrammet utan kod. Jobbet transformerar dataströmning från en Event Hubs-instans (händelsehubb) och lagrar resultatdata i en Azure SQL databas.

I Azure Portal går du till sidan Event Hubs-instans för din händelsehubb.
Välj Funktioner>Bearbeta data på den vänstra menyn och välj sedan Starta på kortet Transformera och lagra data till SQL-databas .
Ange ett namn för Stream Analytics-jobbet och välj sedan Skapa. Du ser Stream Analytics-jobbdiagrammet med Event Hubs-fönstret till höger.
I fönstret Händelsehubb granskar du inställningarna för serialiserings- och autentiseringsläge och väljer Anslut.
När anslutningen har upprättats och du har data i din Event Hubs-instans ser du två saker:
- Fält som finns i indata. Du kan välja Lägg till fält eller välja symbolen med tre punkter bredvid ett fält för att ta bort, byta namn på eller ändra dess typ.
- Ett live-exempel på inkommande data i tabellen Dataförhandsgranskning under diagramvyn. Den uppdateras automatiskt med jämna mellanrum. Du kan välja Pausa förhandsversionen av direktuppspelning för att se en statisk vy över exempeldata.
Välj panelen Gruppera efter för att aggregera data. I panelen Gruppera efter konfiguration kan du ange det fält som du vill gruppera efter tillsammans med tidsfönstret.

I följande exempel används medelvärdet av pris och symbol .
Du kan verifiera resultatet av steget i avsnittet Dataförhandsgranskning .
Välj panelen Hantera fält . I konfigurationspanelen Hantera fält väljer du de fält som du vill mata ut genom att välja Fältet Lägg till ->Importerat schema –> fält.

Om du vill lägga till alla fält väljer du Lägg till alla fält. När du lägger till ett fält kan du ange ett annat namn för utdata. Till exempel AVG_Value till Value. När du har sparat valen visas data i fönstret Dataförhandsgranskning .

I följande exempel väljs Symbol och AVG_Value . Symbolen mappas till symbolen och AVG_Value mappas till pris.
Välj SQL-panel . I SQL Database konfigurationspanelen fyller du i nödvändiga parametrar och ansluter. Välj Läs in befintlig tabell så att tabellen väljs automatiskt. I följande exempel [dbo].[stocks] väljs. Välj sedan Anslut.

Anteckning

Schemat för den tabell som du väljer att skriva måste exakt matcha antalet fält och deras typer som din dataförhandsgranskning genererar.
I fönstret Dataförhandsgranskning visas den dataförhandsgranskning som matas in i SQL-databasen.
Välj Spara och välj sedan Starta Stream Analytics-jobbet.
Om du vill starta jobbet anger du:
- Antalet enheter för direktuppspelning (SUS) som jobbet körs med. SUs representerar mängden beräkning och minne som allokerats till jobbet. Vi rekommenderar att du börjar med tre och sedan justerar efter behov.
- Hantering av utdatafel – Det gör att du kan ange vilket beteende du vill när ett jobbs utdata till målet misslyckas på grund av datafel. Som standard försöker jobbet igen tills skrivåtgärden lyckas. Du kan också välja att ta bort sådana utdatahändelser.
När du har valt Start börjar jobbet köras inom två minuter. Du ser måttpanelen i den nedre rutan öppen. Det tar någon gång innan panelen uppdateras. Välj Uppdatera i det övre högra hörnet på panelen för att uppdatera diagrammet. Gå vidare till nästa steg i en separat flik eller ett separat fönster i webbläsaren.

Du kan också se jobbet under avsnittet Processdata på fliken Stream Analytics-jobb . Välj Öppna mått för att övervaka det eller stoppa och starta om det efter behov.
Gå till din händelsehubb i portalen i ett separat webbläsarfönster eller en separat flik och skicka exempellagerdata igen (som du gjorde i förutsättningarna). På sidan Event Hubs-instans väljer du Generera data (förhandsversion) på den vänstra menyn, väljer Lagerdata för Datauppsättning och väljer sedan Skicka för att skicka exempeldata till händelsehubben. Det tar några minuter att se panelen Mått uppdaterad.
Du bör se poster som infogats i Azure SQL-databasen.