Skip to main content
Această pagină este afișată prin traducere automată. Vizualizați în schimb în limba engleză?
Evoluția mărcii 2022
Soluție pentru parteneri

Conducta de date OT contextualizată în Snowflake

Cum putem colecta în mod fiabil date OT agnostice ale furnizorilor din magazin, să le îmbogățim cu active și context de producție la margine și să livrăm o copie guvernată, interogabilă în Snowflake pentru analiză, ML și consum de întreprindere?

Prezentare generală

prezentare generală a fulgului de zăpadă al hub-ului arhitec

O arhitectură hibridă de la margine la cloud în care Industrial Edge captează, normalizează și contextualizează telemetria și evenimentele OT, apoi le livrează către Snowflake folosind atât modele de ingestie bazate pe fișiere, cât și modele de streaming. Snowflake servește ca cloud de date pentru întreprinderi pentru straturi de aterizare, curate și analitice, permițând analize în timp real, notarea modelelor, aplicații operaționale și integrări cu sistemele MES/ERP/SCADA. Designul acordă prioritate consecvenței datelor, securității, rezilienței și interoperabilității agnostice a furnizorului.

Aflați mai multe

Arhitectură detaliată

Colectarea și contextualizarea marginilor (Industrial Edge)

  • Industrial Edge rulează dispozitive on-prem aproape de magazin și se conectează la echipamentele de automatizare agnostice ale furnizorului prin conectori OT (OPC UA, Modbus, EtherNet/IP etc.). Achiziționează telemetrie brută, alarme și evenimente.
  • La margine, datele sunt pre-procesate: filtrare, comprimare, normalizare a marcajelor de timp, îmbogățirea cu metadate ale activelor (ierarhii de active, ordine de lucru/context lot) și agregare locală pentru a reduce lățimea de bandă în cloud.
  • O bază de date internă (MQTT/ Unified Namespace) sau Industrial Information Hub propagă fluxuri de subiecte armonizate pentru componentele din aval și consumatorii locali.
Vezi arhitectura detaliată
hub de arhitectură fulg de zăpadă grafic detaliat fără text

Descriere

Legarea protocolului și a formatului

  • FFT DataBridge (Edge App) transformă și pregătește datele pentru ingestia bazată pe fișiere. Face tampon pentru a gestiona pierderea conexiunii, grupează datele în mod inteligent, se autentifică în siguranță cu autentificarea pereche de chei Snowflake și scrie în etapele cloud pentru procesarea Snowpipe.
  • Snowflake Connector (Edge App) se abonează la baza de date pentru fluxuri continue, efectuează validarea schemei și verificări de sănătate, tamponează întreruperile scurte în memorie și folosește Snowpipe Streaming pentru a insera rânduri direct în Snowflake cu latență scăzută.

Platforma de date Snowflake

  • Ingestie bazată pe JSON prin Stage + Pipe (FFT DataBridge): încărcăturile utile brute aterizează într-o zonă de stadializare; Snowpipe/Tasks creează tabele curate și arhive istorice.
  • Ingestie directă bazată pe rânduri (Snowpipe Streaming prin Snowflake Connector): disponibilitate continuă, cu latență scăzută a rândurilor operaționale pentru tablouri de bord și monitorizare.
  • Conductele de transformare (SQL, Snowpark, Streams & Tasks) produc seturi de date curate, aliniate în timp și îmbogățite în context pentru BI și ML.
  • Snowflake oferă guvernanță (control acces, mascare, descendență), scalare și capacități cross-cloud pentru consumul întreprinderii.
  • Snowflake rulează nativ și consecvent în cadrul principalilor furnizori de cloud (AWS, Microsoft Azure și Google Cloud Platform), oferind implementare, replicare și mobilitate de date adevărate în cross-cloud.

Valori și beneficii

Componente