Skip to main content
Ez az oldal automatikus fordítással jelenik meg. Inkább megnézi angolul?
Márka evolúció 2022
Partner megoldás

Kontextualizált OT adatcsővezeték Snowflake

Hogyan gyűjthetjük megbízhatóan a szállítótól független OT-adatokat az üzletből, gazdagítsuk azokat az eszközök- és termelési kontextusokkal, valamint egy szabályozott, lekérdezhető példányt szállíthatunk a Snowflake-be elemzés, ML és vállalati fogyasztás céljából?

Áttekintés

építészeti központ hópehely áttekintése

Egy hibrid szegély-felhő architektúra, ahol az Industrial Edge rögzíti, normalizálja és kontextualizálja az OT telemetriát és eseményeket, majd a Snowflake-hez szállítja őket fájlalapú és streaming lenyelési minták felhasználásával. A Snowflake vállalati adatfelhőként szolgál a leszállási, kurált és elemző rétegek számára, lehetővé téve a rövid valós idejű elemzést, a modellpontozást, az operatív alkalmazásokat és a MES/ERP/SCADA rendszerekkel való integrációt. A tervezés az adatok következetességét, a biztonságot, a rugalmasságot és a szállító-agnosztikus interoperabilitást részesíti előnyben.

Részletes építészet

Edge gyűjtés és kontextualizálás (Industrial Edge)

  • Az Industrial Edge on-prem eszközöket üzemeltet az üzlet közelében, és OT csatlakozókon keresztül (OPC UA, Modbus, Ethernet/IP stb.) csatlakozik a forgalmazó-agnosztikus automatizálási berendezésekhez. Nyers telemetriát, riasztásokat és eseményeket szerez.
  • A szélén az adatok előfeldolgozása történik: szűrés, tömörítés, időbélyeg-normalizálás, eszköz metaadatokkal való gazdagítás (eszközhierarchiák, munkaszervezés/kötegelt kontextus), valamint helyi összesítés a felhő sávszélességének csökkentése érdekében.
  • Egy belső adatbázis (MQTT /Unified Namspace) vagy ipari információs központ harmonizált témák terjesztését terjeszti a továbbfejlesztett komponensek és a helyi fogyasztók számára.
építészeti hub hópehely részletes grafika szöveg nélkül

Leírás

Protokoll és formátumok áthidalása

  • Az FFT DataBridge (Edge App) átalakítja és előkészíti az adatokat fájlalapú lenyeléshez. Pufferrel kezeli a kapcsolat elvesztését, intelligensen gyűjti az adatokat, biztonságosan hitelesít a Snowflake kulcspár-hitelesítéssel, és felhőszakaszokra ír a Snowpipe feldolgozásához.
  • A Snowflake Connector (Edge App) feliratkozik az adatbázisra folyamatos adatfolyamokhoz, sémaellenőrzést és állapotellenőrzést végez, pufferelje a memória rövid kimaradását, és a Snowpipe Streaming segítségével a sorokat közvetlenül a Snowflake-be illeszti be alacsony késleltetéssel.

Snowflake adatplatform

  • JSON-alapú lenyelés Stage + Pipe (FFT DataBridge) segítségével: a nyers hasznos rakományok egy színpadozási területen szállnak le; A Snowpipe/Tasks válogatott táblázatokat és történelmi archívumokat hoz létre.
  • Közvetlen soralapú lenyelés (Snowpipe Streaming a Snowflake Connector segítségével): a működési sorok folyamatos, alacsony késleltetésű rendelkezésre állása az irányítópultok és a monitorozáshoz.
  • A transzformációs csővezetékek (SQL, Snowpark, Streams & Tasks) válogatott, időre igazított és kontextussal gazdagított adatkészleteket hoznak létre a BI és ML számára.
  • A Snowflake felügyeleti (hozzáférés-vezérlés, maszkolás, lineage), méretezési és felhőközi képességeket biztosít a vállalati fogyasztáshoz.
  • A Snowflake natív módon és következetesen fut a fő felhőszolgáltatókon (AWS, Microsoft Azure és Google Cloud Platform), valódi felhőkön keresztüli telepítést, replikációt és adatmobilitást kínál.

Értékek és előnyök

Alkatrészek