Skip to main content
Bu sayfa, otomatik çeviri yardımıyla görüntülenmektedir. İngilizce olarak görüntülenmesini ister misiniz?
Marka Evrimi 2022
İş Ortağı Çözümü

Snowflake'e Bağlamsallaştırılmış OT Veri Boru Hattı

Satıcıdan bağımsız OT verilerini atölyeden güvenilir bir şekilde toplayabilir, uçtaki varlık ve üretim bağlamıyla zenginleştirebilir ve analitik, ML ve kurumsal tüketim için Snowflake'e yönetilen, sorgulanabilir bir kopyayı nasıl sunabiliriz?

Genel Bakış

architecture hub kar tanesine genel bakış

Industrial Edge'in OT telemetrisini ve olaylarını yakaladığı, normalleştirdiği ve bağlamsallaştırdığı, ardından hem dosya tabanlı hem de akış alma modellerini kullanarak bunları Snowflake'e teslim ettiği hibrit bir uçtan buluta mimari. Snowflake, iniş, seçilmiş ve analitik katmanlar için kurumsal veri bulutu görevi görerek gerçek zamanlı analitik, model puanlama, operasyonel uygulamalar ve MES/ERP/SCADA sistemleriyle entegrasyonlar sağlar. Tasarım, veri tutarlılığı, güvenlik, esneklik ve satıcıdan bağımsız birlikte çalışabilirliği ön planda tutar.

Detaylı mimari

Kenar toplama ve bağlamsallaştırma (Industrial Edge)

  • Industrial Edge, şirket içi cihazları atölyenin yakınında çalıştırır ve OT konektörleri (OPC UA, Modbus, EtherNet/IP, vb.) aracılığıyla satıcıdan bağımsız otomasyon ekipmanlarına bağlanır. Ham telemetri, alarmlar ve olaylar edinir.
  • Sınırda veriler önceden işlenir: filtreleme, sıkıştırma, zaman damgası normalleştirme, varlık meta verileri ile zenginleştirme (varlık hiyerarşileri, iş emri/toplu iş bağlamı) ve bulut bant genişliğini azaltmak için yerel toplama.
  • Dahili bir veritabanı (MQTT/Unified Namespace) veya Industrial Information Hub, alt bileşenler ve yerel tüketiciler için uyumlaştırılmış konu akışlarını yayar.
mimari merkez kar tanesi detaylı grafik metin yok

Açıklama

Protokol ve format köprüleme

  • FFT DataBridge (Edge App), verileri dosya tabanlı alım için dönüştürür ve hazırlar. Bağlantı kaybını işlemek için arabelleğe alır, verileri akıllıca gruplandırır, Snowflake anahtar çifti kimlik doğrulaması ile güvenli bir şekilde kimlik doğrulaması yapar ve Snowpipe işleme için bulut aşamalarına yazar.
  • Snowflake Connector (Edge App), sürekli akışlar için veri tabanına abone olur, şema doğrulaması ve sağlık kontrolleri gerçekleştirir, bellekteki kısa kesintileri tamponlar ve satırları düşük gecikmeyle doğrudan Snowflake'e eklemek için Snowpipe Streaming'i kullanır.

Snowflake veri platformu

  • Stage+ Pipe (FFT DataBridge) aracılığıyla JSON tabanlı alım: ham yükler bir hazırlama alanına iner; Snowpipe/Tasks küratörlü tablolar ve geçmiş arşivler oluşturur.
  • Doğrudan satır tabanlı alım (Snowflake Connector üzerinden Snowpipe Streaming): gösterge panoları ve izleme için operasyonel satırların sürekli, düşük gecikmeli kullanılabilirliği.
  • Dönüşüm işlem hatları (SQL, Snowpark, Streams & Tasks), BI ve ML için küratörlü, zaman hizalı ve bağlam açısından zenginleştirilmiş veri kümeleri üretir.
  • Snowflake, kurumsal tüketim için yönetişim (erişim kontrolü, maskeleme, soy), ölçeklendirme ve bulutlar arası yetenekler sağlar.
  • Snowflake, büyük bulut sağlayıcılarında (AWS, Microsoft Azure ve Google Cloud Platform) yerel ve tutarlı bir şekilde çalışır ve gerçek bulutlar arası dağıtım, çoğaltma ve veri taşınabilirliği sunar.

Değerler ve faydalar

Bileşenleri