Сбор и контекстуализация данных Edge (Industrial Edge)
Industrial Edge размещает локальные устройства рядом с цехом и подключается к оборудованию автоматизации, не зависящему от производителя, через разъемы OT (OPC UA, Modbus, Ethernet/IP и т. д.). Он собирает необработанные телеметрические данные, сигналы тревоги и события.
На периферии происходит предварительная обработка данных: фильтрация, сжатие, нормализация временных меток, обогащение метаданными активов (иерархии активов, контекст рабочего задания/пакетной обработки) и локальное агрегирование для уменьшения пропускной способности облака.
Внутренняя база данных (MQTT/Unified Namespace) или Industrial Information Hub обеспечивает согласованные тематические потоки для дочерних компонентов и местных потребителей.
Связь между протоколами и форматами
FFT DataBridge (приложение Edge) подготавливает и обогащает данные для потоковой передачи и ввода в Databricks в режиме, близком к реальному времени. Бесплатное сопутствующее приложение, FFT DataService, получает доступ к контекстуализированным данным из Industrial Information Hub Essentials (Edge App) и делает их доступными для FFT DataBridge, которая затем публикует согласованные контекстуализированные потоки данных через Zerobus, обеспечивая непрерывную доставку непосредственно в таблицы, управляемые каталогом Unity.
Для обеспечения надежности решение использует буферизацию в памяти и локальное сохранение данных для устранения перебоев в подключении и продолжительных простоев. Со стороны Databricks данные постепенно загружаются в таблицы Delta в Unity Catalog, что обеспечивает регулируемый доступ с малой задержкой к последующим аналитическим нагрузкам и рабочим нагрузкам искусственного интеллекта. Безопасное подключение обеспечивается с помощью механизмов аутентификации на основе токенов или ключей.
Платформа анализа данных Databricks
Потоковая передача данных через Zerobus непрерывно передает данные в Databricks, где входящие полезные данные OT записываются в таблицы Bronze Delta, управляемые Unity Catalog, сохраняя исходную структуру и метаданные для полной прослеживаемости и аудита.
Конвейеры трансформации, построенные с использованием декларативных конвейеров Lakeflow, рабочих процессов Databricks и Apache Spark, постепенно превращают данные в серебряный (курируемый) и золотой (аналитический) слои, обеспечивая согласование времени, обогащение контекста и готовность к использованию бизнес-аналитики, а также сценарии использования на основе искусственного интеллекта.
Модели искусственного интеллекта разрабатываются и обучаются централизованно в Databricks с использованием MLFlow и Mosaic AI, а затем могут быть развернуты обратно в Siemens Industrial Edge для выполнения с малыми задержками рядом с цехом, что позволяет оптимизировать замкнутый цикл и использовать физические сценарии искусственного интеллекта.
Unity Catalog обеспечивает комплексное управление, включая детальный контроль доступа, маскирование данных и отслеживание происхождения, а платформа Lakehouse изначально работает в AWS, Microsoft Azure и Google Cloud Platform, поддерживая межоблачное развертывание и бесперебойную мобильность данных.