合作伙伴解决方案

将情境化 OT 数据管道导入 Snowflake

我们如何才能可靠地从车间收集与供应商无关的 OT 数据，利用边缘的资产和生产环境对其进行丰富，并将受管控的可查询副本交付给 Snowflake 以供分析、机器学习和企业消费？

概述

一种边缘到云的混合架构，其中 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（边缘应用程序）转换和准备数据以进行基于文件的摄取。它可以缓冲以处理连接丢失，智能地批处理数据，使用 Snowflake 密钥对身份验证进行安全身份验证，并写入云端以进行 Snowpipe 处理。
Snowflake Connector（边缘应用程序）订阅数据总线以获取连续流，执行架构验证和运行状况检查，缓冲内存中的短暂中断，并使用 Snowpipe Streaming 以低延迟将行直接插入到 Snowflake 中。

Snowflake 数据平台

通过 Stage + Pipe (FFT DataBridge) 进行基于 JSON 的提取：原始有效载荷落在暂存区；Snowpipe/Tasks 创建精选表格和历史档案。
基于行的直接提取（通过 Snowflake Connector 进行 Snowpipe 流式传输）：为仪表板和监控提供持续、低延迟的操作行。
转型管道（SQL、Snowpark、Streams 和任务）为 BI 和 ML 生成精选、时间对齐且内容丰富的数据集。
Snowflake 为企业消费提供治理（访问控制、屏蔽、世系）、扩展和跨云功能。
Snowflake在主要云提供商（AWS、微软Azure和谷歌云平台）上以原生方式持续运行，提供真正的跨云部署、复制和数据移动。