本发明涉及物联网,尤其涉及一种物联网平台的设备消息处理方法、装置、电子设备及介质。
背景技术:
1、在实际的物联网领域中,存在着物联网设备种类繁多、设备厂家多样,接口不同等多样性,现有市场上多数将物联网设备接入到物联网平台,在物联网平台进行物联网设备的互联互通。在万物互联的今天,接入到物联网平台是海量的设备,设备所上报的设备消息也是海量的,这意味着处理海量设备消息数据需要依赖庞大的计算能力。
2、现有的对物联网平台的设备消息处理方法,由于计算量庞大,导致对设备消息处理方法效率低。
技术实现思路
1、本发明提供一种物联网平台的设备消息处理方法、装置、电子设备及介质,用以解决设备消息处理方法效率低的缺陷,实现提高对设备消息处理的效率。
2、第一方面,本发明提供一种物联网平台的设备消息处理方法,应用于消息传输设备,包括:
3、基于第一物联网设备的设备消息的接收顺序,依次存储所述设备消息;
4、基于所述设备消息的设备编号和所述接收顺序,将已存储的所述设备消息分配至物联网平台的至少一个数据处理单元;其中,所述数据处理单元基于所述设备消息和所述接收顺序,向至少一个第二物联网设备发送控制指令,所述第二物联网设备执行所述控制指令,以完成对所述设备消息的处理,所述数据处理单元的数量是基于所述设备消息的处理量确定的。
5、根据本发明提供的一种物联网平台的设备消息处理方法,所述基于所述设备消息的设备编号和所述接收顺序,将已存储的所述设备消息分配至物联网平台的至少一个数据处理单元,包括:
6、基于已存储的所述设备消息的所述设备编号和匹配信息,确定与所述设备消息关联的目标数据处理单元的单元编号,所述匹配信息为所述设备编号与所述单元编号的关联信息;
7、基于所述接收顺序,将所述设备消息分配至所述单元编号对应的所述目标数据处理单元。
8、根据本发明提供的一种物联网平台的设备消息处理方法,所述基于所述接收顺序,将所述设备消息分配至所述单元编号对应的所述目标数据处理单元之前,还包括:
9、检测各所述数据处理单元的故障信息,并基于所述故障信息,获取更新后的匹配信息;
10、基于已存储的所述设备消息的所述设备编号和更新后的所述匹配信息,确定所述目标数据处理单元的单元编号。
11、根据本发明提供的一种物联网平台的设备消息处理方法,所述基于第一物联网设备的设备消息的接收顺序,依次存储所述设备消息之前,还包括:
12、接收各所述第一物联网设备发送的所述设备消息;
13、基于所述设备消息的接收时间节点的排序结果,确定所述接收顺序;其中,所述第一物联网设备根据触发信息,生成所述设备消息,并基于所述触发信息的产生顺序,确定所述设备消息的发送顺序,以基于所述发送顺序发送所述设备消息,所述发送顺序与所述接收顺序一致。
14、第二方面,本发明提供一种物联网平台的设备消息处理方法,应用于数据处理单元,包括:
15、接收消息传输设备分配的设备消息,并确定所述设备消息的接收顺序;
16、基于所述设备消息和所述接收顺序,向至少一个第二物联网设备发送控制指令;其中,所述第二物联网设备执行所述控制指令,以完成对所述设备消息的处理。
17、根据本发明提供的一种物联网平台的设备消息处理方法,所述基于所述设备消息和所述接收顺序,向至少一个第二物联网设备发送控制指令,包括:
18、基于所述接收顺序,对所述设备消息进行匹配分析,以确定与所述设备消息关联的应用场景;
19、确定与所述应用场景关联的至少一个所述第二物联网设备,并向所述第二物联网设备发送所述控制指令。
20、根据本发明提供的一种物联网平台的设备消息处理方法,所述应用场景至少包括第一物联网设备、触发信息、所述设备消息以及与所述第一物联网设备联动的所述第二物联网设备。
21、第三方面,本发明提供一种物联网平台的设备消息处理装置,所述物联网平台的设备消息处理装置包括第一接收模块、第一发送模块,其中:
22、所述第一接收模块,用于基于第一物联网设备的设备消息的接收顺序,依次存储所述设备消息;
23、所述第一发送模块,用于基于所述设备消息的设备编号和所述接收顺序,将已存储的所述设备消息分配至物联网平台的至少一个数据处理单元;其中,所述数据处理单元基于所述设备消息和所述接收顺序,向至少一个第二物联网设备发送控制指令,所述第二物联网设备执行所述控制指令,以完成对所述设备消息的处理,所述数据处理单元的数量是基于所述设备消息的处理量确定的;
24、或者,所述物联网平台的设备消息处理装置包括第二接收模块、第二发送模块,其中:
25、所述第二接收模块,用于接收消息传输设备分配的设备消息,并确定所述设备消息的接收顺序;
26、所述第二发送模块,用于基于所述设备消息和所述接收顺序,向至少一个第二物联网设备发送控制指令;其中,所述第二物联网设备执行所述控制指令,以完成对所述设备消息的处理。
27、第四方面,本发明提供一种电子设备,包括存储器、处理器及存储在存储器上并可在处理器上运行的计算机程序,所述处理器执行所述程序时实现如上述任一种所述物联网平台的设备消息处理方法的步骤。
28、第五方面,本发明还提供一种非暂态计算机可读存储介质,其上存储有计算机程序,该计算机程序被处理器执行时实现如上述任一种所述物联网平台的设备消息处理方法的步骤。
29、本发明提供的物联网平台的设备消息处理方法、装置、电子设备及介质,基于第一物联网设备的设备消息的接收顺序,依次存储设备消息;基于设备消息的设备编号和接收顺序,将已存储的设备消息分配至物联网平台的至少一个数据处理单元;其中,数据处理单元基于设备消息和接收顺序,向至少一个第二物联网设备发送控制指令,第二物联网设备执行控制指令,以完成对设备消息的处理,数据处理单元的数量是基于设备消息的处理量确定的。本发明实施例根据设备编号,向数据处理单元分配设备消息,提高了对设备消息处理的效率;基于接收顺序,依次分配设备消息,提高了对设备消息处理的准确性;设置多个数据处理单元对设备消息进行处理,在提高对设备消息处理的效率的同时,降低了对处理器的要求,进而降低了对设备消息处理的成本。
1.一种物联网平台的设备消息处理方法,其特征在于,应用于消息传输设备,包括:
2.根据权利要求1所述的物联网平台的设备消息处理方法,其特征在于,所述基于所述设备消息的设备编号和所述接收顺序,将已存储的所述设备消息分配至物联网平台的至少一个数据处理单元,包括:
3.根据权利要求2所述的物联网平台的设备消息处理方法,其特征在于,所述基于所述接收顺序,将所述设备消息分配至所述单元编号对应的所述目标数据处理单元之前,还包括:
4.根据权利要求1所述的物联网平台的设备消息处理方法,其特征在于,所述基于第一物联网设备的设备消息的接收顺序,依次存储所述设备消息之前,还包括:
5.一种物联网平台的设备消息处理方法,其特征在于,应用于数据处理单元,包括:
6.根据权利要求5所述的物联网平台的设备消息处理方法,其特征在于,所述基于所述设备消息和所述接收顺序,向至少一个第二物联网设备发送控制指令,包括:
7.根据权利要求6所述的物联网平台的设备消息处理方法,其特征在于,所述应用场景至少包括第一物联网设备、触发信息、所述设备消息以及与所述第一物联网设备联动的第二物联网设备。
8.一种物联网平台的设备消息处理装置,其特征在于,所述物联网平台的设备消息处理装置包括第一接收模块、第一发送模块,其中:
9.一种电子设备,包括存储器、处理器及存储在所述存储器上并可在所述处理器上运行的计算机程序,其特征在于,所述处理器执行所述计算机程序时实现如权利要求1至7任一项所述物联网平台的设备消息处理方法的步骤。
10.一种非暂态计算机可读存储介质,其上存储有计算机程序,其特征在于,所述计算机程序被处理器执行时实现如权利要求1至7任一项所述物联网平台的设备消息处理方法的步骤。