一种实时数据动态融合方法、装置、设备及存储介质与流程

本发明涉及数据处理，尤其涉及一种实时数据动态融合方法、装置、设备及存储介质。

背景技术：

1、在工业物联网和智能制造领域中，底层设备和传感器，如plc（programmablelogic controller，可编程逻辑控制器）、dcs（distributed control system，分散控制系统）和边缘网关等设备源源不断的产生海量异构实时数据。通常，这些数据以离散的点位形式存在，单一的数据点往往无法直接反映设备或产线的整体运行状态。例如，设备总能耗可能需要由a设备的电流和b设备的电压等多点位计算得出。

2、目前，行业内常见的数据融合中大量衍生数据的计算逻辑被硬编码在上位机软件或服务后端中，如果现场设备的点位或计算公式发生改变，常常需要重新修改代码、编译并重启服务，无法满足工业现场数据灵活多变的业务需求。部分方案通过引入大数据流处理引擎进行流式计算，占用大量服务器资源，不适合在边缘网关或轻量级服务器部署。此外，传统方式采用定时器轮询抓取各个点位的数据后再进行聚合。这导致未更新数据的无效查询浪费cpu（central processing unit，中央处理器）性能资源，同时也无法保证数据融合的绝对实时性、有效性和准确性。

技术实现思路

1、本发明提供了一种实时数据动态融合方法、装置、设备及存储介质，以实现数据融合的动态更新，确保数据融合更新的实时性，提高数据融合更新效率和准确度，以满足数据灵活多变的业务需求。

2、根据本发明的一方面，提供了一种实时数据动态融合方法，所述方法包括：

3、对目标数据融合场景下，基于统一信息模型构建的内存地址树中源节点的变更回调函数进行监听，并在监听到变更回调函数触发时，确定目标源节点及其对应的变更参数数据；所述内存地址树中创建有基于不同传输协议的多源异构设备的设备参数数据构建的至少一个源节点，以及基于各多源异构设备之间的融合参数数据构建的至少一个融合节点；

4、将所述目标源节点的变更参数数据存储至预先构建的局部缓存中，并基于预先构建的倒排依赖映射表获取所述目标源节点存在数据融合关联关系的目标融合节点；

5、从所述内存地址树中获取所述目标融合节点对应的融合脚本表达式，以及从所述局部缓存中提取所述目标源节点的变更参数数据；

6、根据所述目标源节点的变更参数数据，基于所述目标融合节点对应的融合脚本表达式，确定所述目标融合节点的融合数据更新结果；

7、采用所述融合数据更新结果对所述内存地址树中目标融合节点的融合参数数据进行数据更新。

8、根据本发明的另一方面，提供了一种实时数据动态融合装置，所述装置包括：

9、变更数据确定模块，用于对目标数据融合场景下，基于统一信息模型构建的内存地址树中源节点的变更回调函数进行监听，并在监听到变更回调函数触发时，确定目标源节点及其对应的变更参数数据；所述内存地址树中创建有基于不同传输协议的多源异构设备的设备参数数据构建的至少一个源节点，以及基于各多源异构设备之间的融合参数数据构建的至少一个融合节点；

10、缓存写入模块，用于将所述目标源节点的变更参数数据存储至预先构建的局部缓存中，并基于预先构建的倒排依赖映射表获取所述目标源节点存在数据融合关联关系的目标融合节点；

11、参数提取模块，用于从所述内存地址树中获取所述目标融合节点对应的融合脚本表达式，以及从所述局部缓存中提取所述目标源节点的变更参数数据；

12、融合结果确定模块，用于根据所述目标源节点的变更参数数据，基于所述目标融合节点对应的融合脚本表达式，确定所述目标融合节点的融合数据更新结果；

13、数据更新模块，用于采用所述融合数据更新结果对所述内存地址树中目标融合节点的融合参数数据进行数据更新。

14、根据本发明的另一方面，提供了一种电子设备，所述电子设备包括：

15、至少一个处理器；以及

16、与所述至少一个处理器通信连接的存储器；其中，

17、所述存储器存储有可被所述至少一个处理器执行的计算机程序，所述计算机程序被所述至少一个处理器执行，以使所述至少一个处理器能够执行本发明任一实施例所述的实时数据动态融合方法。

18、根据本发明的另一方面，提供了一种计算机可读存储介质，所述计算机可读存储介质存储有计算机指令，所述计算机指令用于使处理器执行时实现本发明任一实施例所述的实时数据动态融合方法。

19、本发明实施例技术方案通过对内存地址树中的源节点进行回调监听，将监听到的源节点的变更参数数据存储至局部缓存并基于倒排依赖映射表获取目标源节点存在数据融合关联关系的目标融合节点，获取目标融合节点的融合脚本表达式，以及从局部缓存中提取目标源节点的变更参数数据，根据目标源节点的变更参数数据，基于融合脚本表达式确定融合数据更新结果，采用融合数据更新结果对内存地址树中目标融合节点的融合参数数据进行数据更新。上述技术方案解决了定时遍历轮询的济源浪费以及无法确保实时性的问题，实现了对数据融合的动态更新，确保了数据融合更新的实时性，无需相关人员介入修改代码或其他配置修改即可自动化完整融合数据的自动更新，且无需人工介入提高了数据融合更新效率和准确度，满足了数据灵活多变场景下的业务需求。

20、应当理解，本部分所描述的内容并非旨在标识本发明的实施例的关键或重要特征，也不用于限制本发明的范围。本发明的其它特征将通过以下的说明书而变得容易理解。

1.一种实时数据动态融合方法，其特征在于，包括：

2.根据权利要求1所述的方法，其特征在于，在所述基于统一信息模型构建的内存地址树中源节点的变更回调函数进行监听，并在监听到变更回调函数触发时，确定目标源节点及其对应的变更参数数据之前，还包括：

3.根据权利要求2所述的方法，其特征在于，所述根据各传输协议的各多源异构设备的参数结构数据构建内存地址树的源节点，包括：

4.根据权利要求2所述的方法，其特征在于，所述根据各多源异构设备之间的融合参数数据构建内存地址树的融合节点，包括：

5.根据权利要求1所述的方法，其特征在于，所述根据所述目标源节点的变更参数数据，基于所述目标融合节点对应的融合脚本表达式，确定所述目标融合节点的融合数据更新结果，包括：

6.根据权利要求1所述的方法，其特征在于，所述倒排依赖映射表的构建方式如下：

7.根据权利要求1所述的方法，其特征在于，所述目标数据融合场景为工业自动化场景，相应的，所述统一信息模型为用于过程控制的对象连接与嵌入统一架构opc ua标准信息模型。

8.一种实时数据动态融合装置，其特征在于，包括：

9.一种电子设备，其特征在于，所述电子设备包括：

10.一种计算机可读存储介质，其特征在于，所述计算机可读存储介质存储有计算机指令，所述计算机指令用于使处理器执行时实现权利要求1-7中任一项所述的实时数据动态融合方法。