一种车联网数据交互方法、装置及计算机程序产品与流程

本发明涉及车联网，具体涉及一种车联网数据交互方法、装置及计算机程序产品。

背景技术：

1、在车联网领域，数据上传目前存在多种方式，主要包括mqtt、http以及文件数据上传。

2、就文件数据上传而言，其在实际应用中面临诸多问题。在车端，由于各云厂商存储服务存在差异，车端需要针对不同云厂商进行定制化开发以实现接入，这一过程涉及大量的适配工作，不仅工作量庞大，而且开发效率极为低下。

3、现阶段车端常用的数据上传方案为：车端应用首先对业务数据进行序列化处理，之后借助mqtt协议将数据传输至云端。当车端待上传的数据量过大时，受限于相关硬件条件以及mqtt通道自身效率较低等因素，通过长连接mqtt方式完成数据上传会变得十分困难。若采用文件上传方式，每次文件上传结束后，车端必须将上传结果通知云端，以确保数据的完整性和准确性，所有确认步骤完成后，才能继续以相同流程传输下一文件，传输效率较低。

技术实现思路

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、本发明还提供一种车联网数据交互装置，包括：

30、一个或多个处理器；

31、存储器；

32、一个或多个应用程序，其中所述一个或多个应用程序被存储在所述存储器中并被配置为由所述一个或多个处理器执行，所述一个或多个应用程序被配置用于执行所述的车联网数据交互方法。

33、本发明还提供一种计算机程序产品，包括计算机指令，所述计算机指令指示计算机设备执行所述方法对应的操作。

34、实施本发明具有如下有益效果：本发明使车端直接从云端服务器获取待上传文件的存储链接，直接上传数据到各云存储，无需关心多云接入；同时将确认消息和下一个请求相结合，减少请求云端服务，简化了车端与云端的交互流程，减少了通信开销，并有效降低了云端实时数仓的存储和处理费用，实现了成本节约与资源优化。同时，本发明还能够无缝对接不同云厂商的对象存储服务，确保了数据上传的灵活性和广泛性。并且，通过本发明提出的分层存储结构和智能查询机制，实现了数据的快速检索，无需在收到文件时即时对数据进行繁琐的解析，从而替代了传统的实时数仓方案。本发明不仅极大地提升了数据检索效率，还显著降低了单车数据的存储成本，为车辆数据的大规模存储和管理提供了高效、经济的解决方案。

1.一种车联网数据交互方法，其特征在于，包括以下步骤：

2.根据权利要求1所述的方法，其特征在于，所述文件基于时间序列的信号列存储，其标识信息至少包括所述文件的文件名，所述文件名包含生成所述文件的时间戳信息。

3.根据权利要求1所述的方法，其特征在于，车端向云端服务器发送确认消息后，接收云端服务器反馈的确认收到消息，所述确认收到消息包含下一次请求的文件的存储链接。

4.根据权利要求1所述的方法，其特征在于，还包括：车端通过关联的客户端向云端服务器发送查询请求，所述请求中包含有查询条件。

5.一种车联网数据交互方法，其特征在于，包括以下步骤：

6.根据权利要求5所述的方法，其特征在于，还包括：

7.根据权利要求5所述的方法，其特征在于，所述云端服务器根据所述标识信息生成所述文件的存储密钥，具体包括：

8.根据权利要求5所述的方法，其特征在于，还包括：云端服务器接收车端通过关联的客户端发送的查询请求，从中解析得到包含在所述请求中的查询条件，并根据所述查询条件生成查询密钥。

9.根据权利要求8所述的方法，其特征在于，云端服务器根据所述查询条件生成查询密钥具体包括：

10.根据权利要求8所述的方法，其特征在于，还包括：

11.一种车联网数据交互装置，其特征在于，所述车联网数据交互装置设置于车端，包括：

12.一种车联网数据交互装置，其特征在于，所述车联网数据交互装置设置于云端服务器，包括：

13.一种车联网数据交互装置，其特征在于，包括：

14.一种计算机程序产品，其特征在于，包括计算机指令，所述计算机指令指示计算机设备执行如权利要求1至10任一项所述方法对应的操作。