数据接入处理方法、装置、电子设备和可读存储介质与流程

1.本公开涉及人工智能领域，尤其涉及智能交通、自动驾驶、物联网技术领域，具体涉及一种数据接入处理方法、装置、电子设备和可读存储介质。

背景技术：

2.将数据接入云端是车辆与设备智能化、网联化的重要环节，因此数据接入是一项长期的工作。而智能网联设备与车辆本身及其衍生数据也在不断的变化发展，数据接入需要应对多种类路侧设备、车端数据的迭代更新。目前，智能网联设备和车辆数据的接入方式通常是面向某个特定使用场景或是数据接入需求来开发特定的数据接入服务，以实现数据接入。

技术实现要素：

3.本公开提供了一种数据接入处理方法、装置、电子设备和可读存储介质。
4.根据本公开的第一方面，提供了一种数据接入处理方法，包括：
5.获取目标设备对应的通讯协议和数据解析协议；
6.根据所述目标设备对应的通讯协议，配置所述目标设备对应的数据接入服务集；
7.获取所述目标设备基于所述通讯协议上传至所述数据接入服务集的目标数据，并基于所述数据解析协议对所述目标数据进行解析处理；
8.将解析处理后的所述目标数据发送至目标存储节点。
9.根据本公开的第二方面，提供了一种数据接入处理装置，包括：
10.第一获取模块，用于获取目标设备对应的通讯协议和数据解析协议；
11.第一配置模块，用于根据所述目标设备对应的通讯协议，配置所述目标设备对应的数据接入服务集；
12.处理模块，用于获取所述目标设备基于所述通讯协议上传至所述数据接入服务集的目标数据，并基于所述数据解析协议对所述目标数据进行解析处理；
13.第一发送模块，用于将解析处理后的所述目标数据发送至目标存储节点。
14.根据本公开的第三方面，提供了一种电子设备，包括：
15.至少一个处理器；以及
16.与所述至少一个处理器通信连接的存储器；其中，
17.所述存储器存储有可被所述至少一个处理器执行的指令，所述指令被所述至少一个处理器执行，以使所述至少一个处理器能够执行第一方面所述的方法。
18.根据本公开的第四方面，提供了一种存储有计算机指令的非瞬时计算机可读存储介质，其中，所述计算机指令用于使所述计算机执行第一方面所述的方法。
19.根据本公开的第五方面，提供了一种计算机程序产品，包括计算机程序，所述计算机程序在被处理器执行时实现第一方面所述的方法。
20.本公开实施例中，服务平台能够根据通讯协议为不同设备灵活地配置数据接入服务集，使得服务平台不再只能接收特定设备的数据，有效提升了服务平台的应用场景和范围。
21.应当理解，本部分所描述的内容并非旨在标识本公开的实施例的关键或重要特征，也不用于限制本公开的范围。本公开的其它特征将通过以下的说明书而变得容易理解。
附图说明
22.附图用于更好地理解本方案，不构成对本公开的限定。其中：
23.图1是本公开实施例提供的一种数据接入处理方法的流程图；
24.图2是应用本公开实施例提供的一种数据接入处理方法的场景示意图；
25.图3是本公开实施例提供的一种数据接入处理装置的结构图之一；
26.图4是本公开实施例提供的一种数据接入处理装置的结构图之二；
27.图5是本公开实施例提供的一种数据接入处理装置的结构图之三；
28.图6是用来实现本公开实施例的数据接入处理方法的电子设备的框图。
具体实施方式
29.以下结合附图对本公开的示范性实施例做出说明，其中包括本公开实施例的各种细节以助于理解，应当将它们认为仅仅是示范性的。因此，本领域普通技术人员应当认识到，可以对这里描述的实施例做出各种改变和修改，而不会背离本公开的范围和精神。同样，为了清楚和简明，以下的描述中省略了对公知功能和结构的描述。
30.请参照图1，图1是本公开实施例提供的一种数据接入处理方法的流程图，如图1所示，所述方法包括以下步骤：
31.步骤s101、获取目标设备对应的通讯协议和数据解析协议。
32.需要说明地，本公开实施例所提供的数据接入处理方法可以是应用于数据接入服务器，所述服务器也可以称为对数据接入服务进行管理的服务平台。为更好地理解，后续实施例中将以服务平台作为执行主体对本公开实施例的具体实现方式进行解释说明。
33.本公开实施例中，所述目标设备也可称为负载，例如所述目标设备可以为网联车、第三方云平台、路侧单元(road side unit，rsu)、边缘计算技术(mobile edge computing，mec)设备、信号控制器、智能灯杆、智能交通灯等。所述目标设备与服务平台通信连接，进而所述目标设备能够与所述服务平台之间进行数据传输。可以理解地，不同类型的目标设备对应的通讯协议可能不同，也即不同类型的目标设备与服务平台之间需要基于对应的通讯协议来实现数据传输。另外，不同类型的目标设备对应的数据解析协议也可能不同，而服务平台在获取到目标设备上传的数据后，需要基于对应的数据解析协议对上传的数据进行处理。
34.可选地，服务平台可以是先确定目标设备，也即确定是哪一种设备，然后获取该目标设备对应的通讯协议和数据解析协议。例如，服务平台可以是预先存储有不同设备各自对应的通讯协议和数据解析协议，在确定目标设备后，例如服务平台可以是接收用户输入的设备名称来确定目标设备，服务平台获取预先存储的通讯协议和数据解析协议中与所述目标设备匹配的通讯协议和数据解析协议。
35.可选地，所述通讯协议包括但不限于http协议、tcp协议、udp协议、websocket协议等；所述数据解析协议包括但不限于json协议、bytes协议、protobuf协议等。
36.步骤s102、根据所述目标设备对应的通讯协议，配置所述目标设备对应的数据接入服务集。
37.该步骤中，服务平台在获取目标设备对应的通讯协议和数据解析协议后，则基于所述目标设备对应的通讯协议，为所述目标设备配置对应的数据接入服务集，进而目标设备需要上传至服务平台的数据能够上传至该目标设备对应的数据接入服务集。
38.本公开实施例中，不同类型的目标设备对应的通讯协议不同，也即不同类型的目标设备需要通过其各自对应的通讯协议进行数据传输，服务平台根据不同类型目标设备各自对应的通讯协议，为每个类型目标设备创建其对应的数据接入服务集，进而服务平台也就能够接收多种类型目标设备上传的数据，使得服务平台的应用场景更为广阔。
39.需要说明地，服务平台配置目标设备对应的数据接入服务集，可以是包括为所述目标设备配置对应的接入通道，进而目标设备通过特定的接入通道接入所述数据接入服务集，并通过所述接入通道实现数据上传。
40.步骤s103、获取所述目标设备基于所述通讯协议上传至所述数据接入服务集的目标数据，并基于所述数据解析协议对所述目标数据进行解析处理。
41.本公开实施例中，服务平台在基于目标设备对应的通讯协议，为所述目标设备配置对应的数据接入服务集后，则目标设备能够基于所述通讯协议将需要上传的目标数据上传至所述数据接入服务集，进而服务平台也就能够获取到目标设备上传的目标数据。进一步地，服务平台能够基于所述目标设备对应的数据解析协议对所述目标数据进行解析处理。例如目标设备可以是将所述目标数据打包上传，则服务平台基于对应的数据解析协议对打包的目标数据进行解析处理。
42.可选地，所述解析处理还可以是包括对所述目标数据进行筛选或修改等操作。例如，服务平台可以是基于预设的筛选原则对所述目标数据进行筛选，如过滤掉所述目标数据中格式不正确或是重复的数据，或是根据业务端对数据的需求过滤掉所述目标数据中业务端不需要的数据；等等。进而，通过对所述目标数据进行筛选，也就能够有效降低目标数据的数据量，从而节省所述目标数据所占据的存储空间。
43.需要说明地，所述服务平台对所述目标数据进行修改，例如可以是对所述目标数据中格式不正确的数据进行修正，或者是对所述目标数据进行增加、删除等修改操作，例如可以是基于python或是java等处理方式对所述目标数据进行修改，本公开对此不做过多赘述。
44.步骤s104、将解析处理后的所述目标数据发送至目标存储节点。
45.其中，所述目标存储节点可以是预设的存储节点，例如所述目标存储节点可以是预设的消息队列或是数据库；或者所述目标存储节点也可以是服务平台为所述目标设备配置的存储节点。进而，服务平台在完成对目标数据的解析处理后，将解析处理后的目标数据发送至目标存储节点，进而以实现对目标数据的接收和发送。
46.本公开实施例中，服务平台通过获取目标设备对应的通讯协议，配置所述目标设备对应的数据接入服务集，并接收目标设备基于所述通讯协议上传至所述数据接入服务集的目标数据，进而也就使得服务平台能够根据通讯协议为不同设备灵活地配置数据接
入服务集，使得服务平台不再只能接收特定设备的数据，有效提升了服务平台的应用场景和范围。另外，服务平台在接收到目标设备上传的目标数据后，还能够基于目标设备对应的数据解析协议对所述目标数据进行解析处理，并将解析处理后的目标数据发送至目标存储节点，进而服务平台也就不仅能实现对数据的接收，还能够实现对数据的发送，避免服务平台存储过多的数据而占据存储空间。
47.可选地，所述将解析处理后的所述目标数据发送至目标存储节点之前，所述方法还包括：
48.识别对所述目标数据有获取需求的业务端，将所述业务端配置为所述目标数据的目标存储节点。
49.需要说明地，服务平台可以与多个业务端建立通信连接，例如对于需要从服务平台获取数据的业务端，可以预先接入服务平台，进而以从服务平台获取相关数据。服务平台在对目标设备配置数据接入服务集后，可以是进一步识别对目标设备的数据有获取需求的业务端，并将这些业务端配置为所述目标设备的目标存储节点，进而当服务平台获取到目标设备上传至数据接入服务集的目标数据后，将所述目标数据发送至所述目标存储节点，也即发送给对所述目标数据有获取需求的业务端，以保障业务端对所述目标数据的及时获取。
50.本公开实施例中，服务平台在为目标设备配置数据接入服务集后，还能够对目标设备上传的目标数据配置对应的目标存储节点，从而也就能够灵活地控制对于目标数据的传输走向，使得服务平台对于目标数据的管理更为灵活，也更具主动性，并且也能够避免目标数据对于服务平台存储空间的占据，有效释放服务平台的存储空间。
51.可选地，本公开实施例中，所述配置所述目标设备对应的数据接入服务集之后，所述方法还包括：
52.获取所述目标设备对应的数据类型，在所述数据接入服务集中配置与所述数据类型对应的数据接入服务子集；
53.所述获取所述目标设备基于所述通讯协议上传至所述数据接入服务集的目标数据，包括：
54.获取所述目标设备基于所述通讯协议上传至第一子集的目标数据；
55.其中，所述数据接入服务子集包括所述第一子集，所述第一子集对应的数据类型为所述目标数据的数据类型。
56.需要说明地，即使对于同一类型的目标设备，该类型目标设备也可以是包括多种数据类型，例如所述数据类型可以是与设备版本相关，或者数据类型也可以是同一类型下不同个体的目标设备各自对应的数据，等等。
57.示例性地，假设所述目标设备为网联车，网联车的数据类型可以是基于不同个体的网联车进行划分，例如网联车a对应一类数据类型，网联车b对应一类数据类型，网联车c对应一类数据类型
……
进而，不同的网联车也就对应不同的数据类型。服务平台在获取目标设备对应的数据类型后，则在所述数据接入服务集中配置与所述数据类型对应的数据接入服务子集，也即数据类型与数据接入服务子集之间是一一对应的，从而通过配置不同的数据接入服务子集，也就使得服务平台能够对数据接入服务集进行更好的管理。
58.进一步地，在所述数据接入服务集中创建对应于不同数据类型的数据接入服务
子集后，对于目标设备上传的目标数据，服务平台根据所述目标数据对应的数据类型，将所述目标数据上传至对应的数据接入服务子集(也即所述第一子集)中。这样，服务平台也就能够根据目标设备的数据类型在对应的数据接入服务集中配置多个数据接入服务子集，从而即使对于同一类型的目标设备，也能够根据数据类型的不同，将目标数据基于数据类型保存至不同的数据接入服务子集中，从而以实现对目标设备的不同数据类型的数据的分类保存，能够更好地实现对目标设备上传的目标数据的管理。
59.可选地，所述在所述数据接入服务集中配置与所述数据类型对应的数据接入服务子集之后，所述方法还包括：
60.获取所述目标设备下线的数据类型；
61.识别所述数据接入服务集中与所述下线的数据类型对应的第二子集，删除所述第二子集。
62.可以理解地，目标设备能够对其数据类型进行更新。例如，若所述目标设备的数据类型与目标设备的版本相关，则当目标设备更新迭代为新版本时，则所述目标设备的数据类型也会相应地更新为最新版本，这种情况下，则目标设备可以是下线旧版本，则旧版本对应的数据类型也同样会下线，也即目标设备不会再生成与下线的数据类型对应的数据。
63.本公开实施例中，服务平台还能够获取目标设备下线的数据类型，也即目标设备不再使用的数据类型，进一步识别所述数据接入服务集中与所述下线的数据类型对应的第二子集，并删除所述第二子集。这样，也就能够使得服务平台能够及时删除没有使用需求的数据接入服务子集，更好地实现对数据接入服务子集的管理。
64.需要说明地，本公开实施例中，服务平台能够根据目标设备的数据类型，在所述数据接入服务集中创建对应的数据接入服务子集，进而以实现对所述数据接入服务集的扩容；而对于目标设备已经下线的数据类型，服务平台能够及时删除已下线的数据类型对应的数据接入服务子集，从而以实现对数据接入服务集的缩容，避免对数据接入服务集的存储空间的占用。
65.进一步地，所述方法还可以包括以下步骤：
66.在所述目标设备存在数据响应需求的情况下，配置与所述数据响应需求对应的响应消息格式；
67.在将解析处理后的所述目标数据发送至目标存储节点之后，基于所述响应消息格式向所述目标设备发送响应消息，所述响应消息用于指示解析处理后的所述目标数据已发送至所述目标存储节点。
68.需要说明地，对于某些类型目标设备，当服务平台将目标设备上传到的目标数据发送给目标存储节点后，目标设备要求数据接收方按要求返回响应消息。例如，某些雷达设备会要求数据接收方按要求返回响应消息。
69.本公开实施例中，当所述目标设备存在数据响应需求，也即目标设备要求数据接收方返回响应消息，对于这类型目标设备，服务平台还能够配置与所述数据响应需求对应的响应消息格式。其中，所述响应消息格式可以是根据目标设备的数据响应需求来配置，例如所述数据响应需求中可以是包括期望得到的数据信息，则服务平台根据期望得到的数据信息来配置响应消息格式。在服务平台将解析处理后的所述目标数据发送至目标存储节点之后，服务平台基于所述响应消息格式向目标设备发送响应消息，所述响应消息也就包含
所述目标设备期望得到的数据信息，进而目标设备能够及时获知服务平台已将目标数据发送至对应的目标存储节点，从而目标设备也就能够确定目标数据传输阶段的完成并及时进入下一阶段业务流程，从而保障目标设备对于相关业务流程的有序推进。
70.可选地，服务平台在将解析处理后的所述目标数据发送至目标存储节点之后，也可以是基于所述响应消息格式向所述目标存储节点发送请求信息，该请求信息用于指示目标存储节点反馈响应消息；所述目标存储节点接收到请求消息后，向所述服务平台发送响应消息，该响应消息用于表征所述目标存储节点已接收到服务平台发送的目标数据，还可以包括其他所述目标设备期望得到的数据信息；进一步地，服务平台将所述响应消息发送给目标设备，以确保目标设备能够及时获知所述目标数据已发送给目标存储节点，从而使得目标设备能够进入下一阶段的业务流程。
71.可选地，所述方法还可以包括：
72.获取所述数据接入服务集对应的日志信息；
73.基于所述日志信息判断所述数据接入服务集是否能执行对所述目标数据的接收和/或发送；
74.在所述数据接入服务集未能执行对所述目标数据的接收和/或发送的情况下，对所述数据接入服务集的配置进行调整，或者重新配置所述目标设备对应的数据接入服务集。
75.本公开实施例中，服务平台还可以是实时地或者是按照预设周期获取所述数据接入服务集对应的日志信息，所述日志信息能够表征是否接收了所述目标数据、接收所述目标数据的时间、是否发送了所述目标数据以及发送所述目标数据的时间等。进而，所述服务平台也就能够基于所述日志信息来判断所述数据接入服务集是否执行了对所述目标数据的接收和/或发送。
76.进一步地，若服务平台基于所述日志信息发现所述数据接入服务集未能执行对所述目标数据的接收和/或发送，例如日志信息中未记载有接收和/或发送目标数据的相关信息，则认为数据接入服务集不能成功执行对目标数据的接收和/或发送，这种情况下，则服务平台可以对所述数据接入服务集的配置进行调整，例如可能是因为数据接入服务集的存储空间不够而导致不能正常接收目标数据，则服务平台可以是对所述数据接入服务集进行扩容；或者，服务平台也可以是重新配置所述目标设备对应的数据接入服务集，以确保对目标设备上传的目标数据的正常接收。
77.需要说明地，若基于所述日志信息确定数据接入服务集能够正常执行对目标数据的接收和/或发送，也即说明服务平台针对所述目标设备配置的数据接入服务集能够正常运行。进一步地，服务平台获取所述数据接入服务集对应的地址信息，并可以将所述地址信息配置到目标设备中并启动目标设备，从而目标设备也就能够按照所述地址信息，将目标数据上传至对应的数据接入服务集中，从而以保障其他业务端(也即目标存储节点)对目标数据的获取。
78.请参照图2，图2是本公开实施例提供的一种数据接入处理方法的场景示意图，以下将结合图2对本公开实施例提供的数据接入处理方法进行解释说明。
79.需要说明地，本公开实施例提供的数据接入处理方法可以是应用于如上所述的服务平台，所述服务平台提供有用户界面，服务平台能够接收用户作用于用户界面上的操作
来执行对目标设备对应的数据接入服务集的配置。例如，所述用户界面上可以是提供用供用户选择的多种类型的目标设备，如图2中所示的网联车、第三方云平台、rsu、mec设备、信号控制器、智能灯杆等，用户可以从中选择出一种目标设备，服务平台根据用户做出的选择操作，获取与该目标设备对应的通讯协议和数据解析协议，并根据所述目标设备对应的通讯协议，为该目标设备配置对应的数据接入服务集(也可称为数据接入通道服务集)，如图2中所示的数据接入服务集1、数据接入服务集2
……
数据接入服务集n。不同的数据接入服务集也就对应不同类型的目标设备，其中，服务平台可以是通过负载均衡来实现对多个目标设备与多个数据接入服务集之间的管理。
80.需要说明地，服务平台可以是包括服务管理模块，通过该服务管理模块来实现对数据接入服务集的配置和管理。其中，对于每一个数据接入服务集，服务平台还可以通过服务管理模块来对所述数据接入服务集进行扩容和缩容，例如可以根据目标设备的数据类型为数据接入服务集创建多个数据接入服务子集，如图2中所示的接入服务1、接入服务2
……
接入服务n，进而以实现对数据接入服务集的扩容。另外，服务管理模块还能够根据目标设备已下线的数据类型，及时删除对应的接入服务，进而以实现对数据接入服务集的缩容。
81.进一步地，目标设备在将目标数据上传至对应的数据接入服务集后，服务平台可以是将所述数据接入服务集中的数据发送至下一存储节点，如图2中所示的消息队列(如kafka消息队列)或是数据库(如关系型数据库管理系统(mysql)等)。从而，服务平台也就能够灵活地控制对于目标数据的传输走向。通过创建对应于不同目标设备的数据接入服务集，使得服务平台对于目标数据的管理更为灵活，提升了服务平台的应用场景。
82.请参照图3，图3是本公开实施例提供的一种数据接入处理装置的结构图之一，如图3所示，所述数据接入处理装置300包括：
83.第一获取模块301，用于获取目标设备对应的通讯协议和数据解析协议；
84.第一配置模块302，用于根据所述目标设备对应的通讯协议，配置所述目标设备对应的数据接入服务集；
85.处理模块303，用于获取所述目标设备基于所述通讯协议上传至所述数据接入服务集的目标数据，并基于所述数据解析协议对所述目标数据进行解析处理；
86.第一发送模块304，用于将解析处理后的所述目标数据发送至目标存储节点。
87.可选地，请进一步参照图4，所述数据接入处理装置300还包括：
88.第二配置模块305，用于获取所述目标设备对应的数据类型，在所述数据接入服务集中配置与所述数据类型对应的数据接入服务子集；
89.所述处理模块303还用于：
90.获取所述目标设备基于所述通讯协议上传至第一子集的目标数据；
91.其中，所述数据接入服务子集包括所述第一子集，所述第一子集对应的数据类型为所述目标数据的数据类型。
92.可选地，请进一步参照图5，所述数据接入处理装置300还包括：
93.第二获取模块306，用于获取所述目标设备下线的数据类型；
94.删除模块307，用于识别所述数据接入服务集中与所述下线的数据类型对应的第二子集，删除所述第二子集。
95.可选地，所述数据接入处理装置300还包括：
96.第三配置模块，用于识别对所述目标数据有获取需求的业务端，将所述业务端配置为所述目标数据的目标存储节点。
97.可选地，所述数据接入处理装置300还包括：
98.第四配置模块，用于在所述目标设备存在数据响应需求的情况下，配置与所述数据响应需求对应的响应消息格式；
99.第二发送模块，用于在将解析处理后的所述目标数据发送至目标存储节点之后，基于所述响应消息格式向所述目标设备发送响应消息，所述响应消息用于指示解析处理后的所述目标数据已发送至所述目标存储节点。
100.可选地，所述数据接入处理装置300还包括：
101.第三获取模块，用于获取所述数据接入服务集对应的日志信息；
102.判断模块，用于基于所述日志信息判断所述数据接入服务集是否能执行对所述目标数据的接收和/或发送；
103.所述处理模块还用于：在所述数据接入服务集未能执行对所述目标数据的接收和/或发送的情况下，对所述数据接入服务集的配置进行调整，或者重新配置所述目标设备对应的数据接入服务集。
104.本公开实施例提供的数据接入处理装置300，能够根据通讯协议为不同设备灵活地配置数据接入服务集，使得服务平台不再只能接收特定设备的数据，有效提升了服务平台的应用场景和范围。
105.需要说明地，本公开实施例提供的数据接入处理装置300能够实现上述图1和图2所述的数据接入处理方法的全部技术过程，并能够达到相同的技术效果，为避免重复，此处不再赘述。
106.本公开的技术方案中，所涉及的用户个人信息的获取，存储和应用等，均符合相关法律法规的规定，且不违背公序良俗。
107.根据本公开的实施例，本公开还提供了一种电子设备、一种可读存储介质和一种计算机程序产品。
108.图6示出了可以用来实施本公开的实施例的示例电子设备600的示意性框图。电子设备旨在表示各种形式的数字计算机，诸如，膝上型计算机、台式计算机、工作台、个人数字助理、服务器、刀片式服务器、大型计算机、和其它适合的计算机。电子设备还可以表示各种形式的移动装置，诸如，个人数字处理、蜂窝电话、智能电话、可穿戴设备和其它类似的计算装置。本文所示的部件、它们的连接和关系、以及它们的功能仅仅作为示例，并且不意在限制本文中描述的和/或者要求的本公开的实现。
109.如图6所示，设备600包括计算单元601，其可以根据存储在只读存储器(rom)602中的计算机程序或者从存储单元608加载到随机访问存储器(ram)603中的计算机程序，来执行各种适当的动作和处理。在ram 603中，还可存储设备600操作所需的各种程序和数据。计算单元601、rom 602以及ram 603通过总线604彼此相连。输入/输出(i/o)接口605也连接至总线604。
110.设备600中的多个部件连接至i/o接口605，包括：输入单元606，例如键盘、鼠标等；输出单元607，例如各种类型的显示器、扬声器等；存储单元608，例如磁盘、光盘等；以及通
信单元609，例如网卡、调制解调器、无线通信收发机等。通信单元609允许设备600通过诸如因特网的计算机网络和/或各种电信网络与其他设备交换信息/数据。
111.计算单元601可以是各种具有处理和计算能力的通用和/或专用处理组件。计算单元601的一些示例包括但不限于中央处理单元(cpu)、图形处理单元(gpu)、各种专用的人工智能(ai)计算芯片、各种运行机器学习模型算法的计算单元、数字信号处理器(dsp)、以及任何适当的处理器、控制器、微控制器等。计算单元601执行上文所描述的各个方法和处理，例如上述数据接入处理方法。例如，在一些实施例中，数据接入处理方法可被实现为计算机软件程序，其被有形地包含于机器可读介质，例如存储单元608。在一些实施例中，计算机程序的部分或者全部可以经由rom 602和/或通信单元609而被载入和/或安装到设备600上。当计算机程序加载到ram 603并由计算单元601执行时，可以执行上文描述的数据接入处理方法的一个或多个步骤。备选地，在其他实施例中，计算单元601可以通过其他任何适当的方式(例如，借助于固件)而被配置为执行数据接入处理方法。
112.本文中以上描述的系统和技术的各种实施方式可以在数字电子电路系统、集成电路系统、场可编程门阵列(fpga)、专用集成电路(asic)、专用标准产品(assp)、芯片上系统的系统(soc)、负载可编程逻辑设备(cpld)、计算机硬件、固件、软件、和/或它们的组合中实现。这些各种实施方式可以包括：实施在一个或者多个计算机程序中，该一个或者多个计算机程序可在包括至少一个可编程处理器的可编程系统上执行和/或解释，该可编程处理器可以是专用或者通用可编程处理器，可以从存储系统、至少一个输入装置、和至少一个输出装置接收数据和指令，并且将数据和指令传输至该存储系统、该至少一个输入装置、和该至少一个输出装置。
113.用于实施本公开的方法的程序代码可以采用一个或多个编程语言的任何组合来编写。这些程序代码可以提供给通用计算机、专用计算机或其他可编程数据处理装置的处理器或控制器，使得程序代码当由处理器或控制器执行时使流程图和/或框图中所规定的功能/操作被实施。程序代码可以完全在机器上执行、部分地在机器上执行，作为独立软件包部分地在机器上执行且部分地在远程机器上执行或完全在远程机器或服务器上执行。
114.在本公开的上下文中，机器可读介质可以是有形的介质，其可以包含或存储以供指令执行系统、装置或设备使用或与指令执行系统、装置或设备结合地使用的程序。机器可读介质可以是机器可读信号介质或机器可读储存介质。机器可读介质可以包括但不限于电子的、磁性的、光学的、电磁的、红外的、或半导体系统、装置或设备，或者上述内容的任何合适组合。机器可读存储介质的更具体示例会包括基于一个或多个线的电气连接、便携式计算机盘、硬盘、随机存取存储器(ram)、只读存储器(rom)、可擦除可编程只读存储器(eprom或快闪存储器)、光纤、便捷式紧凑盘只读存储器(cd-rom)、光学储存设备、磁储存设备、或上述内容的任何合适组合。
115.为了提供与用户的交互，可以在计算机上实施此处描述的系统和技术，该计算机具有：用于向用户显示信息的显示装置(例如，crt(阴极射线管)或者lcd(液晶显示器)监视器)；以及键盘和指向装置(例如，鼠标或者轨迹球)，用户可以通过该键盘和该指向装置来将输入提供给计算机。其它种类的装置还可以用于提供与用户的交互；例如，提供给用户的反馈可以是任何形式的传感反馈(例如，视觉反馈、听觉反馈、或者触觉反馈)；并且可以用任何形式(包括声输入、语音输入或者、触觉输入)来接收来自用户的输入。
116.可以将此处描述的系统和技术实施在包括后台部件的计算系统(例如，作为数据服务器)、或者包括中间件部件的计算系统(例如，应用服务器)、或者包括前端部件的计算系统(例如，具有图形用户界面或者网络浏览器的用户计算机，用户可以通过该图形用户界面或者该网络浏览器来与此处描述的系统和技术的实施方式交互)、或者包括这种后台部件、中间件部件、或者前端部件的任何组合的计算系统中。可以通过任何形式或者介质的数字数据通信(例如，通信网络)来将系统的部件相互连接。通信网络的示例包括：局域网(lan)、广域网(wan)和互联网。
117.计算机系统可以包括客户端和服务器。客户端和服务器一般远离彼此并且通常通过通信网络进行交互。通过在相应的计算机上运行并且彼此具有客户端-服务器关系的计算机程序来产生客户端和服务器的关系。服务器可以是云服务器，也可以为分布式系统的服务器，或者是结合了区块链的服务器。
118.应该理解，可以使用上面所示的各种形式的流程，重新排序、增加或删除步骤。例如，本公开中记载的各步骤可以并行地执行也可以顺序地执行也可以不同的次序执行，只要能够实现本公开公开的技术方案所期望的结果，本文在此不进行限制。
119.上述具体实施方式，并不构成对本公开保护范围的限制。本领域技术人员应该明白的是，根据设计要求和其他因素，可以进行各种修改、组合、子组合和替代。任何在本公开的精神和原则之内所作的修改、等同替换和改进等，均应包含在本公开保护范围之内。

技术特征：

1.一种数据接入处理方法，包括：获取目标设备对应的通讯协议和数据解析协议；根据所述目标设备对应的通讯协议，配置所述目标设备对应的数据接入服务集；获取所述目标设备基于所述通讯协议上传至所述数据接入服务集的目标数据，并基于所述数据解析协议对所述目标数据进行解析处理；将解析处理后的所述目标数据发送至目标存储节点。2.根据权利要求1所述的方法，其中，所述配置所述目标设备对应的数据接入服务集之后，所述方法还包括：获取所述目标设备对应的数据类型，在所述数据接入服务集中配置与所述数据类型对应的数据接入服务子集；所述获取所述目标设备基于所述通讯协议上传至所述数据接入服务集的目标数据，包括：获取所述目标设备基于所述通讯协议上传至第一子集的目标数据；其中，所述数据接入服务子集包括所述第一子集，所述第一子集对应的数据类型为所述目标数据的数据类型。3.根据权利要求2所述的方法，其中，所述在所述数据接入服务集中配置与所述数据类型对应的数据接入服务子集之后，所述方法还包括：获取所述目标设备下线的数据类型；识别所述数据接入服务集中与所述下线的数据类型对应的第二子集，删除所述第二子集。4.根据权利要求1所述的方法，其中，所述将解析处理后的所述目标数据发送至目标存储节点之前，所述方法还包括：识别对所述目标数据有获取需求的业务端，将所述业务端配置为所述目标数据的目标存储节点。5.根据权利要求1-4中任一项所述的方法，还包括：在所述目标设备存在数据响应需求的情况下，配置与所述数据响应需求对应的响应消息格式；在将解析处理后的所述目标数据发送至目标存储节点之后，基于所述响应消息格式向所述目标设备发送响应消息，所述响应消息用于指示解析处理后的所述目标数据已发送至所述目标存储节点。6.根据权利要求1-4中任一项所述的方法，还包括：获取所述数据接入服务集对应的日志信息；基于所述日志信息判断所述数据接入服务集是否能执行对所述目标数据的接收和/或发送；在所述数据接入服务集未能执行对所述目标数据的接收和/或发送的情况下，对所述数据接入服务集的配置进行调整，或者重新配置所述目标设备对应的数据接入服务集。7.一种数据接入处理装置，包括：第一获取模块，用于获取目标设备对应的通讯协议和数据解析协议；
第一配置模块，用于根据所述目标设备对应的通讯协议，配置所述目标设备对应的数据接入服务集；处理模块，用于获取所述目标设备基于所述通讯协议上传至所述数据接入服务集的目标数据，并基于所述数据解析协议对所述目标数据进行解析处理；第一发送模块，用于将解析处理后的所述目标数据发送至目标存储节点。8.根据权利要求7所述的装置，其中，所述装置还包括：第二配置模块，用于获取所述目标设备对应的数据类型，在所述数据接入服务集中配置与所述数据类型对应的数据接入服务子集；所述处理模块还用于：获取所述目标设备基于所述通讯协议上传至第一子集的目标数据；其中，所述数据接入服务子集包括所述第一子集，所述第一子集对应的数据类型为所述目标数据的数据类型。9.根据权利要求8所述的装置，其中，所述装置还包括：第二获取模块，用于获取所述目标设备下线的数据类型；删除模块，用于识别所述数据接入服务集中与所述下线的数据类型对应的第二子集，删除所述第二子集。10.根据权利要求7所述的装置，其中，所述装置还包括：第三配置模块，用于识别对所述目标数据有获取需求的业务端，将所述业务端配置为所述目标数据的目标存储节点。11.根据权利要求7-10中任一项所述的装置，其中，所述装置还包括：第四配置模块，用于在所述目标设备存在数据响应需求的情况下，配置与所述数据响应需求对应的响应消息格式；第二发送模块，用于在将解析处理后的所述目标数据发送至目标存储节点之后，基于所述响应消息格式向所述目标设备发送响应消息，所述响应消息用于指示解析处理后的所述目标数据已发送至所述目标存储节点。12.根据权利要求7-10中任一项所述的装置，其中，所述装置还包括：第三获取模块，用于获取所述数据接入服务集对应的日志信息；判断模块，用于基于所述日志信息判断所述数据接入服务集是否能执行对所述目标数据的接收和/或发送；所述处理模块还用于：在所述数据接入服务集未能执行对所述目标数据的接收和/或发送的情况下，对所述数据接入服务集的配置进行调整，或者重新配置所述目标设备对应的数据接入服务集。13.一种电子设备，包括：至少一个处理器；以及与所述至少一个处理器通信连接的存储器；其中，所述存储器存储有可被所述至少一个处理器执行的指令，所述指令被所述至少一个处理器执行，以使所述至少一个处理器能够执行权利要求1-6中任一项所述的方法。14.一种存储有计算机指令的非瞬时计算机可读存储介质，其中，所述计算机指令用于使所述计算机执行根据权利要求1-6中任一项所述的方法。
15.一种计算机程序产品，包括计算机程序，所述计算机程序在被处理器执行时实现根据权利要求1-6中任一项所述的方法。

技术总结

本公开提供了一种数据接入处理方法、装置、电子设备和可读存储介质，涉及人工智能领域，尤其涉及智能交通、自动驾驶、物联网技术领域。具体实现方案为：获取目标设备对应的通讯协议和数据解析协议；根据所述目标设备对应的通讯协议，配置所述目标设备对应的数据接入服务集；获取所述目标设备基于所述通讯协议上传至所述数据接入服务集的目标数据，并基于所述数据解析协议对所述目标数据进行解析处理；将解析处理后的所述目标数据发送至目标存储节点。储节点。储节点。