Poznámka:
Přístup k této stránce vyžaduje autorizaci. Můžete se zkusit přihlásit nebo změnit adresáře.
Přístup k této stránce vyžaduje autorizaci. Můžete zkusit změnit adresáře.
Toky dat umožňují připojit různé zdroje dat a provádět operace s daty, což zjednodušuje nastavení cest k datům pro přesouvání, transformaci a rozšiřování dat. Komponenta toku dat je součástí operací Azure IoT, která je nasazená jako rozšíření Azure Arc. Konfigurace toku dat se provádí prostřednictvím uživatelsky definovaných definic prostředků Kubernetes CRDs.
Konfigurace můžete psát pro různé případy použití, například:
- Transformace dat a jejich odeslání zpět do MQTT
- Transformace dat a jejich odeslání do cloudu
- Odeslat data do cloudu nebo na hranu bez transformace
Toky dat nejsou omezeny na oblast, ve které je nasazená instance operace IoT. Toky dat můžete použít k odesílání dat do koncových bodů cloudu v různých oblastech.
Klíčové funkce
Tady jsou klíčové funkce toků dat.
Zpracování a směrování dat
Toky dat umožňují přijímání, zpracování a směrování sdělení do určených destinací. Můžete zadat:
- Zdroje: Kde se zprávy ingestují
- Cíle: Vyprázdnění zpráv, včetně podpory dynamického směrování témat na základě obsahu zpráv pro koncové body MQTT
- Transformace (volitelné): Konfigurace operací zpracování dat
Možnosti transformace
Transformace se dají použít na data během fáze zpracování, aby bylo možné provádět různé operace. Mezi tyto operace patří:
- Výpočet nových vlastností: Na základě existujících vlastností ve zprávě
- Přejmenovat vlastnosti: Standardizace nebo objasnění dat
- Převod jednotek: Převod hodnot na různé měrné jednotky
- Standardizace hodnot: Škálování hodnot vlastností na uživatelsky definovaný rozsah
- Kontextová data: Přidání referenčních dat do zpráv pro rozšiřování a řízení přehledů
Konfigurace a nasazení
Konfigurace je specifikována pomocí Kubernetes CRD. Na základě této konfigurace vytvoří operátor toku dat instance toku dat, které zajistí vysokou dostupnost a spolehlivost.
Zaměstnanecké výhody
- Zjednodušené nastavení: Snadné připojení zdrojů a cílů dat
- Flexibilní transformace: Provádění široké škály datových operací
- Škálovatelná konfigurace: Použití CRD Kubernetes pro škálovatelné a spravovatelné konfigurace
- Vysoká dostupnost: Nativní prostředek Kubernetes zajišťuje spolehlivost.
Pomocí toků dat můžete efektivně spravovat cesty k datům. Můžete zajistit, aby se data přesně odesílala, transformovala a obohatila tak, aby vyhovovala vašim provozním potřebám.
Registr schématu
Registr schématu, funkce poskytovaná službou Azure Device Registry, je synchronizované úložiště v cloudu a na hraničních zařízeních. Registr schémat ukládá definice zpráv pocházejících z okrajových zařízení a pak zpřístupňuje rozhraní API pro přístup k těmto schématům na okrajových zařízeních. Konektory southbound, jako je konektor pro OPC UA, můžou vytvářet schémata zpráv a přidávat je do registru schémat nebo zákazníci můžou nahrávat schémata do webového uživatelského rozhraní provozního prostředí.
Toky dat používají schémata zpráv k transformaci zprávy do formátu očekávaného cílovým koncovým bodem.
Další informace naleznete v tématu Vysvětlení schémat zpráv.
Místní úložiště zpráv zprostředkovatele MQTT
Při použití místního zprostředkovatele MQTT jako zdrojového koncového bodu v toku dat se zprávy ukládají během ztráty připojení mezi tokem dat a cílovým koncovým bodem. Jako ukázkový scénář předpokládejme, že vytvoříte tok dat pomocí výchozího místního zprostředkovatele MQTT jako zdrojového koncového bodu a Azure Event Hubs jako cílového koncového bodu. Pokud dojde ke ztrátě připojení mezi tokem dat a službou Azure Event Hubs, zprávy se ukládají do fronty zpráv odběratele Zprostředkovatele MQTT. Když se připojení obnoví, tok dat odešle zprávy ve frontě zpráv odběratele do služby Azure Event Hubs.
Místní fronta zpráv zprostředkovatele MQTT je ve výchozím nastavení uložena v paměti. Zprostředkovatele MQTT můžete nakonfigurovat tak, aby ukládal zprávy na disk pomocí konfigurace diskové vyrovnávací paměti. Další informace o konfiguraci zprostředkovatele MQTT naleznete v tématu Konfigurace nastavení zprostředkovatele pro vysokou dostupnost, škálování a využití paměti. Další informace o vyrovnávací paměti zpráv založené na disku naleznete v tématu Konfigurace chování vyrovnávací paměti zpráv založené na disku.