Geoomheining en georuimtelijke aggregatie scenario's met Azure Stream Analytics

Met ingebouwde georuimtelijke functies kunt u Azure Stream Analytics gebruiken om toepassingen te ontwikkelen voor scenario's zoals vloot beheer, het delen van wijzigingen, verbonden auto's en het bijhouden van activa.

Geofencing

Azure Stream Analytics ondersteunt real-time latentie berekeningen in realtime in de Cloud en op de IoT Edge runtime.

Scenario met geoomheining

Een productie bedrijf moet activa op hun gebouwen volgen. Ze hebben elk apparaat voorzien van een GPS en willen meldingen ontvangen als een apparaat een bepaald gebied verlaat.

Referentie gegevens die in dit voor beeld worden gebruikt, hebben de geofence-informatie voor de gebouwen en de apparaten die in elk van de gebouwen zijn toegestaan. Houd er rekening mee dat referentie gegevens statisch of langzaam kunnen worden gewijzigd. Statische referentie gegevens worden gebruikt voor dit scenario. Een gegevens stroom verzendt voortdurend de apparaat-ID en de huidige positie.

Geofences definiëren in referentie gegevens

Een geofence kan worden gedefinieerd met behulp van een geojson-object. Voor taken met compatibiliteits versie 1,2 en hoger kunnen geofences ook worden gedefinieerd met behulp van bekende tekst (WKT) als NVARCHAR(MAX) . WKT is een Open Geospatial Consortium-standaard (OGC) die wordt gebruikt om ruimtelijke gegevens in een tekst indeling weer te geven.

De ingebouwde georuimtelijke functies kunnen gedefinieerde geofences gebruiken om erachter te komen of een element zich in of uit een specifieke geofence-veelhoek bevindt.

De volgende tabel is een voor beeld van geofence-referentie gegevens die kunnen worden opgeslagen in Azure Blob-opslag of een Azure SQL-tabel. Elke site wordt vertegenwoordigd door een georuimtelijke veelhoek en elk apparaat is gekoppeld aan een toegestane site-ID.

Waarschuwingen genereren met geofence

Apparaten kunnen hun ID en locatie elke minuut verzenden via een stroom met de naam DeviceStreamInput . De volgende tabel is een stroom van invoer.

U kunt een query schrijven die de stream van het apparaat koppelt aan de geofence-referentie gegevens en een waarschuwing genereert telkens wanneer een apparaat buiten het gebouw is dat is toegestaan.

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

De volgende afbeelding geeft de geofences. U kunt zien waar de apparaten zich bevinden in overeenstemming met de stroom gegevens invoer.

Het apparaat ' C ' bevindt zich in de gebouw-ID 2, maar dit is niet toegestaan volgens de referentie gegevens. Dit apparaat moet zich bevinden in gebouw-ID 3. Als u deze taak uitvoert, wordt er een waarschuwing gegenereerd voor deze specifieke schending.

Site met meerdere toegestane apparaten

Als een site meerdere apparaten toestaat, kan een matrix met apparaat-Id's worden gedefinieerd in AllowedDeviceID en een User-Defined-functie kan worden gebruikt in de WHERE component om te controleren of de apparaat-id van de stream overeenkomt met een apparaat-id in die lijst. Raadpleeg voor meer informatie de Java script UDF -zelf studie voor Cloud taken en de C#-zelf studie over de UDF voor Edge-taken.

Georuimtelijke aggregatie

Azure Stream Analytics ondersteunt in realtime georuimtelijke aggregatie in de Cloud en op de IoT Edge runtime.

Scenario voor georuimtelijke aggregatie

Een cab-bedrijf wil een realtime toepassing bouwen om hun cab-Stuur Programma's te begeleiden die op zoek zijn naar de gebieden van de steden die een hogere vraag ondervinden.

Het bedrijf slaat logische regio's van de stad op als referentie gegevens. Elke regio wordt gedefinieerd door een RegionID, regionaam en geofence.

De geofences definiëren

De volgende tabel is een voor beeld van geofence-referentie gegevens die kunnen worden opgeslagen in Azure Blob-opslag of een Azure SQL-tabel. Elke regio wordt vertegenwoordigd door een georuimtelijke veelhoek, die wordt gebruikt om te correleren met de aanvragen die afkomstig zijn van streaming-gegevens.

Deze veelhoeken zijn alleen ter referentie en vertegenwoordigen geen werkelijke plaats logische of fysieke schei dingen.

Verzamel gegevens over een tijd venster

De volgende tabel bevat streaming-gegevens van ' onderdrukkingen '.

Met de volgende query wordt de stroom van het apparaat toegevoegd aan de geofence-referentie gegevens en wordt het aantal aanvragen per regio in een tijd venster van 15 minuten elke minuut berekend.

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)

Met deze query wordt een aantal aanvragen per minuut voor de laatste 15 minuten uitgevoerd op elke regio binnen de stad. Deze informatie kan eenvoudig worden weer gegeven door Power BI dash board of kunnen worden verzonden naar alle Stuur Programma's als SMS-tekst berichten via integratie met services zoals Azure functions.

In de onderstaande afbeelding ziet u de uitvoer van de query naar Power BI dash board.

Volgende stappen

• Inleiding tot Stream Analytics georuimtelijke functies
• Georuimtelijke functies (Azure Stream Analytics)