(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210600132.2 (22)申请日 2022.05.30 (71)申请人 重庆忽米网络科技有限公司 地址 400041 重庆市高新区万科023创意天 地万科锦尚4幢3单 元 (72)发明人 巩书凯　陈虎　卢仁谦　梁先黎　 王艺谚　 (74)专利代理 机构 重庆博凯知识产权代理有限 公司 50212 专利代理师 黄河 (51)Int.Cl. H04L 67/56(2022.01) H04L 69/08(2022.01) H04L 69/18(2022.01) H04L 69/40(2022.01)G06F 9/50(2006.01) G06F 16/215(2019.01) G16Y 20/00(2020.01) G16Y 30/00(2020.01) G16Y 40/10(2020.01) (54)发明名称 基于分布式的工业设备数据处理系统及方 法 (57)摘要 本发明涉及物联网数据处理技术领域， 具体 涉及基于分布式的工业设备数据处理系统及方 法， 该系统包括端点代理模块、 命令集群模块、 数 采集群模块和数据处理模块； 端点代理模块集成 在被采集端， 所述被采集端包括直连装置端和直 连网关端； 数据处理模块中设置有协议转换器； 协议转换器中设置有代理管理单元和多个转换 单元， 每个转换单元均有唯一的转换ID； 代理管 理单元用于设置数据采集指令并发送给命令集 群模块， 所述数据采集指令包括采集地址和转换 ID； 命令集群模块用于将 接收到的数据采集指令 发送给采集地址对应的端点代理模块； 端点代理 模块内设置有多个不同协议的线程。 本方法可以 有效降低服 务器的压力。 权利要求书2页 说明书6页 附图1页 CN 114945039 A 2022.08.26 CN 114945039 A 1.基于分布式的工业设备数据处理系统， 其特征在于： 包括端点代理模块、 命令集群模 块、 数采集群模块和数据处理模块； 端点代理模块集成在被采集端， 所述被采集端包括直连 装置端和直连网关端； 数据处理模块中设置有协议转换器； 协议转换器中设置有代理管理单元和多个转换单 元， 每个转换单元均有唯一的转换ID； 代理管理单元用于设置数据采集指令并发送给命令 集群模块， 所述数据采集指令包括采集地址和转换ID； 命令集群模块用于将接收到的数据 采集指令发送给采集 地址对应的端点代理模块； 端点代理模块内设置有多个不同协议的线程； 端点代理模块用于接收到数据采集指令 后， 获取采集地址中的数据作为采集数据， 并调用与采集数据的协议相对应的线程， 将采集 数据与对应的转换ID一起 发送给数采集群模块； 数采集群模块用于将端点代理模块 发送的 采集数据发送给对应转换ID的转换单元； 转换单元用于将接收到的采集数据进 行协议转换 处理。 2.如权利要求1所述的基于分布式的工业设备数据处理系统， 其特征在于： 所述被采集 端还包括子网网关； 所述子网网关的网段内包括多个中转网关及直连 的设备， 所述中转网 关连接有设备， 中转网关用于将连接的设备的数据发送给子网网关； 还包括端点管理器， 端 点管理器集成在子网网关， 用于管理子网网关的网段内的设备数据； 端点管理器内构建有 多个线程池， 各线程池分别与子网网段内各设备 的数据协议相对应； 同一子网网关中的端 点管理器与端点代理模块通信； 若端点代理模块若与端点管理器通信， 则端点管理器接 收 到数据采集指令后， 从端点管理器中获取采集 地址中的数据。 3.如权利要求1所述的基于分布式的工业设备数据处理系统， 其特征在于： 命令集群模 块包括上行命令单元和下行命令单元； 上行命令单元与代理管理单元通信， 用于接 收代理 管理单元中的数据采集指令； 下行命令单元与端点代理模块通信， 用于将数据采集指令发 送给端点代理模块。 4.如权利要求3所述的基于分布式的工业设备数据处理系统， 其特征在于： 端点代理模 块还用于接收到数据采集指令后， 根据获取设备数据的结果向下行命令单元反馈指令配置 完成情况， 所述指令配置完成情况包括配置成功或配置失败； 上行命令单元还用于将指令 配置完成情况发送给代理管理单 元。 5.如权利要求4所述的基于分布式的工业设备数据处理系统， 其特征在于： 转换单元还 用于将采集数据进行协议 转换处理后， 以Jso n格式数据存 储或转发至目标地址中。 6.如权利要求5所述的基于分布式的工业设备数据处理系统， 其特征在于： 端点代理模 块内的线程包括 IOTClient、 MQT TClient、 EMQXClient、 HTTPClient和modbusC client。 7.如权利要求6所述的基于分布式的工业设备数据处理系统， 其特征在于： 所述数据采 集指令还包括数据采集频率和数据清洗规则； 端点代理模块接 收到数据采集指令后， 按照 数据采集频率获取采集 地址中的数据， 并按照数据清洗规则进行清洗后得到采集数据。 8.如权利要求1所述的基于分布式的工业设备数据处理系统， 其特征在于： 所述数据处 理模块中设置的协议 转换器的数量大于一。 9.基于分布式的工业设备数据处理方法， 其特征在于， 使用权利要求1 ‑8任一项所述的 基于分布式的工业设备 数据处理系统， 包括以下步骤： S1、 在代理管理单元中设置数据采集指令， 所述数据采集指令包括采集地址和转换ID；权　利　要　求　书 1/2 页 2 CN 114945039 A 2并将数据采集指令发送给命令集群模块； S2、 命令集群模块将数据采集指令发送给采集 地址对应的端点代理模块； S3、 端点代理模块获取采集地址中的数据作为采集数据， 并调用与采集数据的协议相 对应的线程， 将采集数据与对应的转换ID一 起发送给 数采集群模块； S4、 数采集群将端点代理模块发送的采集数据发送给对应转换ID的转换 单元； S5、 转换单元将接收到的采集数据进行协议转换处理后， 以Json格式数据存储或转发 至目标地址中。 10.如权利要求8所述的基于分布式的工业设备数据处理方法， 其特征在于： S1中， 所诉 数据采集指令还包括数据采集频率和数据清洗规则； S3中， 端点代理模块按数据采集频率 获取采集 地址中的数据， 并按照数据清洗规则进行 数据清洗后得到采集数据。权　利　要　求　书 2/2 页 3 CN 114945039 A 3