Skip to main content
Цю сторінку перекладено автоматично. Перейти натомість до англійської версії?
Еволюція бренду 2022
Партнерське рішення

Контекстуалізований конвеєр даних OT у Snowflake

Як ми можемо надійно збирати дані OT, що не залежать від постачальників, з цеху, збагатити їх контекстом активів та виробництва на межі та доставити керовану копію, яку можна запитувати, у Snowflake для аналітики, ML та споживання підприємств?

Огляд

огляд архітектурного хаба сніжинки

Гібридна архітектура від краю до хмари, де Industrial Edge фіксує, нормалізує та контекстуалізує телеметрію та події OT, а потім доставляє їх до Snowflake, використовуючи як шаблони на основі файлів, так і потокове передавання. Snowflake служить хмарою корпоративних даних для посадкових, кураторських та аналітичних шарів, забезпечуючи аналітику майже в реальному часі, оцінку моделей, операційні програми та інтеграцію з системами MES/ERP/SCADA. Дизайн надає пріоритет узгодженості даних, безпеці, стійкості та незалежній від постачальників взаємодії.

Докладніше

Детальна архітектура

Колекція та контекстуалізація країв (Industrial Edge)

  • Industrial Edge працює на локальних пристроях неподалік від цеху та підключається до обладнання автоматизації, що не залежить від постачальника через роз'єми OT (OPC UA, Modbus, EtherNet/IP тощо). Він набуває необроблену телеметрію, тривоги та події.
  • На краю дані попередньо обробляються: фільтрація, стиснення, нормалізація часових міток, збагачення метаданими активів (ієрархії активів, робочий ордер/контекст пакету) та локальна агрегація для зменшення пропускної здатності хмари.
  • Внутрішня база даних (MQTT/ Unified Namespace) або Industrial Information Hub поширює гармонізовані тематичні потоки для нижчих компонентів та локальних споживачів.
Переглянути детальну архітектуру
архітектура хаба сніжинка детальна графіка без тексту

Опис

Мостування протоколів і форматів

  • FFT DataBridge (Edge App) перетворює та готує дані для прийому на основі файлів. Він буферує для обробки втрати з'єднання, інтелектуально групує дані, надійно автентифікує за допомогою пари ключів Snowflake та записує на хмарні етапи для обробки Snowpipe.
  • Snowflake Connector (Edge App) підписується на базу даних для безперервних потоків, виконує перевірку схеми та перевірки стану, буферує короткі відключення в пам'яті та використовує Snowpipe Streaming для вставлення рядків безпосередньо в Snowflake з низькою затримкою.

Платформа даних Snowflake

  • Прийом на основі JSON за допомогою Stage+ Pipe (FFT DataBridge): необроблені корисні навантаження приземляються в зону постановки; Snowpipe/Tasks створює підібрані таблиці та історичні архіви.
  • Пряме введення на основі рядків (Snowpipe Streaming через Snowflake Connector): безперервна доступність оперативних рядків з низькою затримкою для інформаційних панелей та моніторингу.
  • Конвеєри трансформації (SQL, Snowpark, Streams & Tasks) створюють підібрані, узгоджені за часом та збагачені контекстом набори даних для BI та ML.
  • Snowflake забезпечує управління (контроль доступу, маскування, лінію), масштабування та крос-хмарні можливості для корпоративного споживання.
  • Snowflake працює на основі та послідовно серед основних хмарних постачальників (AWS, Microsoft Azure та Google Cloud Platform), пропонуючи справжнє міжхмарне розгортання, реплікацію та мобільність даних.

Цінності та переваги

Компоненти