Polystaket och geospatiala agg regerings scenarier med Azure Stream Analytics

Med inbyggda geospatiala funktioner kan du använda Azure Stream Analytics för att skapa program för scenarier som hantering av flottan, delning av delning, anslutna bilar och till gångs spårning.

Geofencing

Azure Stream Analytics stöder real tids beräkningar i real tid i molnet och på IoT Edge Runtime.

Scenario för polystaket

Ett tillverknings företag måste spåra till gångar på sina byggnader. De förser varje enhet med en GPS och vill ta emot meddelanden om en enhet lämnar ett visst utrymme.

Referens data som används i det här exemplet har avgränsnings information för byggnader och de enheter som tillåts i varje byggnad. Kom ihåg att referens data kan vara antingen statiska eller långsamma att ändra. Statiska referens data används för det här scenariot. En data ström genererar kontinuerligt enhets-ID och dess aktuella position.

Definiera avgränsningar i referens data

Ett geografiskt avgränsnings tecken kan definieras med hjälp av ett geografiskt JSON-objekt. För jobb med kompatibilitet version 1,2 och högre kan även avgränsningar definieras med välkänd text (well) som NVARCHAR(MAX) . WELL är en Open Geospatial Consortium (OGC) standard som används för att representera spatialdata i ett text format.

De inbyggda geospatiala funktionerna kan använda definierade gränser för att ta reda på om ett element ligger inom eller ut ur en viss kors avgränsnings polygon.

Följande tabell är ett exempel på referens data som kan lagras i Azure Blob Storage eller en Azure SQL-tabell. Varje plats representeras av en Geospatial polygon och varje enhet är associerad med ett tillåtet plats-ID.

Generera aviseringar med en avgränsning

Enheter kan generera sitt ID och sin plats varje minut genom en data ström som kallas DeviceStreamInput . Följande tabell är en Stream med indata.

Du kan skriva en fråga som ansluter enhets strömmen med referens data för avgränsning och genererar en avisering varje gång en enhet är utanför en tillåten byggnad.

SELECT DeviceStreamInput.DeviceID, SiteReferenceInput.SiteID, SiteReferenceInput.SiteName 
INTO Output
FROM DeviceStreamInput 
JOIN SiteReferenceInput
ON st_within(DeviceStreamInput.GeoPosition, SiteReferenceInput.Geofence) = 0
WHERE DeviceStreamInput.DeviceID = SiteReferenceInput.AllowedDeviceID

Följande bild representerar de båda gränserna. Du kan se var enheterna är i överensstämmelse med strömmens data indata.

Enheten "C" finns inuti Byggnads-ID 2, vilket inte tillåts enligt referens data. Den här enheten bör finnas i Byggnads-ID 3. Om du kör det här jobbet skapas en avisering för denna överträdelse.

Webbplats med flera tillåtna enheter

Om en plats tillåter flera enheter kan en matris med enhets-ID: n definieras i AllowedDeviceID och en User-Defined funktion kan användas i WHERE -satsen för att kontrol lera om ström enhets-ID: t matchar alla enhets-ID: n i listan. Mer information finns i själv studie kursen om JavaScript-skript för moln jobb och C# UDF -självstudie för Edge-jobb.

Geospatial agg regering

Azure Stream Analytics stöder geospatiala geospatiala agg regeringar i real tid i molnet och på IoT Edge Runtime.

Geospatialt samlings scenario

Ett CAB-företag vill bygga ett real tids program för att vägleda sina CAB-drivrutiner som söker efter att gå till de områden i städerna som för närvarande har högre efter frågan.

Företaget lagrar logiska regioner i staden som referens data. Varje region definieras av ett RegionID, RegionName och ett geografiskt avgränsnings tecken.

Definiera de gränser

Följande tabell är ett exempel på referens data som kan lagras i Azure Blob Storage eller en Azure SQL-tabell. Varje region representeras av en Geospatial polygon, som används för att korrelera med de begär Anden som kommer från strömmande data.

Dessa polygoner är endast till för referens och representerar inte faktiska logiska eller fysiska avgränsningar för stad.

Samla data över en tids period

Följande tabell innehåller strömmande data för "Overrides".

Följande fråga ansluter enhets strömmen med referens data för avgränsning och beräknar antalet förfrågningar per region i ett tids period på 15 minuter varje minut.

SELECT count(*) as NumberOfRequests, RegionsRefDataInput.RegionName 
FROM UserRequestStreamDataInput
JOIN RegionsRefDataInput 
ON st_within(UserRequestStreamDataInput.FromLocation, RegionsRefDataInput.Geofence) = 1
GROUP BY RegionsRefDataInput.RegionName, hoppingwindow(minute, 1, 15)

Den här frågan utvärderar antalet begär Anden varje minut under de senaste 15 minuterna per region i staden. Den här informationen kan enkelt visas på Power BI instrument panel eller skickas till alla driv rutiner som SMS-textmeddelanden via integrering med tjänster som Azure Functions.

Bilden nedan visar utdata från frågan för att Power BI instrument panelen.

Nästa steg

• Introduktion till Stream Analytics geospatiala funktioner
• GeoSpatiala funktioner (Azure Stream Analytics)