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

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

Как мы можем надежно собирать независимые от поставщиков данные OT из цеха, обогащать их информацией об активах и производственном контексте на периферии и предоставлять управляемую копию Snowflake с возможностью запросов для аналитики, машинного обучения и корпоративного потребления?

Обзор

обзор снежинки архитектурного центра

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

Узнайте больше

Подробная архитектура

Сбор и контекстуализация данных Edge (Industrial Edge)

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

Описание

Связь между протоколами и форматами

  • FFT DataBridge (приложение Edge) преобразует и подготавливает данные для приема на основе файлов. Он выполняет буферизацию для обработки потери соединения, интеллектуально пакетирует данные, безопасно аутентифицируется с помощью аутентификации Snowflake с помощью пары ключей Snowflake и записывает данные в облачные хранилища для обработки Snowpipe.
  • Snowflake Connector (Edge App) подписывается на шину данных для непрерывных потоков, выполняет проверку схемы и проверку работоспособности, устраняет кратковременные перебои в памяти и использует Snowpipe Streaming для вставки строк непосредственно в Snowflake с низкой задержкой.

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

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

Ценности и преимущества

Компоненты