Skip to main content
Ta strona jest wyświetlana przy użyciu automatycznego translatora. Czy chcesz wyświetlić ją w języku angielskim?
Ewolucja marki 2022
Rozwiązanie partnerskie

Kontekstualny rurociąg danych OT do Snowflake

W jaki sposób możemy rzetelnie zbierać z magazynu dane dotyczące OT, wzbogacić je o aktywa i kontekst produkcji na krawędzi oraz dostarczyć kontrolowaną kopię do Snowflake do celów analitycznych, ML i konsumpcji przedsiębiorstwa?

omówienie

przegląd płatka śniegu w architekturze

Hybrydowa architektura brzegowa do chmury, w której Industrial Edge przechwytuje, normalizuje i kontekstualizuje telemetrię i zdarzenia OT, a następnie dostarcza je do Snowflake przy użyciu zarówno wzorców pobierania plików, jak i strumieniowego. Snowflake służy jako korporacyjna chmura danych dla warstw docelowych, wyselekcjonowanych i analitycznych, umożliwiając analizę w czasie krótkim czasie rzeczywistym, ocenę modeli, aplikacje operacyjne i integrację z systemami MES/ERP/SCADA. Projekt stawia priorytet spójności danych, bezpieczeństwu, odporności i interoperacyjności niezależnej od dostawcy.

Szczegółowa architektura

Gromadzenie i kontekstualizacja krawędzi (Industrial Edge)

  • Industrial Edge obsługuje urządzenia on-prem w pobliżu sklepu i łączy się z urządzeniami automatyki niezależnej od dostawcy za pośrednictwem złączy OT (OPC UA, Modbus, Ethernet/IP itp.). Pozyskuje surową telemetrię, alarmy i zdarzenia.
  • Na krawędzi dane są wstępnie przetwarzane: filtrowanie, kompresja, normalizacja znaczników czasu, wzbogacanie o metadane zasobów (hierarchie zasobów, kolejność robocza/kontekst wsadowy) oraz lokalna agregacja w celu zmniejszenia przepustowości w chmurze.
  • Wewnętrzna baza danych (MQTT /Unified Namespace) lub Industrial Information Hub propaguje zharmonizowane strumienie tematyczne dla dalszych komponentów i lokalnych konsumentów.
architektura hub płatek śniegu szczegółowa grafika bez tekstu

Opis

Połączenie protokołów i formatów

  • FFT DataBridge (Edge App) przekształca i przygotowuje dane do pobierania plików. Buforuje, aby poradzić sobie z utratą połączenia, inteligentnie gromadzi dane, bezpiecznie uwierzytelnia za pomocą auth pary kluczy Snowflake i zapisuje na etapach chmury w celu przetwarzania Snowpipe.
  • Snowflake Connector (Edge App) subskrybuje bazę danych dla ciągłych strumieni, przeprowadza walidację schematu i kontrole stanu, buforuje krótkie przerwy w pamięci i używa Snowpipe Streaming do wstawiania wierszy bezpośrednio do Snowflake z małym opóźnieniem.

Platforma danych Snowflake

  • Spożywanie oparte na JSON za pośrednictwem rury Stage + (FFT DataBridge): surowe ładunki lądują w obszarze inscenizacji; Snowpipe/Zadania tworzą wyselekcjonowane tabele i archiwa historyczne.
  • Bezpośrednie spożycie w oparciu o rzędy (strumieniowanie strumieniowe rur śnieżnych przez łącznik Snowflake Connector): ciągła dostępność wierszy operacyjnych dla pulpitów nawigacyjnych i monitorowania o niskim opóźnieniu.
  • Rurociągi transformacji (SQL, Snowpark, Streams & Tasks) tworzą wyselekcjonowane, dopasowane do czasu i wzbogacone w kontekst zestawy danych dla BI i ML.
  • Snowflake zapewnia funkcje zarządzania (kontrola dostępu, maskowanie, liniage), skalowanie i funkcje w różnych chmurach dla konsumpcji przedsiębiorstwa.
  • Snowflake działa natywnie i konsekwentnie u głównych dostawców chmury (AWS, Microsoft Azure i Google Cloud Platform), oferując prawdziwe wdrażanie w chmurze, replikację i mobilność danych.

Wartości i korzyści

Komponenty