1

嗨，

我是milo（和 OPC-UA）的新手，并尝试使用历史数据访问实现 OPC-UA 服务器。我重用了当前的 milo 服务器示例并创建了一个历史节点。在这个节点上，我可以（使用 Prosys OPC UA 客户端）查询空历史记录。我知道我必须自己实现历史节点的持久性。到目前为止一切顺利——但我找不到任何有关处理历史读取请求以及如何返回响应的信息。更准确地说，如何HistoryData将HistoryReadResult

@Override
public void historyRead(HistoryReadContext context, HistoryReadDetails readDetails, TimestampsToReturn timestamps,
        List<HistoryReadValueId> readValueIds)
{
     List<HistoryReadResult> results = Lists.newArrayListWithCapacity(readValueIds.size());
     for (HistoryReadValueId readValueId : readValueIds){
         //return 3 historical entries
         DataValue v1 = new DataValue(new Variant(new Double(1)), StatusCode.GOOD, new DateTime(Date.from(Instant.now().minus(1, ChronoUnit.MINUTES))));
         DataValue v2 = new DataValue(new Variant(new Double(2)), StatusCode.GOOD, new DateTime(Date.from(Instant.now().minus(2, ChronoUnit.MINUTES))));
         DataValue v3 = new DataValue(new Variant(new Double(3)), StatusCode.GOOD,  new DateTime(Date.from(Instant.now().minus(3, ChronoUnit.MINUTES))));
         HistoryData data = new HistoryData(new DataValue[] {v1,v2,v3});
         //???
         HistoryReadResult result = new HistoryReadResult(StatusCode.GOOD, ByteString.NULL_VALUE, ??? );
         results.add(result);
     }
     context.complete(results);
}
4

2 回答 2

1

您将需要访问规范才能成功实施历史访问服务。第 4 部分和第 11 部分。

构造函数中的最后一个参数HistoryReadResult应该是一个HistoryData结构。ExtensionObject基本上是结构被编码和传输的容器。

要创建它，ExtensionObject您将首先创建一个HistoryData（或HistoryModifiedData，取决于...参见规范），然后执行类似ExtensionObject.encode(historyData)获取完成构建HistoryReadResult.

于 2017-10-18T13:47:37.747 回答
1

覆盖 historyRead 是正确的做法。

HistoryReadResult result = new HistoryReadResult(StatusCode.GOOD, ByteString.NULL_VALUE,ExtensionObject.encode(data) );

但是，在使用特定的 AccessLevel 和 Historizing 模式定义我的 variableNode 之前，UA-Expert 等通用客户端没有调用方法，如下所示：

        Set<AccessLevel> acclevels = new LinkedHashSet<>();
        acclevels.add(AccessLevel.CurrentRead);
        acclevels.add(AccessLevel.CurrentWrite);
        acclevels.add(AccessLevel.HistoryRead);

        UaVariableNode node = new UaVariableNode.UaVariableNodeBuilder(server.getNodeMap())
                .setNodeId(new NodeId(namespaceIndex, "HelloWorld/Test/" + name))
                .setAccessLevel(ubyte(AccessLevel.getMask(acclevels)))                  
                .setUserAccessLevel(ubyte(AccessLevel.getMask(acclevels)))
                .setBrowseName(new QualifiedName(namespaceIndex, name))
                .setDisplayName(LocalizedText.english(name))
                .setDataType(typeId)
                .setTypeDefinition(Identifiers.BaseDataVariableType)
                .setHistorizing(true)
                .build();
于 2019-09-09T12:21:16.377 回答