Skip to main content
Тази страница се показва с помощта на автоматизиран превод. Вместо това вижте на английски?
Еволюция на марката 2022
Партньорско решение

Контекстуализиран тръбопровод за данни от OT в Snowflake

Как можем надеждно да събираме от магазина данни от търговците от търговския обект, да ги обогатим с активи и производствен контекст на ръба и да доставим управлявано копие за търсене в 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/Задачите създават подбрани таблици и исторически архиви.
  • Директно поглъщане на базата на редове (Snowpipe Streaming чрез Snowflake Connector): непрекъсната наличност на оперативни редове с ниска латентност за табла и мониторинг.
  • Трансформационните тръбопроводи (SQL, Snowpark, Streams & Tasks) произвеждат подбрани, подравнени във времето и обогатени с контекст набори от данни за BI и ML.
  • Snowflake предоставя възможности за управление (контрол на достъпа, маскиране, линия), мащабиране и междуоблачни възможности за потребление на предприятията.
  • Snowflake работи естествено и последователно сред основните доставчици на облачни услуги (AWS, Microsoft Azure и Google Cloud Platform), предлагайки истинско внедряване, репликация и мобилност на данни в различни облаци.

Ценности и ползи

Компоненти