CN117579713B - 物联设备的数据接入方法、系统、终端设备以及存储介质 - Google Patents

Abstract

本申请涉及物联网技术领域，尤其涉及一种物联设备的数据接入方法、系统、终端设备以及存储介质，本申请基于物联设备的各种复杂环境，以该多运行环境适配器构建打通物联设备与物联平台的数据交互，即通过本申请设计的多运行环境适配器可以兼容物联设备直接与物联平台通信；在物联平台接收到多运行环境适配器上传的物联数据后，物联平台按照预设的规则引擎模型解析物联数据，得到物联设备的结构化业务数据。即通过规则引擎模型进行配置后，可以免代码支持物联设备的数据通信与接入的物联平台，从而实现以免编码的方式有效地提高了物联设备与物联平台之间的数据对接效率。

Description

物联设备的数据接入方法、系统、终端设备以及存储介质

技术领域

本申请涉及物联网技术领域，尤其涉及一种物联设备的数据接入方法、系统、终端设备以及存储介质。

背景技术

随着物联网技术的不断发展，用户对物联设备与物联平台之间的数据对接效率也越来越重视。

传统物联设备对接采用根据设备所开放协议进行二次编码开发，即针对不同协议的设备均需要进行编码实现设备的对接，且如果协议变更的话，又需要重新去修改编解码代码，不仅人力成本极大，且系统内部的逻辑臃肿，进而导致物联设备与物联网平台之间的数据对接效率低下，也就是说，如何提高物联设备与物联平台之间的数据对接效率是目前亟需解决的技术问题。

发明内容

本申请的主要目的在于提供一种物联设备的数据接入方法、系统、终端设备以及存储介质，旨在提高物联设备与物联平台之间的数据对接效率。

为实现上述目的，本申请提供一种物联设备的数据接入方法，所述物联设备的数据接入方法应用于多运行环境适配器，所述多运行环境适配器分别与物联设备和物联平台连接，所述多运行环境适配器为独立运行部件，或者所述多运行环境适配器集成于所述物联平台中；

所述物联设备的数据接入方法包括：

通过所述物联平台构建预设的规则引擎模型；

获取所述物联设备的物联数据，并对所述物联设备的设备协议进行协议适配转换，得到与所述物联平台匹配的通用适配协议，所述物联数据为按照所述设备协议上传的报文码流；

依据所述通用适配协议将所述物联数据发送至所述物联平台，以供所述物联平台按照所述规则引擎模型对所述物联数据进行解析，得到所述物联设备的结构化业务数据。

可选地，所述多运行环境适配器包括数据接收模块、数据采集模块和协议适配器，所述获取所述物联设备的物联数据的步骤包括：

通过所述数据接收模块响应所述物联设备的接入请求，得到所述物联设备的物联数据；或者/和，

通过所述数据采集模块接入所述协议适配器发送的目标设备采集指令，并依据所述物联设备对所述目标设备采集指令做出的响应，得到所述物联设备的物联数据；

所述多运行环境适配器还包括指令发送模块，所述物联设备的数据接入方法还包括：

通过所述指令发送模块接入所述物联平台发送的设备控制指令，依据所述设备控制指令对所述物联设备的设备状态与参数进行调整。

可选地，所述依据所述通用适配协议将所述物联数据发送至所述物联平台的步骤包括：

依据所述设备协议的端口元素确定所述物联数据对应的设备传输协议；

在将所述设备传输协议转换为所述通用适配协议后，通过所述通用适配协议的协议转换端口将所述物联数据透传至所述物联平台。

此外，本申请还提供了一种物联设备的数据接入方法，所述物联设备的数据接入方法还应用于物联平台，所述物联平台通过多运行环境适配器与物联设备连接，所述多运行环境适配器为独立运行部件，或者所述多运行环境适配器集成于所述物联平台中；

所述物联设备的数据接入方法包括：

构建预设的规则引擎模型；

在接收到所述多运行环境适配器依据所述通用适配协议上传的所述物联数据后，按照所述规则引擎模型对所述物联数据进行解析，得到所述物联设备的结构化业务数据；

其中，所述多运行环境适配器设置为获取所述物联设备的物联数据，并对所述物联设备的设备协议进行协议适配转换，得到与所述物联平台匹配的通用适配协议，依据所述通用适配协议将所述物联数据发送至所述物联平台；所述物联数据为按照所述设备协议上传的报文码流。

可选地，所述物联平台包括调用解析模块和规则引擎模块，所述调用解析模块分别与所述多运行环境适配器和所述规则引擎模块连接，所述规则引擎模块设置有所述规则引擎模型；

所述按照所述规则引擎模型对所述物联数据进行解析，得到所述物联设备的结构化业务数据的步骤包括：

当所述调用解析模块接收到所述物联数据时，依据所述物联数据的数据格式触发所述调用解析模块调用所述规则引擎模型，并依据所述规则引擎模型和所述物联数据确定所述物联设备的结构化业务数据。

可选地，所述规则引擎模型设置有多个业务规则，每个业务规则包括一组报文通信属性，以及具有该组报文通信属性的报文码流所遵循的通信协议；

所述依据所述规则引擎模型和所述物联数据确定所述物联设备的结构化业务数据的步骤包括：

解析所述物联数据，得到所述物联数据的目标报文通信属性和目标通信协议；

判断所述目标报文通信属性和所述目标通信协议，是否命中任一所述业务规则；

若命中任一所述业务规则，则依据命中的业务规则对所述目标报文通信属性和所述目标通信协议进行识别，得到所述物联设备的设备类型；

依据所述设备类型和所述物联数据确定所述物联设备的结构化业务数据。

可选地，所述构建预设的规则引擎模型的步骤包括：

获取所述物联设备的物模型元数据和规则元数据，所述物模型元数据为所述物联设备的监测指标的定义描述元素，所述规则元数据为与所述监测指标对应的寻址参数，所述寻址参数至少包括标识符、字节长度和数据类型；

将所述物模型元数据和所述规则元数据进行关联绑定，得到预设的规则引擎模型。

此外，为实现上述目的，本申请还提供一种物联设备的数据接入系统，所述物联设备的数据接入系统包括物联设备、多运行环境适配器和物联平台；

所述多运行环境适配器用于，获取所述物联设备的物联数据，并对所述物联设备的设备协议进行协议适配转换，得到与所述物联平台匹配的通用适配协议，依据所述通用适配协议将所述物联数据发送至所述物联平台；所述物联数据为按照所述设备协议上传的报文码流；

所述物联平台用于，构建预设的规则引擎模型

所述物联平台还用于，接收所述多运行环境适配器按照所述通用适配协议发送的物联数据，并按照所述规则引擎模型对所述物联数据进行解析，得到所述物联设备的结构化业务数据。

此外，为实现上述目的，本申请还提供一种终端设备，所述终端设备包括存储器、处理器及存储在所述存储器上并可在所述处理器上运行的物联设备的数据接入程序，所述物联设备的数据接入程序被所述处理器执行时实现上述物联设备的数据接入方法的步骤。

此外，为实现上述目的，本申请还提供一种计算机可读存储介质，所述计算机可读存储介质上存储有物联设备的数据接入程序，所述物联设备的数据接入程序被处理器执行时实现上述的物联设备的数据接入方法的步骤。

本申请设计了一个多运行环境适配器构建物联设备到物联平台之间的通信链路，从而实现了物联设备可以快速地接入物联平台的目的，然后通过本申请的多运行环境适配器可以及时获取物联设备的物联数据，该物联数据为物联设备按照自身的设备协议上传的报文码流，并对设备协议进行协议适配转换，得到与物联平台匹配的通用适配协议，然后按照通用适配协议将物联数据稳定地发送至物联平台，也就是说，本申请通过多运行环境适配器对设备协议进行协议适配转换，从而满足了物联设备的多业务应用场景便捷接入物联平台的需求，然后通过物联平台构建预设的规则引擎模型，以便物联平台依据接收到的物联数据调用该规则引擎模型解析物联数据，得到物联设备的结构化业务数据，即本申请通过调用预设的规则引擎模型对物联数据进行解析，从而实现以免编码的方式有效地提高了物联设备与物联平台之间的数据对接效率。

附图说明

图1是本申请物联设备的数据接入方法第一实施例的流程示意图；

图2是本申请实施例方案涉及的多运行环境适配器与物联平台的结构示意图；

图3是本申请实施例方案涉及的规则引擎模型可视化还原示意图；

图4是本申请实施例方案涉及的物联设备的数据接入系统的结构示意图；

图5为本申请实施例方案涉及的终端设备的结构示意图。

本申请目的的实现、功能特点及优点将结合实施例，参照附图做进一步说明。

具体实施方式

本申请实施例提供了一种物联设备的数据接入方法，参照图1所示，图1是本申请物联设备的数据接入方法第一实施例的流程示意图。

这里将详细地对示例性实施例进行说明，其示例表示在附图中。下面的描述涉及附图时，除非另有表示，不同附图中的相同数字表示相同或相似的要素。以下示例性实施例中所描述的实施方式并不代表与本申请相一致的所有实施方式。

本实施例中，本申请物联设备的数据接入方法应用于多运行环境适配器，所述多运行环境适配器分别与物联设备和物联平台连接，所述多运行环境适配器为独立运行部件，或者所述多运行环境适配器集成于所述物联平台中。

在本实施例中，本申请设计的多运行环境适配器可以在设备内网环境中单独运行，也可集成在物联平台上运行，其作用是兼容物联设备可直接与物联平台通信，亦可用于多运行环境适配器通信，从而满足了物联设备的多业务应用场景便捷接入物联平台的需求。

本申请物联设备的数据接入方法包括：

步骤S10：通过所述物联平台构建预设的规则引擎模型。

在本实施例中，物联平台基于预设的人机交互界面接入若干个物联设备的物模型元数据和规则元数据，依据若干个物模型元数据和若干个规则元数据构建预设的规则引擎模型，以便物联平台接入多运行环境适配器发送的物理设备的物联数据后，可以及时调用预设的规则引擎模型自适应匹配对应的业务规则解析该物联数据，也就是说，调用预设的规则引擎模型对该物联数据进行数据解析，以便物联平台中的调用解析模块(即非结构化数据解析模块)通过预设的规则引擎模型认知物联数据的报文结构与含义，进而生成物联设备的结构化业务数据。

在另一实施例中，物联平台还涉及有规则引擎的配置，即将物联设备端与物联平台端通信的报文通过引擎定义的元素进行可视化还原，引擎通过对报文以引擎定义的元素配置还原之后，即可优化搭建该规则引擎模型的流程。

需要说明的是，物联数据为物联设备按照自身的设备协议上传的报文码流。本申请中的物联设备的数量有多个，且物联设备包括但不限于环境监测设备、配电箱监测设备、智能水电表设备、照明机电传感器和消防监测传感器等设备。

物联设备自身的设备协议包括但不限于设备厂家TCP/UDP私有协议、modbus、BACnet、SNMP、MQTT、http、webSocket和SDK等协议，且每一物联设备的设备协议有多个。

结构化业务数据是指以固定格式和结构存储的业务数据，通常采用表格形式进行组织和管理，且业务数据与物联设备的设备类型和设备应用场景相关，是用于支持业务系统应用的数据。

步骤S20：获取所述物联设备的物联数据，并对所述物联设备的设备协议进行协议适配转换，得到与所述物联平台匹配的通用适配协议，所述物联数据为按照所述设备协议上传的报文码流。

在本实施例中，物联平台通过多运行环境适配器与物联设备连接，也就是说，通过本申请设计的多运行环境适配器可以兼容物联设备直接与物联平台通信。具体的，多运行环境适配器接收到物联设备按照设备协议上传的报文码流(即物联数据)后，然后将物联数据的设备协议通过协议适配器进行协议适配转换，得到与物联平台匹配的通用适配协议。

在具体实施例中，参照图2，图2是本申请实施例方案涉及的多运行环境适配器与物联平台的结构示意图。多运行环境适配器也称为多运行环境适配模块，多运行环境适配模块至少包括数据接收模块、数据采集模块、指令发送模块和协议适配器，其中，数据接收模块、数据采集模块、指令发送模块分别与协议适配器连接，且数据接收模块与物联设备的第一通信方式对应，数据采集模块与物联设备的第二通信方式对应，指令发送模块与物联设备的第三通信方式对应。

在具体实施例中，多运行环境适配器首先获取物联设备的通信传输方式，当该通信传输方式为物联设备的第一通信方式时，协议适配器通过数据接收模块接入物联设备按照自身的设备协议上传的报文码流。

当该通信传输方式为物联设备的第二通信方式时，通过数据采集模块接入协议适配器发送的目标设备采集指令，并依据物联设备对目标设备采集指令做出的响应，得到物联设备的物联数据，具体的，当数据采集模块接收到该目标设备采集指令后，将该目标设备采集指令发送至与数据采集模块连接的各个物联设备中；然后采集响应于目标设备采集指令的物联设备，按照其自身的设备协议上传的报文码流(即物联数据)。

当该通信传输方式为物联设备的第三通信方式时，指令接收模块通过协议适配器接收到物联平台下发的设备控制指令，并依据所述设备控制指令对所述物联设备的设备状态与参数进行调整。

需要说明的是，第一通信方式可以理解为物联设备主动向协议适配器进行通信交互的过程；第二通信方式可以理解为物联设备依据协议适配器输出的目标设备采集指令被动地向协议适配器进行通信交互的过程；第三通信方式可以理解为依据物联平台下发的设备控制指令对物联设备的设备状态与参数进行调整的过程。

在本实施例中，本申请设计的多运行环境适配器依据物联设备的通信传输方式从数据接收模块、数据采集模块、指令发送模块查找到与通信传输方式适配的通信模块，然后通过适配的通信模块兼容不同物联设备的业务应用场景，从而在各物联设备对应的业务应用场景下，可以快速接入各物联设备对应的物联数据，满足了物联设备的多业务应用场景便捷接入物联平台的需求。

进一步地，在又一实施例中，在上述步骤S20：获取所述物联设备的物联数据之前，所述物联设备的数据接入方法还包括以下实施步骤：

步骤A10：判断物联设备的对接方式是否为IP化通信模式，当物联设备的对接方式为IP化通信模式时，多运行环境适配器则可以直接构建物联设备到物联平台之间的通信链路；当物联设备的对接方式不为IP化通信模式时(即当物联设备的对接方式为非IP化通信模式时)，依据多运行环境适配器中的串口连接通道与物联设备进行通信连接，在通信连接成功后，依据多运行环境适配器中的协议转换模块将物联设备的对接方式从非IP化通信模式调整至IP化通信模式，执行构建物联设备到物联平台之间的通信链路的步骤。

需要说明的是，串口连接通道包括但不限于RS485或RS232，该串口连接通道可以级联串口网关或和同时连接多个串口对端；多运行环境适配器中的无线通信模块包括但不限于蓝牙和RFID射频等。

在本实施例中，本申请设计的多运行环境适配器通过串口连接通道对处于非IP化通信模式下的物联设备进行级联连接后，采用多运行环境适配器中的协议转换模块实现该物联设备以IP化通信方式与物联平台进行通信交互的目的，在物联平台仅支撑IP化通信协议进行数据传输的情况下，有效地避免了传统对接方式需要对非IP化通信模式的物联设备进行针对性选型而存在耗时时间长的现象发生，进一步提高了物联设备接入物联平台的效率。

步骤S30：依据所述通用适配协议将所述物联数据发送至所述物联平台，以供所述物联平台按照所述规则引擎模型对所述物联数据进行解析，得到所述物联设备的结构化业务数据。

在本实施例中，依据该设备协议的端口元素可以准确地得到该物联数据对应的设备传输协议，在将设备传输协议转换为通用适配协议后，通过通用适配协议的协议转换端口将每一物联数据统一透传至物联平台，此时，物联平台按照预设的规则引擎模型解析物联数据，得到物联设备的结构化业务数据。即通过规则引擎模型进行配置后，可以免代码支持物联设备的数据通信与接入的物联平台，从而实现以免编码的方式有效地提高了物联设备与物联平台之间的数据对接效率。

综上，本申请基于物联设备的各种复杂环境，设计了一款多运行环境适配器，并以该多运行环境适配器构建打通物联设备与物联平台的数据交互，从而实现了物联设备可以快速地接入物联平台的目的，具体的，物联平台通过多运行环境适配器与物联设备连接，也就是说，通过本申请设计的多运行环境适配器可以兼容物联设备直接与物联平台通信；在物联平台接收到多运行环境适配器上传的物联数据后，物联平台按照预设的规则引擎模型解析物联数据，得到物联设备的结构化业务数据。即通过规则引擎模型进行配置后，可以免代码支持物联设备的数据通信与接入的物联平台，从而实现以免编码的方式有效地提高了物联设备与物联平台之间的数据对接效率。

进一步地，基于本申请物联设备的数据接入方法的第一实施例，提出本申请物联设备的数据接入方法的第二实施例。

进一步地，在一些可行的实施例中，所述多运行环境适配器包括协议适配器，上述步骤S10：获取所述物联设备的物联数据还可以包括以下实施步骤：

步骤S101：通过所述数据接收模块响应所述物联设备的接入请求，得到所述物联设备的物联数据；或者/和，通过所述数据采集模块接入所述协议适配器发送的目标设备采集指令，并依据所述物联设备对所述目标设备采集指令做出的响应，得到所述物联设备的物联数据。

在本实施例中，数据接收模块会对物联设备的接入请求做出响应，得到物联设备的物联数据，然后通过数据接收模块将该物联数据发送至协议适配器，进而可以通过协议适配器将物联数据透传至物联平台。或者/和，通过数据采集模块接入协议适配器发送的目标设备采集指令，并依据物联设备对目标设备采集指令做出的响应，得到物联设备的物联数据，具体的，当数据采集模块接收到该目标设备采集指令后，将该目标设备采集指令发送至与数据采集模块连接的各个物联设备中；然后采集响应于目标设备采集指令的物联设备，按照其自身的设备协议上传的报文码流(即物联数据)

进一步地，在另一些可行的实施例中，所述多运行环境适配器还包括指令发送模块，所述物联设备的数据接入方法还包括：

步骤B10：通过所述指令发送模块接入所述物联平台发送的设备控制指令，依据所述设备控制指令对所述物联设备的设备状态与参数进行调整。

在本实施例中，物联平台将下发的设备控制指令透传至协议适配器，然后指令接收模块通过协议适配器接收到物联平台下发的设备控制指令，并依据设备控制指令对物联设备的设备状态与参数进行调整。

需要说明的是，设备控制指令包括但不限于环境监测设备中湿度监测阈值的调整指令。设备状态与参数可以理解为设备状态和设备参数，其中，设备状态指的是物联设备运行过程中所处的状态，用于反映设备的运行状况、性能表现和使用情况等方面的信息，且设备状态包括但不限于开机状态、待机状态、关机状态、故障状态和更新状态等。

设备参数是衡量物联设备性能的重要指标，设备参数通常分为电气参数、机械参数和物理参数等几类。其中，电气参数包括但不限于电压、电流、功率等，机械参数包括但不限于速度、转矩、质量等，物理参数包括但不限于温度、湿度、压力等。

在具体实施例中，当环境监测设备通过指令接收模块接收到物联平台下发的湿度监测阈值的调整指令后，环境监测设备依据该调整指令将自身原始湿度阈值自适应调整为该调整指令携带的湿度监测阈值。

进一步地，在另一实施例中，本申请设计的数据接收模块、数据采集模块、指令发送模块实现了模块间相互同步，例如，当物联设备的数量有多个时，依据各物联设备对应的通信传输方式从数据接收模块、数据采集模块、指令发送模块查找到与各物联设备通信传输方式相适配的通信模块，并通过各自适配的通信模块分别接收各物联设备的物联数据，从而满足了物联设备的多业务应用场景便捷接入物联平台的需求。

在本实施例中，本申请设计的数据接收模块和数据采集模块支持扩展，且每类不同的通信协议即为一个独立的协议通信处理对象，部分角色适合在本地端运行，部分角色适合在云端运行，通过该方式兼容不同的运行环境的场景的自动化适配效果。

进一步地，在另一些可行的实施例中，上述步骤S30：依据所述通用适配协议将所述物联数据发送至所述物联平台，还可以包括以下实施步骤：

步骤S301：依据所述设备协议的端口元素确定所述物联数据对应的设备传输协议；

步骤S302：在将所述设备传输协议转换为所述通用适配协议后，通过所述通用适配协议的协议转换端口将所述物联数据透传至所述物联平台。

在本实施例中，参照图2，多运行环境适配器中的协议适配器依据物联设备的设备协议的端口元素确定承载该物联数据的设备传输协议，然后将承载该物联数据的传输协议转换为通用适配协议，并将该物联数据和对应的设备传输协议进行封装后，按照通用适配协议的协议转换端口将封装后的物联数据透传到物联平台中的调用解析模块(即非结构化数据解析模块)中，以便非结构化数据解析模块通过调用预设的规则引擎模型，实现将非结构化的报文码流(即物联数据)解析为物联设备的结构化业务数据，从而提升了物联设备与物联平台之间的数据对接效率。

进一步地，基于本申请物联设备的数据接入方法的第一实施例或者/和第二实施例，提出本申请物联设备的数据接入方法的第三实施例。

本申请物联设备的数据接入方法还应用于物联平台，所述物联平台通过多运行环境适配器与物联设备连接，所述多运行环境适配器为独立运行部件，或者所述多运行环境适配器集成于所述物联平台中；

所述物联设备的数据接入方法还包括以下实施步骤：

步骤C10：构建预设的规则引擎模型。

在本实施例中，物联平台基于预设的人机交互界面接入若干个物联设备的物模型元数据和规则元数据，依据若干个物模型元数据和若干个规则元数据构建预设的规则引擎模型，以便物联平台接入多运行环境适配器发送的物理设备的物联数据后，可以及时调用预设的规则引擎模型自适应匹配对应的业务规则解析该物联数据，也就是说，调用预设的规则引擎模型对该物联数据进行数据解析，以便物联平台中的调用解析模块(即非结构化数据解析模块)通过预设的规则引擎模型认知物联数据的报文结构与含义，进而生成物联设备的结构化业务数据。

在另一实施例中，物联平台还涉及有规则引擎的配置，即将物联设备端与物联平台端通信的报文通过引擎定义的元素进行可视化还原，引擎通过对报文以引擎定义的元素配置还原之后，即可优化搭建该规则引擎模型的流程。

步骤C20：在接收到所述多运行环境适配器依据所述通用适配协议上传的所述物联数据后，按照所述规则引擎模型对所述物联数据进行解析，得到所述物联设备的结构化业务数据；其中，所述多运行环境适配器设置为获取所述物联设备的物联数据，并对所述物联设备的设备协议进行协议适配转换，得到与所述物联平台匹配的通用适配协议，依据所述通用适配协议将所述物联数据发送至所述物联平台；所述物联数据为按照所述设备协议上传的报文码流。

在本实施例中，多运行环境适配器接收到物联设备按照设备协议上传的报文码流(即物联数据)后，然后将物联数据的设备协议通过协议适配器进行协议适配转换，得到与物联平台匹配的通用适配协议。然后依据该设备协议的端口元素可以准确地得到该物联数据对应的设备传输协议，在将设备协议转换为通用适配协议后，通过通用适配协议的协议转换端口将每一物联数据统一透传至物联平台，此时，物联平台按照预设的规则引擎模型解析物联数据，得到物联设备的结构化业务数据。即通过规则引擎模型进行配置后，可以免代码支持物联设备的数据通信与接入的物联平台，从而实现以免编码的方式有效地提高了物联设备与物联平台之间的数据对接效率。

进一步地，在另一实施例中，将物联设备的结构化业务数据以高效的时序存储至数据结构化&业务化模块后，通过数据结构化&业务化模块提供高性能的数据服务，方便应用方对数据的消费和应用。

进一步地，在一些可行的实施例中，所述物联平台包括调用解析模块和规则引擎模块(即规则引擎框架)，所述调用解析模块分别与所述多运行环境适配器和所述规则引擎模块连接，所述规则引擎模块设置有预设的规则引擎模型，上述步骤C20：按照所述规则引擎模型对所述物联数据进行解析，得到所述物联设备的结构化业务数据还包括以下实施步骤：

步骤C201：当所述调用解析模块接收到所述物联数据时，依据所述物联数据的数据格式触发所述调用解析模块调用所述规则引擎模型，并依据所述规则引擎模型和所述物联数据确定所述物联设备的结构化业务数据。

在本实施例中，当调用解析模块接收到多运行环境适配器发送的物联数据时，触发调用解析模块调用规则引擎模块，以便预设的规则引擎模型自适应匹配对应的业务规则解析该物联数据，得到物联设备的结构化业务数据。

需要说明的是，预设的规则引擎模型中设置有多个业务规则，参照图2，预设的规则引擎模型中包括但不限于json业务规则、XML业务规则、私有协议业务规则和特殊协议业务规则，其中，json业务规则的数据格式为json格式，XML业务规则的数据格式为XML格式，私有协议业务规则的数据格式包括但不限于json格式、支持指定地址偏移量+长度、分隔符和类型+长度+数据(即Type+Lenght+Value，简称TLV)；特殊协议业务规则包括但不限于modbus、BACnet和SNMP，且特殊协议业务规则的数据格式是依据特殊协议规则自有的协议特征确定的。

另外，需要说明的是，参照图3，图3是本申请实施例方案涉及的规则引擎模型可视化还原示意图。规则引擎模型即将物联设备端与物联平台通信的报文通过引擎定义的元素进行可视化还原，引擎通过对物联数据以引擎定义的元素配置还原之后，即可认知物联数据中的报文结构与含义，从而对其进行解析。

在具体实施例中，当调用解析模块接收到多运行环境适配器发送的物联数据时，首先确定物联数据的数据格式，当物联数据的数据格式为json格式时，触发调用解析模块调用规则引擎模块中与json格式匹配的json规则引擎模型，然后依据json规则引擎模型对物联数据进行解析，得到物联设备的结构化业务数据。

进一步地，在另一些可行的实施例中，所述规则引擎模型设置有多个业务规则，每个业务规则包括一组报文通信属性，以及具有该组报文通信属性的报文码流所遵循的通信协议，上述步骤C201：并依据所述规则引擎模型和所述物联数据确定所述物联设备的结构化业务数据，还包括以下实施步骤：

步骤C2011：解析所述物联数据，得到所述物联数据的目标报文通信属性和目标通信协议；

在本实施例中，通过调用解析模块对物联数据进行解析，得到该物联数据的目标报文通信属性和目标通信协议。

需要说明的是，预设的规则引擎模型设置有多个业务规则，每个业务规则包括一组报文通信属性，以及具有该组报文通信属性的报文码流所遵循的通信协议；目标报文通信属性包括物联数据的报文IP地址和报文端口。

步骤C2012：判断所述目标报文通信属性和所述目标通信协议，是否命中任一所述业务规则；

在本实施例中，通过调用解析模块判断目标报文通信属性和目标通信协议，是否命中该规则引擎模型中任一业务规则。

步骤C2013：若命中任一所述业务规则，则依据命中的业务规则对所述目标报文通信属性和所述目标通信协议进行识别，得到所述物联设备的设备类型；

在本实施例中，若命中任一业务规则，则依据命中的业务规则对目标报文通信属性和目标通信协议进行识别，得到物联设备的设备类型。

步骤C2014：依据所述设备类型和所述物联数据确定所述物联设备的结构化业务数据。

在本实施例中，获取该设备类型对应的设备监测属性，然后通过预设的规则引擎模型按照该设备监测属性对物联数据进行配置，可以认知物联数据中的报文结构与含义，从而对其进行解析，得到物联设备的结构化业务数据。也就是说，本申请通过规则引擎模型进行配置后，可以免代码支持物联设备的数据通信与接入的物联平台，从而实现以免编码的方式有效地提高了物联设备与物联平台之间的数据对接效率。

进一步地，在一些可行的实施例中，上述步骤C10：构建预设的规则引擎模型，还包括以下实施步骤：

步骤C101：获取所述物联设备的物模型元数据和规则元数据，所述物模型元数据为所述物联设备的监测指标的定义描述元素，所述规则元数据为与所述监测指标对应的寻址参数，所述寻址参数至少包括标识符、字节长度和数据类型；

在本实施例中，通过预设的人机交互界面获取物联设备的物模型元数据和规则元数据，物模型元数据为物联设备的监测指标的定义描述元素，规则元数据为与监测指标对应的寻址参数，该寻址参数至少包括与监测指标对应的标识符、字节长度和数据类型。

需要说明的是，物联设备的监测指标与物联设备的功能类型一一关联，例如，当物联设备为环境监测设备，该环境监测设备的监测指标至少包括二氧化硫、氮氧化物、臭氧、颗粒物、大气温度、湿度、风速和风向等，另外，环境监测设备的监测指标还可以依据用户的需求进行自定义，本申请在此不做任何限制。监测指标的定义描述元素有多个，该定义描述元素可以理解为用机器语言定义某一监测指标表征的具体含义。

另外，需要说明的是，每一寻址参数对应一个物联设备的监测指标，且寻址参数至少包括该监测指标指定的标识符、字节长度和数据类型，具体的，当环境监测设备的监测指标为温度时，温度的标识符为“temperature”，温度的字节长度为自定义的温度所占字节，温度的数据类型依据用户需求进行自定义，且数据类型包括但不限于float(单精度浮点型)和int32(整数型)。另外，本申请的寻址参数可以依据用户的需求进行自定义，本申请在此不做任何限制。

进一步地，在又一实施例，协议分析的方法划分为两类。公共协议采用公共的数据格式进行抽象化提炼其共性格式；而私有协议则根据多个不通厂家的私有协议的报文格式进行分析，提炼其格式的共性特点进行配置上的封装；其中，公共协议承载的数据格式基本以json格式为主，即对公共协议的解析除了协议通信的底座，在数据解析上则采用解析json格式的方式，将非结构化的报文解析为结构化的业务数据对象(即结构化业务数据)。即在规则引擎界面上配置json中各个字段的key,以及其对应的数据类型和业务字段；私有协议在传输层支持TCP与UDP的传输协议，在传输层往上采用多种数据格式支撑报文数据的解析。目前私有协议的数据格式除了json格式之外，支持指定地址偏移量+长度、分隔符、类型+长度+数据(即Type+Lenght+Value,简称TLV)等格式，这四类数据格式能覆盖现有私有协议设备80％以上的设备；另外，针对较少见的共有协议(如：modbus、BACnet、SNMP等)，则根据自有的协议特征进行搭建规则模型。

步骤C102：将所述物模型元数据和所述规则元数据进行关联绑定，得到预设的规则引擎模型。

在本实施例中，参照图2，通过物联平台的规则引擎元数据生成模型生成模块将物模型元数据和规则元数据进行关联绑定，得到预设的规则引擎模型。

综上，本申请体现了多协议与规则的可配置，提升了方案的兼容性和扩展性；同时采用的平台云与本地端模块的混合运行环境，由本地端解决对原有物联引擎在传统工业设备的瓶颈，提升了平台接入设备的多场景与便捷接入的效果。

此外，本申请还提供一种物联设备的数据接入系统，请参照图4，图4是本申请实施例方案涉及的物联设备的数据接入系统的结构示意图。

本申请物联设备的数据接入系统包括物联设备H10、多运行环境适配器H20和物联平台H30；

多运行环境适配器H20用于，获取所述物联设备的物联数据，并对所述物联设备的设备协议进行协议适配转换，得到与所述物联平台H30匹配的通用适配协议，依据所述通用适配协议将所述物联数据发送至所述物联平台H30；所述物联数据为按照所述设备协议上传的报文码流，

所述物联平台H30用于，构建预设的规则引擎模型；

所述物联平台H30还用于，接收所述多运行环境适配器H20按照所述通用适配协议发送的物联数据，并按照所述规则引擎模型对所述物联数据进行解析，得到所述物联设备的结构化业务数据。

可选地，多运行环境适配器H20还用于通过所述数据接收模块响应所述物联设备的接入请求，得到所述物联设备的物联数据；或者/和，通过所述数据采集模块接入所述协议适配器发送的目标设备采集指令，并依据所述物联设备对所述目标设备采集指令做出的响应，得到所述物联设备的物联数据。

可选地，多运行环境适配器H20还用于通过所述指令发送模块接入所述物联平台发送的设备控制指令，依据所述设备控制指令对所述物联设备的设备状态与参数进行调整。

可选地，多运行环境适配器H20还用于依据所述设备协议的端口元素确定所述物联数据对应的设备协议；在将所述设备协议转换为所述通用适配协议后，通过所述适配协议转换端口将所述物联数据透传至所述物联平台

可选地，物联平台H30还用于构建预设的规则引擎模型；在接收到所述多运行环境适配器依据所述通用适配协议上传的所述物联数据后，按照所述规则引擎模型对所述物联数据进行解析，得到所述物联设备的结构化业务数据；其中，所述多运行环境适配器设置为获取所述物联设备的物联数据，并对所述物联设备的设备协议进行协议适配转换，得到与所述物联平台匹配的通用适配协议，依据所述通用适配协议将所述物联数据发送至所述物联平台；所述物联数据为按照所述设备协议上传的报文码流。

可选地，物联平台H30还用于当所述调用解析模块接收到所述物联数据时，依据所述物联数据的数据格式触发所述调用解析模块调用所述规则引擎模型，并依据所述规则引擎模型和所述物联数据确定所述物联设备的结构化业务数据。

可选地，物联平台H30还用于解析所述物联数据，得到所述物联数据的目标报文通信属性和目标通信协议；判断所述目标报文通信属性和所述目标通信协议，是否命中任一所述业务规则；若命中任一所述业务规则，则依据命中的业务规则对所述目标报文通信属性和所述目标通信协议进行识别，得到所述物联设备的设备类型；依据所述设备类型和所述物联数据确定所述物联设备的结构化业务数据。

可选地，物联平台H30还用于获取所述物联设备的物模型元数据和规则元数据，所述物模型元数据为所述物联设备的监测指标的定义描述元素，所述规则元数据为与所述监测指标对应的寻址参数，所述寻址参数至少包括标识符、字节长度和数据类型；将所述物模型元数据和所述规则元数据进行关联绑定，得到预设的规则引擎模型。

此外，本申请还提供一种终端设备。请参照图5，图5为本申请实施例方案涉及的终端设备的结构示意图。本申请实施例终端设备具体可以是为本地运行物联设备的数据接入方法的设备。

如图5所示，本申请实施例终端设备可以包括：处理器1001，例如CPU，通信总线1002，用户接口1003，网络接口1004，存储器1005。其中，通信总线1002用于实现这些组件之间的连接通信。用户接口1003可以包括显示屏(Display)、输入单元比如键盘(Keyboard)，可选用户接口1003还可以包括标准的有线接口、无线接口。网络接口1004可选的可以包括标准的有线接口、无线接口(如Wi-Fi接口)。

存储器1005设置在终端设备主体上，存储器1005上存储有程序，该程序被处理器1001执行时实现相应的操作。存储器1005还用于存储供终端设备使用的参数。存储器1005可以是高速RAM存储器，也可以是稳定的存储器(non-volatile memory)，例如磁盘存储器。存储器1005可选的还可以是独立于前述处理器1001的存储装置。

本领域技术人员可以理解，图5中示出的终端设备结构并不构成对终端设备的限定，可以包括比图示更多或更少的部件，或者组合某些部件，或者不同的部件布置。

如图5所示，作为一种存储介质的存储器1005中可以包括操作系统、网络通信模块、用户接口模块以及终端设备的物联设备的数据接入程序。

在图5所示的终端设备中，处理器1001可以用于调用存储器1005中存储的终端设备的物联设备的数据接入程序，并执行上述物联设备的数据接入方法的步骤。

此外，本申请提供了一种计算机可读存储介质。该计算机可读存储介质上存储有物联设备的数据接入程序，物联设备的数据接入程序被处理器执行时实现上述的物联设备的数据接入方法的步骤。

需要说明的是，在本文中，术语“包括”、“包含”或者其任何其他变体意在涵盖非排他性的包含，从而使得包括一系列要素的过程、方法、物品或者系统不仅包括那些要素，而且还包括没有明确列出的其他要素，或者是还包括为这种过程、方法、物品或者系统所固有的要素。在没有更多限制的情况下，由语句“包括一个……”限定的要素，并不排除在包括该要素的过程、方法、物品或者系统中还存在另外的相同要素。

上述本申请实施例序号仅仅为了描述，不代表实施例的优劣。

通过以上的实施方式的描述，本领域的技术人员可以清楚地了解到上述实施例方法可借助软件加必需的通用硬件平台的方式来实现，当然也可以通过硬件，但很多情况下前者是更佳的实施方式。基于这样的理解，本申请的技术方案本质上或者说对现有技术做出贡献的部分可以以软件产品的形式体现出来，该计算机软件产品存储在如上述的一个计算机可读存储介质(如ROM/RAM、磁碟、光盘)中，包括若干指令用以使得一台终端设备(可以是手机，计算机，服务器，或者网络设备等)执行本申请各个实施例所述的方法。

以上仅为本申请的优选实施例，并非因此限制本申请的专利范围，凡是利用本申请说明书及附图内容所作的等效结构或等效流程变换，或直接或间接运用在其他相关的技术领域，均同理包括在本申请的专利保护范围内。

Claims (10)

1.一种物联设备的数据接入方法，其特征在于，所述物联设备的数据接入方法应用于多运行环境适配器，所述多运行环境适配器分别与物联设备和物联平台连接，所述多运行环境适配器为独立运行部件，或者所述多运行环境适配器集成于所述物联平台中；

所述物联设备的数据接入方法包括：

通过所述物联平台构建预设的规则引擎模型；

获取所述物联设备的物联数据，并对所述物联设备的设备协议进行协议适配转换，得到与所述物联平台匹配的通用适配协议，所述物联数据为按照所述设备协议上传的报文码流；

依据所述通用适配协议将所述物联数据发送至所述物联平台，以供所述物联平台按照所述规则引擎模型对所述物联数据进行解析，得到所述物联设备的结构化业务数据；

在所述获取所述物联设备的物联数据的步骤之前，所述物联设备的数据接入方法包括：

判断所述物联设备的对接方式是否为IP化通信模式；

当所述物联设备的对接方式为IP化通信模式时，构建所述物联设备到所述物联平台之间的通信链路；

当所述物联设备的对接方式不为IP化通信模式时，依据所述多运行环境适配器中的串口连接通道与所述物联设备进行通信连接，在所述通信连接成功后，依据多运行环境适配器中的协议转换模块将所述物联设备的对接方式从非IP化通信模式调整至IP化通信模式后，执行所述构建物联设备到物联平台之间的通信链路的步骤；

所述获取所述物联设备的物联数据的步骤包括：

在所述物联设备到所述物联平台之间的通信链路构建完成后，获取所述物联设备的通信传输方式；

当所述通信传输方式为第一通信方式时，所述多运行环境适配器中的协议适配器通过数据接收模块接入物联设备的物联数据，所述第一通信方式为所述物联设备主动向所述协议适配器进行通信交互的过程；

当所述通信传输方式为第二通信方式时，所述多运行环境适配器中的数据采集模块接入所述协议适配器发送的目标设备采集指令，并依据所述物联设备对所述目标设备采集指令做出的响应，得到所述物联设备的物联数据，所述第二通信方式为所述物联设备依据所述协议适配器输出的目标设备采集指令被动地向所述协议适配器进行通信交互的过程。

2.如权利要求1所述物联设备的数据接入方法，其特征在于，所述多运行环境适配器还包括指令发送模块，所述物联设备的数据接入方法还包括：

通过所述指令发送模块接入所述物联平台发送的设备控制指令，依据所述设备控制指令对所述物联设备的设备状态与参数进行调整。

3.如权利要求1所述物联设备的数据接入方法，其特征在于，所述依据所述通用适配协议将所述物联数据发送至所述物联平台的步骤包括：

依据所述设备协议的端口元素确定所述物联数据对应的设备传输协议；

在将所述设备传输协议转换为所述通用适配协议后，通过所述通用适配协议的协议转换端口将所述物联数据透传至所述物联平台。

4.一种物联设备的数据接入方法，其特征在于，所述物联设备的数据接入方法还应用于物联平台，所述物联平台通过多运行环境适配器与物联设备连接，所述多运行环境适配器为独立运行部件，或者所述多运行环境适配器集成于所述物联平台中；

所述物联设备的数据接入方法包括：

构建预设的规则引擎模型；

在接收到所述多运行环境适配器依据通用适配协议上传的所述物联数据后，按照所述规则引擎模型对所述物联数据进行解析，得到所述物联设备的结构化业务数据；

其中，所述多运行环境适配器设置为获取所述物联设备的物联数据，并对所述物联设备的设备协议进行协议适配转换，得到与所述物联平台匹配的通用适配协议，依据所述通用适配协议将所述物联数据发送至所述物联平台；所述物联数据为按照所述设备协议上传的报文码流；

所述多运行环境适配器还被设置为判断所述物联设备的对接方式是否为IP化通信模式；当所述物联设备的对接方式为IP化通信模式时，构建所述物联设备到所述物联平台之间的通信链路；当所述物联设备的对接方式不为IP化通信模式时，依据所述多运行环境适配器中的串口连接通道与所述物联设备进行通信连接，在所述通信连接成功后，依据多运行环境适配器中的协议转换模块将所述物联设备的对接方式从非IP化通信模式调整至IP化通信模式后，执行所述构建物联设备到物联平台之间的通信链路的步骤；

所述多运行环境适配器还被设置为在所述物联设备到所述物联平台之间的通信链路构建完成后，获取所述物联设备的通信传输方式；当所述通信传输方式为第一通信方式时，所述多运行环境适配器中的协议适配器通过数据接收模块接入物联设备的物联数据，所述第一通信方式为所述物联设备主动向所述协议适配器进行通信交互的过程；当所述通信传输方式为第二通信方式时，所述多运行环境适配器中的数据采集模块接入所述协议适配器发送的目标设备采集指令，并依据所述物联设备对所述目标设备采集指令做出的响应，得到所述物联设备的物联数据，所述第二通信方式为所述物联设备依据所述协议适配器输出的目标设备采集指令被动地向所述协议适配器进行通信交互的过程。

5.如权利要求4所述物联设备的数据接入方法，其特征在于，所述物联平台包括调用解析模块和规则引擎模块，所述调用解析模块分别与所述多运行环境适配器和所述规则引擎模块连接，所述规则引擎模块设置有所述规则引擎模型；

所述按照所述规则引擎模型对所述物联数据进行解析，得到所述物联设备的结构化业务数据的步骤包括：

当所述调用解析模块接收到所述物联数据时，依据所述物联数据的数据格式触发所述调用解析模块调用所述规则引擎模型，并依据所述规则引擎模型和所述物联数据确定所述物联设备的结构化业务数据。

6.如权利要求5所述物联设备的数据接入方法，其特征在于，所述规则引擎模型设置有多个业务规则，每个业务规则包括一组报文通信属性，以及具有该组报文通信属性的报文码流所遵循的通信协议；

所述依据所述规则引擎模型和所述物联数据确定所述物联设备的结构化业务数据的步骤包括：

解析所述物联数据，得到所述物联数据的目标报文通信属性和目标通信协议；

判断所述目标报文通信属性和所述目标通信协议，是否命中任一所述业务规则；

若命中任一所述业务规则，则依据命中的业务规则对所述目标报文通信属性和所述目标通信协议进行识别，得到所述物联设备的设备类型；

依据所述设备类型和所述物联数据确定所述物联设备的结构化业务数据。

7.如权利要求4所述物联设备的数据接入方法，其特征在于，所述构建预设的规则引擎模型的步骤包括：

获取所述物联设备的物模型元数据和规则元数据，所述物模型元数据为所述物联设备的监测指标的定义描述元素，所述规则元数据为与所述监测指标对应的寻址参数，所述寻址参数至少包括标识符、字节长度和数据类型；

将所述物模型元数据和所述规则元数据进行关联绑定，得到预设的规则引擎模型。

8.一种物联设备的数据接入系统，其特征在于，所述物联设备的数据接入系统包括物联设备、多运行环境适配器和物联平台；

所述多运行环境适配器用于，获取所述物联设备的物联数据，并对所述物联设备的设备协议进行协议适配转换，得到与所述物联平台匹配的通用适配协议，依据所述通用适配协议将所述物联数据发送至所述物联平台；所述物联数据为按照所述设备协议上传的报文码流；

所述物联平台用于，构建预设的规则引擎模型；

所述物联平台还用于，接收所述多运行环境适配器按照所述通用适配协议发送的物联数据，并按照所述规则引擎模型对所述物联数据进行解析，得到所述物联设备的结构化业务数据；

所述多运行环境适配器还用于判断物联设备的对接方式是否为IP化通信模式；当物联设备的对接方式为IP化通信模式时，构建物联设备到物联平台之间的通信链路；当物联设备的对接方式不为IP化通信模式时，依据所述多运行环境适配器中的串口连接通道与物联设备进行通信连接，在通信连接成功后，依据多运行环境适配器中的协议转换模块将物联设备的对接方式从非IP化通信模式调整至IP化通信模式后，执行构建物联设备到物联平台之间的通信链路的步骤；

所述多运行环境适配器还用于在所述物联设备到所述物联平台之间的通信链路构建完成后，获取所述物联设备的通信传输方式；当所述通信传输方式为第一通信方式时，所述多运行环境适配器中的协议适配器通过数据接收模块接入物联设备的物联数据，所述第一通信方式为所述物联设备主动向所述协议适配器进行通信交互的过程；当所述通信传输方式为第二通信方式时，所述多运行环境适配器中的数据采集模块接入所述协议适配器发送的目标设备采集指令，并依据所述物联设备对所述目标设备采集指令做出的响应，得到所述物联设备的物联数据，所述第二通信方式为所述物联设备依据所述协议适配器输出的目标设备采集指令被动地向所述协议适配器进行通信交互的过程。

9.一种终端设备，其特征在于，所述终端设备包括存储器、处理器及存储在所述存储器上并可在所述处理器上运行的物联设备的数据接入程序，所述处理器执行所述物联设备的数据接入程序时实现如权利要求1至3，或者/和权利要求4至7中任一项所述物联设备的数据接入方法的步骤。

10.一种存储介质，所述存储介质为计算机可读存储介质，其特征在于，所述计算机可读存储介质上存储有物联设备的数据接入程序，所述物联设备的数据接入程序被处理器执行时实现如权利要求1至3，或者/和权利要求4至7中任一项所述物联设备的数据接入方法的步骤。