Partnerløsning

Kontekstualiseret OT-datapipeline til Snowflake

Hvordan kan vi pålideligt indsamle leverandøragnostiske OT-data fra butiksgulvet, berige dem med aktiv- og produktionskontekst i kanten og levere en kontrolleret, forespørgselsbar kopi til Snowflake til analyse, ML og virksomhedsforbrug?

Oversigt

En hybrid kant-til-cloud-arkitektur, hvor Industrial Edge fanger, normaliserer og kontekstualiserer OT-telemetri og begivenheder og derefter leverer dem til Snowflake ved hjælp af både filbaserede og streamingindtagelsesmønstre. Snowflake fungerer som virksomhedsdataskyen til landing, kuraterede og analytiske lag, hvilket muliggør analyse i nær realtid, modelscoring, operationelle apps og integrationer med MES/ERP/SCADA-systemer. Designet prioriterer datakonsistens, sikkerhed, modstandsdygtighed og leverandøragnostisk interoperabilitet.

Se mere

Detaljeret arkitektur

Kantindsamling og kontekstualisering (Industrial Edge)

Industrial Edge kører on-prem-enheder tæt på butiksgulvet og opretter forbindelse til leverandøragnostisk automatiseringsudstyr via OT-stik (OPC UA, Modbus, EtherNet/IP osv.). Det erhverver rå telemetri, alarmer og begivenheder.
Ved kanten forbehandles data: filtrering, komprimering, normalisering af tidsstempel, berigelse med aktivmetadata (aktivhierarkier, arbejdsordre- /batchkontekst) og lokal aggregering for at reducere skybåndbredde.
En intern databus (MQTT/Unified Namespace) eller Industrial Information Hub udbreder harmoniserede emnestrømme for downstream-komponenter og lokale forbrugere.

Se detaljeret arkitektur

arkitektur hub snefnug detaljeret grafik ingen tekst

Beskrivelse

Protokol- og formatbrodannelse

FFT DataBridge (Edge App) transformerer og forbereder data til filbaseret indtagelse. Det bufferer til håndtering af forbindelsestab, batcher data intelligent, autentificerer sikkert med Snowflake key‑pair autentificering og skriver til skyfaser til Snowpipe-behandling.
Snowflake Connector (Edge App) abonnerer på databasen for kontinuerlige streams, udfører skemavalidering og sundhedskontrol, buffrer korte afbrydelser i hukommelsen og bruger Snowpipe Streaming til at indsætte rækker direkte i Snowflake med lav latenstid.

Snowflake dataplatform

JSON-baseret indtagelse via Stage + Pipe (FFT DataBridge): rå nyttelast lander i et iscenesættelsesområde; Snowpipe/Tasks opretter kuraterede tabeller og historiske arkiver.
Direkte rækkebaseret indtagelse (Snowpipe Streaming via Snowflake Connector): kontinuerlig tilgængelighed med lav latens af operationelle rækker til dashboards og overvågning.
Transformationspipelines (SQL, Snowpark, Streams & Tasks) producerer kuraterede, tidsjusterede og kontekstberigede datasæt til BI og ML.
Snowflake leverer styring (adgangskontrol, maskering, afstamning), skalering og cross-cloud funktioner til virksomhedsforbrug.
Snowflake kører naturligt og konsekvent på tværs af de store cloududbydere (AWS, Microsoft Azure og Google Cloud Platform) og tilbyder ægte cross-cloud-implementering, replikering og datamobilitet.

Værdier & fordele

Enkelt, styret kilde til sandhed

Snowflake gemmer rå og kuraterede OT-data, hvilket muliggør konsekvent analyse og rapportering.

Reducerede skyomkostninger og båndbredde

Aggregering og filtrering på kantsiden reducerer datavolumen, samtidig med at troværdigheden bevares, hvor det er nødvendigt.

Hurtigere ML og analyse

Snowpark og Streams & Tasks accelererer funktionsteknik, modeltræning og implementering.

Operationel modstandsdygtighed

Kantbuffering (ringhukommelse, filbuffere) og genforsøgslogik opretholder kontinuitet under netværksafbrydelser.

Security og governance

End-to-end-kryptering, nøglepar-godkendelse, rollebaseret adgang og Snowflake-kontroller beskytter følsomme driftsdata.

Komponenter

Industrial Edge

• Værter for OT-stik, apps, lokal databus og bufferlagring

• Ansvar: sikker erhvervelse, berigelse, filtrering, aggregering og orkestrering

• Administreret centralt via Industrial Edge Management

FFT DataBridge (Edge App)

• Bufferer data ved hjælp af ringhukommelse og filpersistens for at overleve længere afbrydelser

• Håndterer gentagelser, forbindelsestab, batching og pakning af skemaer

• Godkendes sikkert ved hjælp af Snowflake nøglepar-godkendelse

Snowflake Connector (Edge App)

• Abonnerer på Industrial Edge-databasen for kontinuerlige datastrømme

• Buffrer data i hukommelsen til korte afbrydelser

• Udfører skemavalidering og sundhedskontrol via JDBC

• Streamer datarækker direkte ind i Snowflake via Snowpipe

Snowflake Data Cloud

• Landing/Raw-zone: bevarer originale JSON-nyttelaster og metadata til revisionsbarhed

• Kurateret/analytisk zone: strukturerede tabeller, der bruges til rapportering, ML og operationelle apps

• JSON-baseret indtagelse

• Direkte rækkebaseret indtagelse