基于Mqtt协议与JSON报文在数采网关中的数据处理方法和装置与流程
本申请涉及物联网数据采集，特别是涉及一种基于mqtt协议与json报文在数采网关中的数据处理方法和装置。
背景技术：
1、数采网关是采集工业现场设备数据后上传给远程后台的一种设备，其采集的现场设备又称南向设备，与后台通信协议称为北向协议。mqtt作为一种轻量型的物联网通信协议在网关中被广泛应用，通常采用字符串格式通信。为了对接不同公司的后台需要开发相应的北向协议。甚至对于同一公司的不同应用也需要开发不同的北向协议，一个网关厂商都会提供大量的对接不同公司平台的北向协议模块，增加了网关设备的使用难度。
技术实现思路
1、基于此，有必要针对上述技术问题，提供一种基于mqtt协议与json报文在数采网关中的数据处理方法和装置。
2、一种基于mqtt协议与json报文在数采网关中的数据处理方法，所述方法包括：
3、配置南向设备的数据采集对象；所述数据采集对象为数据点对应的采集变量；
4、根据需要连接的后台，配置北向mqtt协议以驱动生成云端对象，在所述云端对象下创建发布对象和订阅对象；所述发布对象用于定义将采集的数据通过北向mqtt协议上报到所述后台，所述订阅对象用于定义通过北向mqtt协议对采集的数据进行处理；
5、通过解析所述订阅对象中json格式的订阅变量，将需要采集的数据映射至所述南向设备的所述数据点，以此调用所述南向设备的数据采集协议将所述数据点的采集变量写入所述南向设备，并且通过所述发布对象上报到所述后台。
6、在其中一个实施例中，所述数据采集对象配置为按照分级方式设置的设备、子设备、采集任务以及采集变量。
7、在其中一个实施例中，所述发布对象的配置包括：配置所述发布对象的上报类型、发布主题以及发布包内容。
8、在其中一个实施例中，所述发布包内容中的数据类型包括字符串类和替换函数。
9、在其中一个实施例中，还包括：根据接收到的订阅消息中的数据主题，遍历所述订阅对象得到所述订阅对象对应的json格式的订阅变量，根据json格式的订阅变量中的payload数据以及所述订阅变量关联的所述南向设备的所述数据点，将需要采集的数据映射至所述南向设备的所述数据点。
10、在其中一个实施例中，将json格式的订阅变量与所述南向设备的所述数据点关联方式为通过解析json格式的订阅变量的关键字层级得到。
11、在其中一个实施例中，解析json格式的订阅变量的关键字层级包括解析单个层级或者解析多个层级。
12、一种基于mqtt协议与json报文在数采网关中的数据处理装置，所述装置包括：
13、南向设备配置模块，用于配置南向设备的数据采集对象；所述数据采集对象为数据点对应的采集变量；
14、北向协议配置模块，用于根据需要连接的后台，配置北向mqtt协议以驱动生成云端对象，在所述云端对象下创建发布对象和订阅对象；所述发布对象用于定义将采集的数据通过北向mqtt协议上报到所述后台，所述订阅对象用于定义通过北向mqtt协议对采集的数据进行处理；
15、数据解析模块，用于通过解析所述订阅对象中json格式的订阅变量，将需要采集的数据映射至所述南向设备的所述数据点，以此调用所述南向设备的数据采集协议将所述数据点的采集变量写入所述南向设备，并且通过所述发布对象上报到所述后台。
16、一种计算机设备，包括存储器和处理器，所述存储器存储有计算机程序，所述处理器执行所述计算机程序时实现以下步骤：
17、配置南向设备的数据采集对象；所述数据采集对象为数据点对应的采集变量；
18、根据需要连接的后台，配置北向mqtt协议以驱动生成云端对象，在所述云端对象下创建发布对象和订阅对象；所述发布对象用于定义将采集的数据通过北向mqtt协议上报到所述后台，所述订阅对象用于定义通过北向mqtt协议对采集的数据进行处理；
19、通过解析所述订阅对象中json格式的订阅变量，将需要采集的数据映射至所述南向设备的所述数据点，以此调用所述南向设备的数据采集协议将所述数据点的采集变量写入所述南向设备，并且通过所述发布对象上报到所述后台。
20、一种计算机可读存储介质，其上存储有计算机程序，所述计算机程序被处理器执行时实现以下步骤：
21、配置南向设备的数据采集对象；所述数据采集对象为数据点对应的采集变量；
22、根据需要连接的后台，配置北向mqtt协议以驱动生成云端对象，在所述云端对象下创建发布对象和订阅对象；所述发布对象用于定义将采集的数据通过北向mqtt协议上报到所述后台，所述订阅对象用于定义通过北向mqtt协议对采集的数据进行处理；
23、通过解析所述订阅对象中json格式的订阅变量，将需要采集的数据映射至所述南向设备的所述数据点，以此调用所述南向设备的数据采集协议将所述数据点的采集变量写入所述南向设备，并且通过所述发布对象上报到所述后台。
24、上述基于mqtt协议与json报文在数采网关中的数据处理方法和装置，通过配置南向设备的数据采集对象，将底层设备的数据点精准映射为采集变量，实现了数据的高效获取。该方法还结合北向mqtt协议，根据不同后台需求生成云端对象，通过创建发布对象和订阅对象，实现了数据的灵活传输与处理。在数据处理过程中，利用json格式的订阅变量解析，能够直观地将需要采集的数据映射至南向设备的数据点。这一过程简化了数据的映射和处理操作，降低了系统复杂性，同时保证了数据传输的可靠性和一致性。本发明不仅提高了数采网关的工作效率，还提供了清晰的系统架构和简便的配置流程，使用户能够灵活适应多种应用场景，显著提升了系统的可靠性、通用性和操作便利性。
技术特征：
1.一种基于mqtt协议与json报文在数采网关中的数据处理方法，其特征在于，所述方法包括：
2.根据权利要求1所述的方法，其特征在于，所述数据采集对象配置为按照分级方式设置的设备、子设备、采集任务以及采集变量。
3.根据权利要求1所述的方法，其特征在于，所述发布对象的配置包括：
4.根据权利要求3所述的方法，其特征在于，所述发布包内容中的数据类型包括字符串类和替换函数。
5.根据权利要求1至4任一项所述的方法，其特征在于，通过解析所述订阅对象中json格式的订阅变量，将需要采集的数据映射至所述南向设备的所述数据点，包括：
6.根据权利要求5所述的方法，其特征在于，将json格式的订阅变量与所述南向设备的所述数据点关联方式为通过解析json格式的订阅变量的关键字层级得到。
7.根据权利要求6所述的方法，其特征在于，解析json格式的订阅变量的关键字层级包括解析单个层级或者解析多个层级。
8.一种基于mqtt协议与json报文在数采网关中的数据处理装置，其特征在于，所述装置包括：
9.一种计算机设备，包括存储器和处理器，所述存储器存储有计算机程序，其特征在于，所述处理器执行所述计算机程序时实现权利要求1至7中任一项所述方法的步骤。
10.一种计算机可读存储介质，其上存储有计算机程序，其特征在于，所述计算机程序被处理器执行时实现权利要求1至7中任一项所述的方法的步骤。
技术总结
本申请涉及一种基于Mqtt协议与JSON报文在数采网关中的数据处理方法和装置。所述方法包括：配置南向设备的数据采集对象，根据需要连接的后台，配置北向Mqtt协议以驱动生成云端对象，在云端对象下创建发布对象和订阅对象，通过解析订阅对象中JSON格式的订阅变量，将需要采集的数据映射至南向设备的数据点，以此调用南向设备的数据采集协议将数据点的采集变量写入南向设备，并且通过发布对象上报到后台。采用本方法能够提高了数采网关的工作效率，还提供了清晰的系统架构和简便的配置流程，使用户能够灵活适应多种应用场景，显著提升了系统的可靠性、通用性和操作便利性。
技术研发人员：盛四华,蒋增文,朱立锋,邓子畏,田炜,黄武,万里云,李刚锋,吴善
受保护的技术使用者：中电工业互联网有限公司
技术研发日：
技术公布日：2024/12/5