Skip to main content
Deze pagina wordt weergegeven met behulp van automatische vertaling. In plaats daarvan in het Engels bekijken?
Merkevolutie 2022
Oplossing voor partners

Contextualiseerde OT-datapijplijn naar Snowflake

Hoe kunnen we op betrouwbare wijze leveranciersonafhankelijke OT-gegevens op de werkvloer verzamelen, deze verrijken met de bedrijfsmiddelen- en productiecontext op het randje, en een beheerde, opvraagbare kopie naar Snowflake sturen voor analyses, ML en bedrijfsgebruik?

Overzicht

overzicht van de architectuurhub Snowflake

Een hybride edge-to-cloud-architectuur waarbij Industrial Edge OT-telemetrie en gebeurtenissen vastlegt, normaliseert en contextualiseert, en deze vervolgens naar Snowflake stuurt met behulp van zowel op bestanden gebaseerde als streaming-opnamepatronen. Snowflake fungeert als de datacloud voor bedrijven voor landings-, gecureerde en analytische lagen, waardoor analyses in bijna realtime, modelscores, operationele apps en integraties met MES/ERP/SCADA-systemen mogelijk zijn. Het ontwerp geeft prioriteit aan gegevensconsistentie, beveiliging, veerkracht en leveranciersonafhankelijke interoperabiliteit.

Gedetailleerde architectuur

Edge-verzameling en contextualisering (Industrial Edge)

  • Industrial Edge gebruikt apparaten op locatie dicht bij de werkvloer en maakt verbinding met automatiseringsapparatuur die onafhankelijk is van de leverancier via OT-connectoren (OPC UA, Modbus, EtherNet/IP, enz.). Het verkrijgt onbewerkte telemetrie, alarmen en gebeurtenissen.
  • Aan de rand worden gegevens voorverwerkt: filtering, compressie, normalisatie van tijdstempels, verrijking met metagegevens van activa (hiërarchieën van bedrijfsmiddelen, context van werkorders en batches) en lokale aggregatie om de bandbreedte in de cloud te beperken.
  • Een interne databus (MQTT/Unified Namespace) of Industrial Information Hub propageert geharmoniseerde onderwerpstromen voor downstream-componenten en lokale consumenten.
architecture hub, sneeuwvlok, gedetailleerde afbeelding zonder tekst.

Beschrijving

Overbrugging van protocollen en formaten

  • FFT DataBridge (Edge-app) transformeert en bereidt gegevens voor voor opname via bestanden. Het buffert om verbindingsverlies op te vangen, batcheert gegevens op intelligente wijze, verifieert veilig met Snowflake key‑pair auth en schrijft naar cloudfasen voor Snowpipe-verwerking.
  • Snowflake Connector (Edge-app) abonneert zich op de databus voor continue streams, voert schemavalidatie en statuscontroles uit, buffert korte geheugenonderbrekingen en gebruikt Snowpipe Streaming om rijen rechtstreeks in Snowflake in te voegen met een lage latentie.

Snowflake dataplatform

  • Inname op basis van JSON via Stage + Pipe (FFT DataBridge): onbewerkte ladingen komen terecht in een verzamelruimte; Snowpipe/Tasks creëert samengestelde tabellen en historische archieven.
  • Directe opname op basis van rijen (Snowpipe Streaming via Snowflake Connector): continue beschikbaarheid van operationele rijen met lage latentie voor dashboards en monitoring.
  • Transformatiepijplijnen (SQL, Snowpark, Streams & Tasks) produceren samengestelde, op tijd afgestemde en contextverrijkte datasets voor BI en ML.
  • Snowflake biedt mogelijkheden voor beheer (toegangscontrole, maskering, lineage), schaalbaarheid en cross-cloud-mogelijkheden voor zakelijk gebruik.
  • Snowflake werkt standaard en consistent bij de belangrijkste cloudproviders (AWS, Microsoft Azure en Google Cloud Platform) en biedt echte cross-cloud-implementatie, replicatie en datamobiliteit.

Waarden en voordelen

Componenten