Skip to main content
Denna sida visas med automatisk översättning. Visa på engelska istället?
Varumärkesutveckling 2022
Partnerlösning

Kontextualiserad OT-datapipeline till Snowflake

Hur kan vi på ett tillförlitligt sätt samla in leverantörsagnostiska OT-data från butiksgolvet, berika den med tillgångs- och produktionskontext i utkanten och leverera en styrd, frågbar kopia till Snowflake för analys, ML och företagskonsumtion?

Översikt

arkitektur nav snöflinga översikt

En hybrid kant-till-moln-arkitektur där Industrial Edge fångar, normaliserar och kontextualiserar OT-telemetri och händelser och sedan levererar dem till Snowflake med hjälp av både filbaserade och strömmande intagningsmönster. Snowflake fungerar som företagsdatamoln för landning, kuraterade och analytiska lager, vilket möjliggör analys i nära realtid, modellpoängsättning, operativa appar och integrationer med MES/ERP/SCADA-system. Designen prioriterar datakonsistens, säkerhet, motståndskraft och leverantörsagnostisk interoperabilitet.

Läs mer

Detaljerad arkitektur

Kantsamling och kontextualisering (Industrial Edge)

  • Industrial Edge kör lokala enheter nära verkstadsgolvet och ansluts till leverantörsagnostisk automationsutrustning via OT-kontakter (OPC UA, Modbus, EtherNet/IP, etc.). Den förvärvar rå telemetri, larm och händelser.
  • Vid kanten förbehandlas data: filtrering, komprimering, normalisering av tidsstämplar, berikning med tillgångsmetadata (tillgångshierarkier, arbetsorder /batchkontext) och lokal aggregering för att minska molnbandbredden.
  • En intern databas (MQTT/Unified Namespace) eller Industrial Information Hub sprider harmoniserade ämnesströmmar för nedströmskomponenter och lokala konsumenter.
Se detaljerad arkitektur
arkitektur nav snöflinga detaljerad grafik ingen text

Beskrivning

Protokoll- och formatöverbryggning

  • FFT DataBridge (Edge App) omvandlar och förbereder data för filbaserad intag. Den buffrar för att hantera anslutningsförluster, batchar data intelligent, autentiserar säkert med Snowflake key‑pair autentisering och skriver till molnstadier för Snowpipe-bearbetning.
  • Snowflake Connector (Edge App) prenumererar på databasen för kontinuerliga strömmar, utför schemavalidering och hälsokontroller, buffrar korta avbrott i minnet och använder Snowpipe Streaming för att infoga rader direkt i Snowflake med låg latens.

Snowflake dataplattform

  • JSON-baserad intag via Stage + Pipe (FFT DataBridge): råa nyttolaster landar i ett iscensättningsområde; Snowpipe/Tasks skapar kurerade tabeller och historiska arkiv.
  • Direkt radbaserad intag (Snowpipe Streaming via Snowflake Connector): kontinuerlig tillgänglighet med låg latens för operativa rader för instrumentpaneler och övervakning.
  • Transformationspipelines (SQL, Snowpark, Streams & Tasks) producerar kuraterade, tidsanpassade och kontextberikade datamängder för BI och ML.
  • Snowflake tillhandahåller styrning (åtkomstkontroll, maskering, härstamning), skalning och moln-funktioner för företagskonsumtion.
  • Snowflake körs inbyggt och konsekvent över de stora molnleverantörerna (AWS, Microsoft Azure och Google Cloud Platform) och erbjuder verklig moln-distribution, replikering och datamobilitet.

Värderingar och fördelar

Komponenter