V řešení Internetu věcí (IoT) zařízení IoT odesílají události (oznámení, potvrzení, telemetrie) do aplikace, aby získala přehledy. Aplikace mohou vyžadovat konkrétní podmnožinu událostí pro zpracování nebo ukládání v různých koncových bodech. Tyto události mohou být také potřeba směrovat do různých služeb pro další zpracování. S horizontálním navýšením kapacity řešení IoT se také liší počet zařízení, objem událostí, různé události a různé služby. Pro zpracování tohoto modelu je nezbytná flexibilní, škálovatelná, konzistentní a spolehlivá metoda pro směrování událostí.
Potenciální případy použití
Maloobchodní prodejna monitoruje chladničky pro sekci zmrazených potravin:
- Výstraha se odešle, když teplota ledniček překročí předem určenou prahovou hodnotu. Pravidlo směrování lze vytvořit s prahovým pravidlem, které tyto konkrétní události odešle do systému upozornění.
- Tým pro datové vědy vytváří model detekce anomálií, který identifikuje problémy s ledničkami předtím, než se některý z nich rozdělí. Pravidlo směrování zpráv může odesílat všechna nezpracovaná telemetrická data do účtu úložiště speciálně pro tým datových věd, který bude používat pro trénování a modelování.
Tento scénář platí pro odvětví maloobchodu, energetiky a životního prostředí.
Architektura
Stáhněte si soubor aplikace Visio s touto architekturou.
Na platformě IoT je možné vytvořit pravidla pro jemně odstupňované směrování událostí. Jedno nebo více pravidel je možné nakonfigurovat na platformě IoT. Pravidla se použijí na události příchozího přenosu dat a směrují se do konkrétních koncových bodů.
Charakteristiky
Tady je několik aspektů, které je potřeba vzít v úvahu při použití tohoto modelu.
Propustnost koncových bodů: Koncové body, které přijímají události, musí být schopné zpracovávat příchozí přenos dat událostí odesílaných přes směrování. Ujistěte se, že služby koncových bodů mají kapacitu ingestovat a ukládat data, dokud nebudou spotřebována.
Formát událostí: Aby bylo směrování škálovatelné a flexibilní, měly by mít události společný formát pro zajištění interoperability napříč protokoly.
Zpracování událostí: Pokud událost odpovídá více trasám, které odkazují na stejný koncový bod, měla by se do tohoto koncového bodu doručit pouze jednou. V takových situacích je také důležité zaručit řazení zpráv.
Duplikace událostí: Pro zpracování duplicit zpráv doporučujeme razítek jedinečného identifikátoru ve vlastnostech aplikace zprávy v okamžiku původu, což je obvykle zařízení nebo modul. Služba, která zprávy využívá, pak může zpracovávat duplicitní zprávy pomocí tohoto identifikátoru.
Náhradní trasa: Události, které neodpovídají žádnému pravidlu, by měly přicházet do náhradní trasy, aby bylo možné je správně vyřešit a žádná událost by se neztratila.
Události nesouvisející s telemetrií: Řešení IoT mají různé typy událostí, jako jsou změny stavu zařízení a události životního cyklu zařízení. Trasa událostí by měla být schopná zachytávat a používat pravidla pro takové události, které nejsou telemetrií, aby bylo možné povolit automatizaci a monitorování.
Kdy použít tento vzor:
Odesílání zpráv telemetrie zařízení, událostí životního cyklu zařízení nebo událostí změny dvojčete zařízení na konkrétní koncové body určené pravidly.
Filtrování událostí použitím konkrétních pravidel
Tento model se nedoporučuje pro:
- Směrování založené na komplexní analýze dat časových řad v reálném čase Například při porovnávání 15minutových průměrných telemetrických dat. Pokud se vyžaduje analýza dat v reálném čase, použijte pro data horké cesty analytickou službu v reálném čase.