将OPC UA与MongoDB集成——Codelitt的可行性研究
内容提要
OPC UA是工业4.0和工业物联网中被广泛认可和重要的通信标准，通过提供标准的通信框架，增强了数据完整性、安全性和可访问性，实现了不同机器和设备之间的互操作性。MongoDB的文档模型适合存储OPC UA语义信息模型，因为它灵活且与复杂数据结构兼容。Codelitt正在开发一个连接器，可以将OPC UA数据实时导入MongoDB。
延伸解读
文档模型如何映射OPC UA信息模型
文章以工业机器人为例，展示OPC UA信息模型中的状态、当前任务、运行参数和维护历史等层次化属性，如何直接对应MongoDB文档中的嵌套字段和数组。这种映射避免了SQL数据库中复杂的实体关系设计，使设备数字影子能够随生产班次实时更新。对于需要保留语义关系的工业数据，文档模型的灵活性降低了建模成本。
端到端数据流中的可靠性设计
架构中，OPC UA服务器将设备数据广播给订阅客户端，客户端监听特定事件后将其放入消息队列，再由消息代理消化大量数据并保障事件源与存储之间的可靠性，最终写入MongoDB Atlas。消息代理的引入意味着系统不是简单的点对点传输，而是为高吞吐和故障恢复预留了缓冲层，适合实时性要求较高的工业场景。
连接器方案的灵活性与选型空间
Codelitt的连接器允许用户根据偏好选择不同的OPC UA客户端，包括基于Node-OPCUA的自定义客户端、AWS IoT SiteWise Edge或Confluent的OPC UA源连接器；消息代理也可选用Azure Event Hub、Amazon Kinesis或Kafka等。这种模块化设计让企业能复用现有云基础设施，但文章未给出各方案在延迟、成本或运维复杂度上的对比，选型时需自行评估。
Q&A
OPC UA 是什么？它在工业 4.0 中有什么作用？
OPC UA（开放平台通信统一架构）是工业 4.0 和工业物联网中广泛认可的重要通信标准。它实现了不同机器和设备之间的互操作性，确保运营技术（OT）层内可靠且安全的信息共享。通过提供标准通信框架，OPC UA 增强了数据的完整性、安全性和可访问性，从而支持许多工业 4.0 用例。
为什么 MongoDB 适合存储 OPC UA 的信息模型？
MongoDB 的文档模型灵活且兼容复杂数据结构，适合存储 OPC UA 语义信息模型。OPC UA 信息模型包含详细的关系和层次结构，而 MongoDB 的动态模式能自然匹配这种层次关系。文档中的字段可在运行时扩展，便于动态更新和高效查询。例如，工业机器人的 OPC UA 信息模型（包含状态、当前任务、操作参数和维护历史）可以轻松表示为嵌套的 MongoDB 文档。
Codelitt 正在开发的连接器有什么功能？
Codelitt 正在开发一个连接器，可以将时间序列 OPC UA 数据实时导入 MongoDB。该连接器是端到端解决方案的一部分，旨在实现从 OPC UA 服务器到 MongoDB 的实时数据摄取。
OPC UA 数据导入 MongoDB 的端到端架构是怎样的？
端到端架构包括：1）工业设备和控制器使用 OPC UA 协议将数据传输到本地服务器；2）OPC UA 服务器监听这些设备并广播给所有订阅的客户端；3）客户端监听特定事件/变量并将事件排队存储；4）消息代理提供队列系统，以消化大量数据并确保事件源与数据存储之间的可靠性；5）MongoDB Atlas 作为数据的最终目的地，并提供使用聚合框架进行分析和使用 Atlas Charts 进行可视化的能力。
在 Codelitt 的解决方案中，用户可以选择哪些 OPC UA 客户端和消息代理？
对于 OPC UA 客户端，用户可以根据偏好选择：基于 Node-OPCUA 开源项目定制的 OPC UA 客户端、AWS IoT SiteWise Edge，或基于 Confluent 的 OPC UA 源连接器。对于消息代理，可以选择任何云提供的解决方案（如 Azure Event Hub、Amazon Kinesis 等）或任何形式的 Kafka 实现（例如 Confluent）。如果使用 Kafka，可以利用 MongoDB Kafka 连接器将数据推送到数据库。
使用 MongoDB 存储 OPC UA 数据相比传统 SQL 数据库有什么优势？
MongoDB 的文档模型是其他所有数据模型的超集，灵活且兼容复杂数据结构。对于 OPC UA 信息模型中的层次关系和详细关系，MongoDB 的动态模式是自然匹配，字段可在运行时扩展，便于动态更新和高效查询。相比之下，使用 SQL 数据库需要创建复杂的实体关系图，而 MongoDB 提供了更优越的替代方案来表示工业设备的数字影子。
