Utveckla Stream Analytics Edge-jobb med hjälp av Visual Studio-verktyg

I den här artikeln lär du dig hur du använder Stream Analytics-verktyg för Visual Studio för att skapa, felsöka och skapa Stream Analytics Edge-jobb. Efter att du skapat och testat jobbet går du till Azure-portalen för att distribuera det till dina enheter.

Förutsättningar för att utveckla Edge-jobb

Du behöver följande förutsättningar för att slutföra stegen i denna artikel:

  1. Installera Visual Studio 2019, Visual Studio 2015 eller Visual Studio 2013 Update 4. Stream Analytics-verktyg stödjer Enterprise (Ultimate/Premium), Professional och Community-versionerna, men inte Express-versionen.

  2. Följ installationsanvisningarna för att installera Stream Analytics-verktyg för Visual Studio.

Skapa ett Stream Analytics Edge-projekt

Skapa Edge-projektet som innehåller din jobbdefinition.

  1. Från Visual Studio, välj File>NewProject>. Gå till listan Mallar till vänster och expandera sedan Azure Stream Analytics>Stream Analytics Edge>Azure Stream Analytics Edge Application. Ange ett namn, plats och lösningsnamn för ditt projekt, och välj sedan OK.

    Skärmdump av dialogrutan New Project för att skapa en Azure Stream Analytics Edge-applikation i Visual Studio.

  2. Efter att Visual Studio har skapat projektet, gå till Prieskumník riešení för att se mapphierarkin.

    Skärmdump av Prieskumník riešení som visar mapphierarkin för ett Stream Analytics Edge-projekt i Visual Studio.

Välj rätt prenumeration

Koppla Visual Studio till Azure-prenumerationen där du vill skapa jobbet.

  1. Från din Visual Studio View-meny, välj Server Explorer.

  2. Välj och håll in (eller högerklicka) Azure, välj Connect to Microsoft Azure Subscription och logga sedan in med ditt Azure-konto.

Definiera indata

Konfigurera Edge Hub-ingången som jobbet läser strömmande händelser från.

  1. Från Prieskumník riešení, expandera Inputs-noden. Du ser en indata med namnet EdgeInput.json. Öppna den för att se inställningarna.

  2. Sätt källtypen till dataström. Sätt sedan Source till Edge Hub, Event Serialization Format till Json och kodning till UTF8. Valfritt, byt namn på Input Alias, men låt det vara som det är i detta exempel. Om du byter namn på indataaliaset, använd det namn du anger när du definierar frågan. Spara inställningarna genom att klicka på Spara. Skärmdump av Stream Analytics Edge Hubs inmatningskonfigurationsinställningar i Visual Studio.

Definiera utmatningar

Konfigurera Edge Hub-utdata som jobbet skriver resultat till.

  1. Från Prieskumník riešení, expandera Outputs-noden. Du ser en utdatafil med namnet EdgeOutput.json. Öppna den för att se inställningarna.

  2. Sätt Sink till Edge Hub, ställ Event Serialization Format till Json, ställ Encoding till UTF8 och ställ Format till Array. Valfritt, byt namn på Output Alias, men låt det vara som det är i detta exempel. Om du byter namn på utdataaliaset, använd det namn du anger när du definierar frågan. Spara inställningarna genom att klicka på Spara. Skärmdump av Stream Analytics Edge Hubs utdatakonfigurationsinställningar i Visual Studio.

Granska ostödda operationer

Stream Analytics-jobb som implementeras i Stream Analytics IoT Edge-miljöerna stöder de flesta referenserna för Stream Analytics Query Language. Följande operationer stöds dock inte för Stream Analytics Edge-jobb:

  1. PARTITION EFTER
  2. Tidsstämpel över
  3. JavaScript UDF
  4. Användardefinierade aggregerade (UDA)
  5. GetMetadataPropertyValue
  6. Att använda mer än 14 aggregat i ett enda steg

När du skapar ett Stream Analytics Edge-jobb i portalen varnar kompilatorn dig automatiskt om du inte använder en stödd operatör.

Definiera transformationsfrågan

Från Visual Studio, definiera följande transformationsfråga i frågeredigeraren (filenscript.asaql).

SELECT * INTO EdgeOutput
FROM EdgeInput 

Testa jobbet lokalt

För att testa frågan lokalt, ladda upp exempeldatan. För att få exempeldata, ladda ner registreringsdata från GitHub-arkivet och spara dem på din lokala dator.

  1. För att ladda upp exempeldata, välj och håll (eller högerklicka) EdgeInput.json-filen och välj sedan Lägg till lokal inmatning.

  2. I popup-fönstret, bläddra bland exempeldata från din lokala sökväg och välj Spara.

    Skärmdump av den lokala inmatningskonfigurationen för uppladdning av exempeldata i Visual Studio.

  3. Visual Studio lägger automatiskt till en fil som heterlocal_EdgeInput.json i din inmatningsmapp.

  4. Du kan antingen köra det lokalt eller skicka in det till Azure. För att testa frågan, välj Kör lokalt.

    Skärmdump av alternativen för Stream Analytics-jobbkörning som visar Kör lokalt i Visual Studio.

  5. Kommandopromptfönstret visar statusen för jobbet. När jobbet körs framgångsrikt skapar det en mapp som ser ut som 2018-02-23-11-31-42 i din projektmappsväg Visual Studio 2015\Projects\MyASAEdgejob\MyASAEdgejob\ASALocalRun\2018-02-23-11-31-42. Gå till mappens sökväg för att se resultaten i den lokala mappen.

    Du kan också logga in på Azure-portalen och verifiera att jobbet är skapat.

    Skärmdump av Stream Analytics-jobbresultatmappen som visar lokal körutdata i Visual Studio.

Skicka in jobbet till Azure

Efter att du testat frågan, publicera jobbet till din Azure-prenumeration.

  1. Innan du skickar in jobbet till Azure, koppla till din Azure-prenumeration. Öppna Server Explorer, välj och håll in (eller högerklicka) Azure, välj Connect to Microsoft Azure-prenumeration och logga sedan in på din Azure-prenumeration.

  2. För att skicka in jobbet till Azure, gå till frågeeditorn och välj Skicka till Azure.

  3. Ett popup-fönster öppnas. Välj att uppdatera ett befintligt Stream Analytics Edge-jobb eller skapa ett nytt. När du uppdaterar ett befintligt jobb ersätts all jobbkonfiguration. I detta scenario publicerar du ett nytt jobb. Välj Create a New Azure Stream Analytics Job, ange ett namn för ditt jobb som MyASAEdgeJob, välj den nödvändiga prenumerationen, resursgruppen och platsen, och välj sedan Submit.

    Skärmdump av dialogrutan för att skicka in ett Stream Analytics Edge-jobb till Azure från Visual Studio.

    Du har nu ett jobb på Stream Analytics Edge. Mer information om hur du distribuerar det till dina enheter finns i Kör jobb på IoT Edge.

Hantera jobbet

Hantera jobbstatusen och jobbdiagrammet från Server Explorer.

  1. Från Stream Analytics i Server Explorer expanderar du prenumerationen och resursgruppen där du implementerade Stream Analytics Edge-jobbet. Du ser MyASAEdgejob med statusen Skapad. Expandera din jobbnod och öppna den sedan för att visa jobbet.

    Skärmdump av Server Explorer som visar jobbhanteringsalternativ för ett Stream Analytics Edge-jobb.

  2. I jobbvyfönstret kan du uppdatera jobbet, ta bort det och öppna det i Azure-portalen.

    Skärmdump av jobbvyfönstret som visar jobbdiagrammet och andra alternativ i Visual Studio.