Scénáře použití geografického a geoprostorového agregace pomocí Azure Stream Analytics

Pomocí integrovaných geoprostorových funkcí můžete použít Azure Stream Analytics k sestavování aplikací pro scénáře, jako je Správa loďstva, jízdní sdílení, připojená auta a sledování prostředků.

Geofencing (monitorování geografických zón)

Azure Stream Analytics podporuje výpočty geografických zón s nízkou latencí v reálném čase v cloudu a na IoT Edge runtime.

Scénář monitorování geografických zón

Výrobní společnost potřebuje sledovat prostředky ve svých budovách. Mají všechna zařízení s GPS a chtějí dostávat oznámení, když zařízení opustí určitou oblast.

Referenční data použitá v tomto příkladu obsahují informace o geografickém plotu pro budovy a zařízení, která jsou v každé z budov povolena. Pamatujte, že referenční data by mohla být statická nebo pomalá změna. V tomto scénáři se používají statická referenční data. Proud dat průběžně generuje ID zařízení a jeho aktuální pozici.

Definice geografických zón v referenčních datech

Geografické ohraničení lze definovat pomocí objektu geografické JSON. Pro úlohy s kompatibilitou verze 1,2 a vyšší lze geografické ploty definovat i pomocí známého textu (Well) jako NVARCHAR(MAX) . Well je standard pro Open Geospatial Consortium (OGC), který se používá k reprezentaci prostorových dat v textovém formátu.

Předdefinované geoprostorové funkce mohou pomocí definovaných geografických zón zjistit, zda je prvek v nebo z konkrétního mnohoúhelníku geografické ploty.

Následující tabulka představuje příklad referenčních dat geografického úložiště, která by mohla být uložená ve službě Azure Blob Storage nebo v tabulce Azure SQL. Všechny lokality jsou reprezentovány pomocí geoprostorového mnohoúhelníku a každé zařízení je přidruženo k povolenému ID webu.

Generování výstrah s geografickou ochranou

Zařízení mohou každou minutu vysílat své ID a umístění prostřednictvím datového proudu DeviceStreamInput . Následující tabulka je datový proud vstupu.

Můžete napsat dotaz, který spojuje datový proud zařízení s referenčními daty geografické plotu a vygeneruje výstrahu pokaždé, když je zařízení mimo povolené sestavení.

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

Následující obrázek představuje geografické ploty. Můžete vidět, kde jsou zařízení v souladu s datovým proudem streamování.

Zařízení "C" se nachází uvnitř sestavování ID 2, které není povoleno podle referenčních dat. Toto zařízení se musí nacházet uvnitř sestavení s ID 3. Spuštění této úlohy vygeneruje výstrahu pro toto konkrétní porušení.

Lokalita s několika povolenými zařízeními

Pokud lokalita povoluje více zařízení, může být definováno pole ID zařízení AllowedDeviceID a v klauzuli User-Defined lze použít funkci WHERE k ověření, zda ID zařízení datového proudu odpovídá jakémukoli ID zařízení v tomto seznamu. Další informace najdete v kurzu JavaScript UDF pro cloudové úlohy a v kurzu pro C# UDF pro úlohy Edge.

Geoprostorové agregace

Azure Stream Analytics podporuje geoprostorové agregace v reálném čase s nízkou latencí v cloudu a na IoT Edge runtime.

Scénář geoprostorové agregace

Společnost CAB chce vytvořit aplikaci v reálném čase, která bude podávat ovladače kabiny, aby hledaly v oblastech, ve kterých se aktuálně vyskytují vyšší požadavky.

Společnost ukládá logické oblasti města jako referenční data. Každá oblast je definována RegionID, RegionName a geografickou ochranou.

Definice geografických zón

Následující tabulka představuje příklad referenčních dat geografického úložiště, která by mohla být uložená ve službě Azure Blob Storage nebo v tabulce Azure SQL. Všechny oblasti jsou reprezentovány pomocí geoprostorového mnohoúhelníku, který se používá ke sladění požadavků přicházejících z datových proudů.

Tyto mnohoúhelníky jsou pouze pro referenci a nepředstavují skutečné logické ani fyzické separace.

Agregovaná data v časovém intervalu

Následující tabulka obsahuje streamovaná data "jezdí".

Následující dotaz spojuje datový proud zařízení s referenčními daty geografické plotu a vypočítává počet požadavků na oblast v časovém intervalu 15 minut každou minutu.

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)

Tento dotaz vypíše počet požadavků každou minutu za posledních 15 minut podle každé oblasti v rámci města. Tyto informace můžete snadno zobrazit pomocí řídicího panelu Power BI, nebo je můžete vysílat do všech ovladačů jako textové zprávy SMS prostřednictvím integrace se službami, jako je služba Azure Functions.

Následující obrázek ukazuje výstup dotazu na Power BI řídicí panel.

Další kroky

• Úvod do Stream Analytics geoprostorové funkce
• Geoprostorové funkce (Azure Stream Analytics)