(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202211055937.X (22)申请日 2022.08.31 (71)申请人 瀚云科技有限公司 地址 214135 江苏省无锡市新吴区菱湖大 道111号无锡软件园天鹅座B栋1 111室 (72)发明人 李靖宇　何渝君　王翔　舒忠玲　 (74)专利代理 机构 深圳市远航专利商标事务所 (普通合伙) 44276 专利代理师 田志远　张朝阳 (51)Int.Cl. G06F 9/50(2006.01) G06F 9/54(2006.01) (54)发明名称 一种工业互联网平台的设备数据处理方法 及系统 (57)摘要 本发明涉及一种工业互联网平台的设备数 据处理方法及系统， 其中方法为： 建立一个与接 入机所在链路并行的、 并可将原始数据转换成标 准数据的数据处理服务， 该数据处理服务获取接 入机上传的原始数据并执行数据处理， 使得接入 机所在链路仅做数据传输。 本发 明通过建立数据 处理服务， 接入机不负责业务处理， 只需要接收、 上传数据， 实现数据上传和数据处理的解耦； 从 而实现在不断开设备与平台的连接， 不丢失数据 的前提下， 同时不用改变硬件的开发逻辑， 不需 要第三方应用端额外做数据处理， 也能够将不同 数据模型、 表达的却是相同意义的设备数据， 处 理为标准 化数据， 供第三方应用端分析使用。 权利要求书2页 说明书6页 附图1页 CN 115357397 A 2022.11.18 CN 115357397 A 1.一种工业互联网平台的设备数据处理方法， 其特征在于， 建立一个与接入机所在链 路并行的、 并可将原始数据转换成标准数据的数据 处理服务， 该数据 处理服务获取接入机 上传的原 始数据并执 行数据处理， 使得接入机所在链路仅做数据传输， 包括如下步骤： 步骤1、 接入机作为Kafka系统的生产端， 将原 始数据发送到Kafka系统的第一主题中； 步骤2、 建立一个数据处理服务作为Kafk a系统的第一消费端， 从Kafka系统的第一主题 中消费原 始数据； 步骤3、 数据处 理服务查询预先上传的数据转 化脚本； 步骤4、 数据处理服务执行与原始数据对应的数据转换脚本， 将原始数据转换为标准数 据， 发送到Kafka系统的第二主题中待其 他消费端消费。 2.根据权利要求1所述的工业互联网平台的设备数据处理方法， 其特征在于， 所述接入 机为MQTT服务器， 不同的设备通过MQT T协议将各自的原 始数据发送到 MQTT服务器。 3.根据权利要求1所述的工业互联网平台的设备数据处理方法， 其特征在于， 所述步骤 3包括如下步骤： S301、 预先上传数据转换脚本； S302、 数据服 务查询对应的数据转换脚本 。 4.根据权利要求3所述的工业互联网平台的设备数据处理方法， 其特征在于， 所述上传 数据转换脚本， 具体为： 利用控制台将数据转换脚本以消息的形式发送至RabbitMQ系统的其中一个消息队列， 数据处理服务订阅该消息队列， 并获取脚本消息； 数据处理服务解析所述脚本消息， 并 以productKey与streamName的组合为键名， 将所 述脚本消息更新到 本地缓存 装置。 5.根据权利要求4所述的工业互联网平台的设备数据处理方法， 其特征在于， 所述控制 台还包括用于删除Rab bitMQ系统消息队列中的脚本消息 。 6.根据权利要求4所述的工业互联网平台的设备数据处理方法， 其特征在于， 所述数据 服务查询对应的数据转换脚本， 具体为： 查询本地缓存 装置中的脚本消息； 判断是否存在与原始数据对应的脚本消息， 对应规则包括： 原始数据与脚本消息携带 的键名一 致； 若存在， 则进入步骤4， 执 行该脚本消息； 若不存在， 则直接将原 始数据发送到Kafka系统的第二主题。 7.根据权利要求1所述的工业互联网平台的设备数据处理方法， 其特征在于， 所述数据 转换脚本为JS脚本， JS脚本的方法名为dataStream_productKey_streamName(byte)， 其中 dataStream表示脚本作用于数据流， productKey表示设备所属产品的唯一标识， streamName表示数据流模型的标识， byte表示设备原 始数据的二进制流。 8.根据权利要求7所述的工业互联网平台的设备数据处理方法， 其特征在于， 所述数据 转换脚本的方法内容包括修改原始数据的结构、 修改数据类型、 修改值， 所述数据转换脚本 的返回值 为设备的标准数据。 9.根据权利要求1所述的工业互联网平台的设备数据处理方法， 其特征在于， 在步骤4 之后还包括： 步骤5、 第三方应用端作为Kafka系统的第二消费端， 从Kafka系统的第二主题权　利　要　求　书 1/2 页 2 CN 115357397 A 2中消费数据。 10.一种工业互联网平台的设备数据处理系统， 用于运行如权利要求1至9任一项所述 的工业互联网平台的设备数据处理方法， 其特征在于， 包括Kafka系统和RabbitMQ系统， 还 包括： 若干设备， 用于生成、 传输原 始数据； 接入机， 用于接收设备的原始数据， 并作为Kafka系统的生产端将原始数据生产至 Kafka系统； 数据处理服务， 作为Kafka系统的第一消费端， 用于从Kafka系统的第一主题中消费数 据， 并发送数据到Kafka系统的第二主题； 数据处理服务还作为RabbitMQ系统的消费端， 用 于从RabbitMQ系统获取、 解析消息； 本地缓存 装置， 用于存 储数据处 理服务解析后的脚本消息； 控制台， 作为Rab bitMQ系统的生产端， 用于发送脚本消息； 第三方应用端， 作为Kafka系统的第二消费端， 用于从Kafka系统的第二主题中消费数 据。权　利　要　求　书 2/2 页 3 CN 115357397 A 3