Skip to main content
Questa pagina viene visualizzata utilizzando la traduzione automatica. Visualizzare la versione in inglese?
Soluzione per i partner

Pipeline di dati OT contestualizzata in Snowflake

Come possiamo raccogliere in modo affidabile dati OT indipendenti dal fornitore dall'officina, arricchirli con un contesto di asset e produzione all'edge e fornire una copia governata e interrogabile in Snowflake per analisi, ML e consumo aziendale?

Panoramica

panoramica di Architecture Hub Snowflake

Un'architettura ibrida edge-to-cloud in cui Industrial Edge acquisisce, normalizza e contestualizza la telemetria e gli eventi OT, quindi li invia a Snowflake utilizzando modelli di ingestione basati su file e streaming. Snowflake funge da cloud di dati aziendali per livelli di atterraggio, curati e analitici, consentendo analisi quasi in tempo reale, punteggio dei modelli, app operative e integrazioni con i sistemi MES/ERP/SCADA. Il design dà priorità alla coerenza dei dati, alla sicurezza, alla resilienza e all'interoperabilità indipendente dal fornitore.

Scopri di più

Architettura dettagliata

Raccolta e contestualizzazione dei bordi (Industrial Edge)

  • Industrial Edge utilizza dispositivi locali vicino all'officina e si connette alle apparecchiature di automazione indipendenti dal fornitore tramite connettori OT (OPC UA, Modbus, EtherNet/IP, ecc.). Acquisisce telemetria grezza, allarmi ed eventi.
  • All'edge, i dati vengono preelaborati: filtraggio, compressione, normalizzazione del timestamp, arricchimento con metadati delle risorse (gerarchie degli asset, ordine di lavoro/contesto batch) e aggregazione locale per ridurre la larghezza di banda del cloud.
  • Un database interno (MQTT/Unified Namespace) o Industrial Information Hub propaga flussi di argomenti armonizzati per i componenti a valle e i consumatori locali.
Vedi l'architettura dettagliata
architecture hub, fiocco di neve, grafica dettagliata, senza testo

Descrizione

Bridging di protocolli e formati

  • FFT DataBridge (Edge App) trasforma e prepara i dati per l'inserimento basato su file. Si bufferizza per gestire la perdita di connessione, raggruppa i dati in modo intelligente, si autentica in modo sicuro con l'autenticazione con coppia di chiavi Snowflake e scrive su fasi cloud per l'elaborazione di Snowpipe.
  • Snowflake Connector (Edge App) si iscrive al database per flussi continui, esegue la convalida dello schema e i controlli di integrità, bufferizza le brevi interruzioni della memoria e utilizza Snowpipe Streaming per inserire righe direttamente in Snowflake con bassa latenza.

Piattaforma dati Snowflake

  • Inserimento basato su JSON tramite Stage + Pipe (FFT DataBridge): i payload grezzi arrivano in un'area di sosta; Snowpipe/Tasks crea tabelle e archivi storici curati.
  • Inserimento diretto basato su righe (Snowpipe Streaming via Snowflake Connector): disponibilità continua e a bassa latenza di righe operative per dashboard e monitoraggio.
  • Le pipeline di trasformazione (SQL, Snowpark, Streams & Tasks) producono set di dati curati, allineati nel tempo e arricchiti dal contesto per BI e ML.
  • Snowflake offre funzionalità di governance (controllo degli accessi, mascheramento, lineage), scalabilità e cross-cloud per il consumo aziendale.
  • Snowflake funziona in modo nativo e coerente tra i principali fornitori di cloud (AWS, Microsoft Azure e Google Cloud Platform), offrendo una vera distribuzione, replica e mobilità dei dati su più cloud.

Valori e vantaggi

Componenti