CN105242882B - 时序数据的帧存储方法及装置、时序数据查询方法及装置 - Google Patents

Abstract

本发明提供了一种时序数据的帧存储方法及装置、时序数据查询方法及装置。其中，该帧存储方法包括：接收数据源设备发送的存储请求，存储请求包括待存储时序数据、数据源设备的设备标识和设备描述信息；根据设备标识，从预先创建的存储空间中获取设备标识对应的内存段中的数据标志；当数据标志指示为旧数据时，将待存储时序数据和设备描述信息存储到内存段中；当数据标志指示为新数据时，将预先创建的存储空间中的所有数据组成帧数据，将帧数据存储在数据文件中。在本发明中时序数据只存储一份，大大减少了存储时序数据所需的存储空间的大小，提高了存储时序数据的存储效率，且同时存储了设备描述信息，从而能够支持多维度的高效查询。

Description

时序数据的帧存储方法及装置、时序数据查询方法及装置

技术领域

本发明涉及数据存储技术领域，具体而言，涉及一种时序数据的帧存储方法及装置、时序数据查询方法及装置。

背景技术

时序数据是指时间序列数据，例如，车辆GPS(Global Positioning System)数据和气象台测的环境温度数据等都是时序数据。由于时序数据的数据量很大，如何实现时序数据的存储已成为急需解决的问题。

当前，相关技术中提供了一种存储时序数据的方法，包括：根据数据源设备的特性对数据源设备传输的时序数据进行分组存储，将具有相同特性的数据源设备传输的时序数据存储在同一文件或同一块区。且对于同一份时序数据按多个特性进行分组，存储多份。例如，对于同一份车辆GPS数据，根据车辆的颜色、车辆型号和车牌号三个特性，将该份车辆GPS数据分别存储三份。

但上述存储时序数据的方法中，同一份时序数据需要根据不同的特性存储多份，导致存储时序数据的效率很低，且存储多份占用大量的存储空间。

发明内容

有鉴于此，本发明实施例的目的在于提供一种时序数据的帧存储方法及装置、时序数据查询方法及装置，实现时序数据只存储一份，大大减少存储所需的存储空间的大小，提高存储效率，且同时存储设备描述信息，能够支持多维度的高效查询。

第一方面，本发明实施例提供了一种时序数据的帧存储方法，所述方法包括：

接收数据源设备发送的存储请求，所述存储请求包括待存储时序数据、所述数据源设备的设备标识和设备描述信息；

根据所述设备标识，从预先创建的存储空间中获取所述设备标识对应的内存段中的数据标志；

当所述数据标志指示为旧数据时，将所述待存储时序数据和所述设备描述信息存储到所述内存段中；

当所述数据标志指示为新数据时，将所述预先创建的存储空间中的所有数据组成帧数据，将所述帧数据存储在数据文件中。

结合第一方面，本发明实施例提供了上述第一方面的第一种可能的实现方式，其中，所述根据所述设备标识，从预先创建的存储空间中获取所述设备标识对应的内存段中的数据标志，包括：

根据所述设备标识，从设备标识与内存索引号的对应关系中获取对应的内存索引号；

根据获取的所述内存索引号，从预先创建的存储空间中确定所述内存索引号对应的内存段；

从确定的所述内存段中获取所述设备标识对应的数据标志。

结合第一方面，本发明实施例提供了上述第一方面的第二种可能的实现方式，其中，所述从预先创建的存储空间中获取所述设备标识对应的内存段中的数据标志之前，还包括：

按照预设时间段内接收多个数据源设备发送存储请求的先后顺序，依次为每个数据源设备分配连续的内存索引号；

根据所述预设时间段内接收的需存储的时序数据的总大小，从内存中划分容量为所述总大小的连续的存储空间；

根据所述多个数据源设备的数目，将所述连续的存储空间划分为所述数目个内存段；

将所述每个数据源设备的内存索引号依次对应于一个内存段，并将所述每个数据源设备的设备标识和内存索引号存储在设备标识与内存索引号的对应关系中。

结合第一方面，本发明实施例提供了上述第一方面的第三种可能的实现方式，其中，所述将所述帧数据存储在数据文件中，包括：

确定当前的数据文件的大小是否达到预设的容量阈值，如果否，则将所述帧数据存储在所述当前的数据文件中；

当确定所述当前的数据文件的大小达到所述预设的容量阈值时，创建一个新的数据文件；

将所述帧数据存储在所述新的数据文件中。

结合第一方面的第三种可能的实现方式，本发明实施例提供了上述第一方面的第四种可能的实现方式，其中，所述创建一个新的数据文件之后，还包括：

为所述新的数据文件分配文件名，并将所述文件名和存储所述帧数据的存储时间对应存储在主索引文件中。

第二方面，本发明实施例提供了一种时序数据查询方法，所述方法包括：

接收终端发送的查询请求，所述查询请求包括时序条件和设备描述信息；

根据所述查询请求和主索引文件，从存储的所有数据文件中获取所述查询请求对应的帧数据，所述主索引文件包括数据文件的文件名和所述数据文件中第一帧的存储时间；

将获取的所述帧数据包括的时序数据发送给所述终端。

结合第二方面，本发明实施例提供了上述第二方面的第一种可能的实现方式，其中，所述根据所述查询请求和主索引文件，从存储的所有数据文件中获取所述查询请求对应的帧数据，包括：

根据所述查询请求包括的设备描述信息，过滤存储的所有数据文件中的帧数据；

根据主索引文件和所述查询请求包括的时序条件，从过滤后的数据文件中获取所述时序条件对应的帧数据。

结合第二方面的第一种可能的实现方式，本发明实施例提供了上述第二方面的第二种可能的实现方式，其中，所述根据主索引文件和所述查询请求包括的时序条件，从过滤后的数据文件中获取所述时序条件对应的帧数据，包括：

当所述查询请求包括的时序条件未指定需查询的时间点时，从主索引文件中获取离当前时间最近的存储时间对应的文件名；

根据获取的所述文件名，从过滤后的数据文件中确定所述文件名对应的数据文件；

从确定的所述数据文件中，获取离当前时间最近的帧数据，将获取的所述帧数据确定为所述时序条件对应的帧数据。

结合第二方面的第一种可能的实现方式，本发明实施例提供了上述第二方面的第三种可能的实现方式，其中，所述根据主索引文件和所述查询请求包括的时序条件，从过滤后的数据文件中获取所述时序条件对应的帧数据，包括：

当所述查询请求包括的时序条件指定需查询的时间点时，从主索引文件中获取在所述时间点之前且离所述时间点最近的存储时间对应的文件名；

根据获取的所述文件名，从过滤后的数据文件中确定所述文件名对应的数据文件；

从确定的所述数据文件中，获取所述时间点对应的帧数据。

结合第二方面的第一种可能的实现方式，本发明实施例提供了上述第二方面的第四种可能的实现方式，其中，所述根据主索引文件和所述查询请求包括的时序条件，从过滤后的数据文件中获取所述时序条件对应的帧数据，包括：

当所述查询请求包括的时序条件指定需查询的时间段时，从主索引文件中确定第一存储时间和第二存储时间，所述第一存储时间和所述第二存储时间组成的时间区间包含所述时间段；

从所述主索引文件中获取在所述第一存储时间和所述第二存储时间组成的时间区间中的每个存储时间对应的文件名；

从获取的每个文件名对应的数据文件中，获取存储时间在所述时间段内的帧数据；

将获取的所述帧数据确定为所述时序条件对应的帧数据。

第三方面，本发明实施例提供了一种时序数据的帧存储装置，所述装置包括：

接收模块，用于接收数据源设备发送的存储请求，所述存储请求包括待存储时序数据、所述数据源设备的设备标识和设备描述信息；

获取模块，用于根据所述设备标识，从预先创建的存储空间中获取所述设备标识对应的内存段中的数据标志；

第一存储模块，用于当所述数据标志指示为旧数据时，将所述待存储时序数据和所述设备描述信息存储到所述内存段中；

第二存储模块，用于当所述数据标志指示为新数据时，将所述预先创建的存储空间中的所有数据组成帧数据，将所述帧数据存储在数据文件中。

结合第三方面，本发明实施例提供了上述第三方面的第一种可能的实现方式，其中，所述获取模块包括：

第一获取单元，用于根据所述设备标识，从设备标识与内存索引号的对应关系中获取对应的内存索引号；

确定单元，用于根据获取的所述内存索引号，从预先创建的存储空间中确定所述内存索引号对应的内存段；

第二获取单元，用于从确定的所述内存段中获取所述设备标识对应的数据标志。

结合第三方面，本发明实施例提供了上述第三方面的第二种可能的实现方式，其中，所述装置还包括：

存储空间创建模块，用于按照预设时间段内接收多个数据源设备发送存储请求的先后顺序，依次为每个数据源设备分配连续的内存索引号；根据所述预设时间段内接收的需存储的时序数据的总大小，从内存中划分容量为所述总大小的连续的存储空间；

内存段划分模块，用于根据所述多个数据源设备的数目，将所述连续的存储空间划分为所述数目个内存段；将所述每个数据源设备的内存索引号依次对应于一个内存段，并将所述每个数据源设备的设备标识和内存索引号存储在设备标识与内存索引号的对应关系中。

结合第三方面，本发明实施例提供了上述第三方面的第三种可能的实现方式，其中，所述第二存储模块包括：

第一存储单元，用于确定当前的数据文件的大小是否达到预设的容量阈值，如果否，则将所述帧数据存储在所述当前的数据文件中；

创建单元，用于当确定所述当前的数据文件的大小达到所述预设的容量阈值时，创建一个新的数据文件；

第二存储单元，用于将所述帧数据存储在所述新的数据文件中。

结合第三方面的第三种可能的实现方式，本发明实施例提供了上述第三方面的第四种可能的实现方式，其中，所述装置还包括：

索引存储模块，用于为所述新的数据文件分配文件名，并将所述文件名和存储所述帧数据的存储时间对应存储在主索引文件中。

第四方面，本发明实施例提供了一种时序数据查询装置，所述装置包括：

接收模块，用于接收终端发送的查询请求，所述查询请求包括时序条件和设备描述信息；

获取模块，用于根据所述查询请求和主索引文件，从存储的所有数据文件中获取所述查询请求对应的帧数据，所述主索引文件包括数据文件的文件名和所述数据文件中第一帧的存储时间；

发送模块，用于将获取的所述帧数据包括的时序数据发送给所述终端。

结合第四方面，本发明实施例提供了上述第四方面的第一种可能的实现方式，其中，所述获取模块包括：

过滤单元，用于根据所述查询请求包括的设备描述信息，过滤存储的所有数据文件中的帧数据；

获取单元，用于根据主索引文件和所述查询请求包括的时序条件，从过滤后的数据文件中获取所述时序条件对应的帧数据。

结合第四方面的第一种可能的实现方式，本发明实施例提供了上述第四方面的第二种可能的实现方式，其中，所述获取单元，用于包括：

第一获取子单元，用于当所述查询请求包括的时序条件未指定需查询的时间点时，从主索引文件中获取离当前时间最近的存储时间对应的文件名；

第一确定子单元，用于根据获取的所述文件名，从过滤后的数据文件中确定所述文件名对应的数据文件；

第二获取子单元，用于从确定的所述数据文件中，获取离当前时间最近的帧数据，将获取的所述帧数据确定为所述时序条件对应的帧数据。

结合第四方面的第一种可能的实现方式，本发明实施例提供了上述第四方面的第三种可能的实现方式，其中，所述获取单元包括：

第三获取子单元，用于当所述查询请求包括的时序条件指定需查询的时间点时，从主索引文件中获取在所述时间点之前且离所述时间点最近的存储时间对应的文件名；

第二确定子单元，用于根据获取的所述文件名，从过滤后的数据文件中确定所述文件名对应的数据文件；

第四获取子单元，用于从确定的所述数据文件中，获取所述时间点对应的帧数据。

结合第四方面的第一种可能的实现方式，本发明实施例提供了上述第四方面的第四种可能的实现方式，其中，所述获取单元包括：

第三确定子单元，用于当所述查询请求包括的时序条件指定需查询的时间段时，从主索引文件中确定第一存储时间和第二存储时间，所述第一存储时间和所述第二存储时间组成的时间区间包含所述时间段；

第五获取子单元，用于从所述主索引文件中获取在所述第一存储时间和所述第二存储时间组成的时间区间中的每个存储时间对应的文件名；

第六获取子单元，用于从获取的每个文件名对应的数据文件中，获取存储时间在所述时间段内的帧数据；

第四确定子单元，用于将获取的所述帧数据确定为所述时序条件对应的帧数据。

在本发明实施例提供的方法及装置中，根据设备标识，从预先创建的存储空间中获取设备标识对应的内存段中的数据标志；当数据标志指示为旧数据时，将待存储时序数据和设备描述信息存储到内存段中；当数据标志指示为新数据时，将预先创建的存储空间中的所有数据组成帧数据，将帧数据存储在数据文件中。在本发明中时序数据只存储一份，大大减少了存储时序数据所需的存储空间的大小，提高了存储时序数据的存储效率，且同时存储了设备描述信息，从而能够支持多维度的高效查询。

为使本发明的上述目的、特征和优点能更明显易懂，下文特举较佳实施例，并配合所附附图，作详细说明如下。

附图说明

为了更清楚地说明本发明实施例的技术方案，下面将对实施例中所需要使用的附图作简单地介绍，应当理解，以下附图仅示出了本发明的某些实施例，因此不应被看作是对范围的限定，对于本领域普通技术人员来讲，在不付出创造性劳动的前提下，还可以根据这些附图获得其他相关的附图。

图1A示出了本发明实施例1所提供的一种时序数据的帧存储方法流程图；

图1B示出了本发明实施例1所提供的一种数据源设备向服务器发送的时序数据的示意图；

图1C示出了本发明实施例1所提供的一种时序数据组成帧数据的示意图；

图2示出了本发明实施例2所提供的一种时序数据查询方法的流程图；

图3示出了本发明实施例3所提供的一种时序数据的帧存储装置的结构示意图；

图4示出了本发明实施例4所提供的一种时序数据查询装置的结构示意图。

具体实施方式

下面将结合本发明实施例中附图，对本发明实施例中的技术方案进行清楚、完整地描述，显然，所描述的实施例仅仅是本发明一部分实施例，而不是全部的实施例。通常在此处附图中描述和示出的本发明实施例的组件可以以各种不同的配置来布置和设计。因此，以下对在附图中提供的本发明的实施例的详细描述并非旨在限制要求保护的本发明的范围，而是仅仅表示本发明的选定实施例。基于本发明的实施例，本领域技术人员在没有做出创造性劳动的前提下所获得的所有其他实施例，都属于本发明保护的范围。

考虑到相关技术中存储时序数据的方法中，同一份时序数据需要根据不同的特性存储多份，导致存储时序数据的效率很低，且存储多份占用大量的存储空间。基于此，本发明实施例提供了一种时序数据的帧存储方法及装置、时序数据查询方法及装置。下面通过实施例进行描述。

实施例1

本发明实施例提供了一种时序数据的帧存储方法。时序数据具有固定的特性，首先数据源设备的设备标识是固定不变的，同一时间段内需要存储时序数据的数据源设备的个数不会变化。其次，相同类型的数据源设备提交时序数据的时间间隔一致。本发明实施例正是利用时序数据的上述固有特性来存储时序数据的。

参见图1A，该方法具体包括以下步骤：

步骤101：接收数据源设备发送的存储请求，该存储请求包括待存储时序数据、数据源设备的设备标识和设备描述信息；

本发明实施例的执行主体为服务器。数据源设备为生成时序数据的设备。例如，当时序数据为车辆GPS数据时，数据源设备为车辆；当时序数据为环境温度数据时，数据源设备可以为气象监测设备。

数据源设备的设备标识可以为数据源设备的名称或硬件地址等。设备描述信息用于描述数据源设备的特征。例如，当数据源设备为车辆时，设备描述信息可以包括车辆的颜色、型号和车牌号等。

数据源设备每隔一定时间段生成时序数据，每次生成时序数据时，都发送存储请求给服务器，并在存储请求中携带生成的待存储时序数据、数据源设备的设备标识和设备描述信息。服务器接收数据源设备发送的该存储请求。

由于存在大量的数据源设备，所以服务器每次都接收到多个数据源设备发送的存储请求。如图1B所示，服务器每一固定时间段内都能接收到数据源设备S1、S2、S3和S4发送的时序数据。

在本发明实施例中，服务器在存储时序数据之前，首先通过如下操作来创建用于存储时序数据的存储空间，具体包括：

当服务器首次接收到多个数据源设备发送的存储请求时，按照预设时间段内接收这多个数据源设备发送存储请求的先后顺序，依次为每个数据源设备分配连续的内存索引号；根据该预设时间段内接收的需存储的时序数据的总大小，从内存中划分容量为该总大小的连续的存储空间；根据这多个数据源设备的数目，将连续的存储空间划分为与这多个数据设备的数目相同的个数个内存段；将每个数据源设备的内存索引号依次对应于一个内存段，并将每个数据源设备的设备标识和内存索引号存储在设备标识与内存索引号的对应关系中。

为了便于理解上述创建存储空间的操作，下面举例进行说明。例如，假设服务器在1s中内首次接收到数据源设备S1、S2、S3和S4发送的存储请求，且这四个数据源设备发送存储请求的先后顺序为S1、S3、S2和S4。则为数据源设备S1、S3、S2和S4分配的连续的内存索引号依次为a1、a2、a3和a4，假设这四个数据源设备发送的时序数据的总大小为C，则从内存中划分大小为C的连续的存储空间，将该连续的存储空间换分为4个内存段，将内存索引号a1、a2、a3和a4依次对应于内存段1、2、3和4，并将每个数据源设备的设备标识和对应的内存索引号存储在如表1所示的设备标识与内存索引号的对应关系中。

表1

设备标识	内存索引号
		S1	a1
S2	a3
		S3	a2
S4	a4

其中，通过上述方式创建了大小为C的联系的存储空间，并存储了如表1所示的设备标识与内存索引号的对应关系之后，后续再次接收到这四个数据源设备发送的存储请求时，固定将数据源设备S1的时序数据存储在内存索引号a1对应的内存段1中，将数据源设备S2的时序数据存储在内存索引号a3对应的内存段3中，将数据源设备S3的时序数据存储在内存索引号a2对应的内存段2中，将数据源设备S4的时序数据存储在内存索引号a4对应的内存段4中。

另外，在本发明实施例中，对于数据源设备的设备标识与内存索引号之间的映射关系，可以使用hash map(哈希映射)，但本发明不对其进行具体限定。

通过上述方式创建用于存储时序数据的存储空间，并接收到数据源设备发送的存储请求之后，通过如下步骤102-104来存储该数据源设备发送的时序数据。

步骤102：根据存储请求包括的设备标识，从预先创建的存储空间中获取设备标识对应的内存段中的数据标志；

在本发明实施例中，预先创建的存储空间中每个数据源设备对应的内存段中都设置有数据标志，该数据标志的不同取值用于指示内存段中存储的时序数据为旧数据或新数据，如当数据标志取值为1时指示内存段中存储的时序数据为旧数据，而取值为0时指示内存段中存储的时序数据为新数据。其中，旧数据表示当前该内存段中没有存储数据，新数据表示当前该内存段中存储有数据。

上述获取设备标识对应的内存段中的数据标志的操作，具体包括：

根据存储请求包括的设备标识，从设备标识与内存索引号的对应关系中获取对应的内存索引号；根据获取的内存索引号，从预先创建的存储空间中确定内存索引号对应的内存段；从确定的内存段中获取该设备标识对应的数据标志。

步骤103：判断获取的数据标志是否指示为旧数据，如果是，则执行步骤104，如果否，则执行步骤105；

根据获取的数据标志的取值来判断该数据标志是否指示为旧数据。

步骤104：将待存储时序数据和设备描述信息存储到上述设备标识对应的内存段中；

当数据标志指示为旧数据时，表明当前该设备标识对应的内存段中没有存储数据，将待存储时序数据和设备描述信息存储到该内存段中，然后重置该内存段中的数据标志，使数据标志指示为新数据。

步骤105：将预先创建的存储空间中的所有数据组成帧数据，将组成的帧数据存储在数据文件中。

上述数据文件用于存储时序数据组成的帧数据，且在存储帧数据的同时记录存储帧数据的存储时间，以便于后续根据存储时间从数据文件中快速读取时序数据。

在本发明实施例中，预先设置了数据文件的容量阈值，即每当数据文件的大小达到该容量阈值时，就关闭该数据文件，然后重新创建一个数据文件。如此限制数据文件的大小，以避免出现过大的数据文件而影响数据文件的存储及后续从数据文件中读取时序数据。

在将组成的帧数据存储在数据文件中之前，判断当前是否存在已打开的数据文件，若存在，则确定当前的数据文件的大小是否达到上述预设的容量阈值，如果否，则将该帧数据存储在当前的数据文件中；当确定当前的数据文件的大小达到预设的容量阈值时，关闭当前的数据文件，然后创建一个新的数据文件；将该帧数据存储在创建的新的数据文件中。

当判断出当前不存在已打开的数据文件时，也创建一个新的数据文件，并将该帧数据存储在创建的新的数据文件中。

在本发明实施例中，还可以先将组成的帧数据存储在当前的数据文件中，然后判断当前的数据文件的大小是否达到上述预设的容量阈值，若达到，则关闭当前的数据文件，创建一个新的数据文件，后续再次存储帧数据时，将帧数据存储在创建的新的数据文件中。

另外，在将帧数据存储在数据文件之后，重置存储空间包括的每个内存段中的数据标志，使每个内存段中的数据标志均指示为旧数据。

如图1C所示，对于预设的时间段内的所有数据源设备的时序数据组成一个帧数据，如t1时间段内数据源设备S1、S2、S3和S4发送的时序数据组成一个帧数据。同样的，t2、t3和t4时间段内数据源设备S1、S2、S3和S4发送的时序数据也分别组成帧数据。

在本发明实施例中，创建一个新的数据文件之后，还需要为新的数据文件分配文件名，并将该文件名和存储上述帧数据的存储时间对应存储在主索引文件中，即将新的数据文件的文件名以及存储第一帧的存储时间对应存储在主索引文件中。

上述主索引文件中存储了每个数据文件的文件名及每个数据文件中第一帧的存储时间，后续从数据文件中查询时序数据时，可以通过主索引文件来快速定位出所需查询的时序数据所在的数据文件，提高查询时序数据的效率。

在本发明实施例中，根据设备标识，从预先创建的存储空间中获取设备标识对应的内存段中的数据标志；当数据标志指示为旧数据时，将待存储时序数据和设备描述信息存储到内存段中；当数据标志指示为新数据时，将预先创建的存储空间中的所有数据组成帧数据，将帧数据存储在数据文件中。在本发明中时序数据只存储一份，大大减少了存储时序数据所需的存储空间的大小，提高了存储时序数据的存储效率，且同时存储了设备描述信息，从而能够支持多维度的高效查询。

实施例2

参见图2，本发明实施例提供了一种时序数据查询方法，该方法具体包括以下步骤：

步骤201：接收终端发送的查询请求，该查询请求包括时序条件和设备描述信息；

本发明实施例的执行主体为服务器。上述终端也可以为数据源设备，如查询车辆GPS数据时，上述终端可以为车辆终端。上述设备描述信息用于描述数据源设备的特征。例如，当数据源设备为车辆时，设备描述信息可以包括车辆的颜色、型号和车牌号等。上述时序条件表明所需查询的时序数据满足的时间条件，该时序条件可以为一个时间点或一个时间区间，该时序条件也可以为指示为空的字符，标识该查询请求未给出所需查询的时序数据的时间特征，此时由于时序数据的时间特性，默认时序条件为当前时间点。

步骤202：根据查询请求和主索引文件，从存储的所有数据文件中获取查询请求对应的帧数据，该主索引文件包括数据文件的文件名和数据文件中第一帧的存储时间；

在本发明实施例中，首先根据查询请求包括的非时序条件，即根据设备描述信息，过滤存储的所有数据文件。由于数据文件中存储有多个帧数据，每个帧数据中都包括多个数据源设备的时序数据及每个数据源设备的设备描述信息，所以根据查询请求中包括的设备描述信息，查询数据文件中的所有帧数据中的设备描述信息，将数据文件的帧数据中与查询请求中包括的设备描述信息不相符的设备描述信息对应的时序数据过滤掉。如此过滤后的数据文件中包括的帧数据中只包含符合查询请求包括的设备描述信息对应的时序数据，缩小了查询范围。

根据查询请求包括的设备描述信息，过滤存储的所有数据文件中的帧数据后，根据主索引文件和查询请求包括的时序条件，从过滤后的数据文件中获取时序条件对应的帧数据。

根据时序条件的不同，上述获取时序条件对应的帧数据的操作可以通过如下第一至第三三种方式来实现，具体包括，

第一种方式，上述查询请求包括的时序条件未指定需查询的时间点，此时默认该查询请求需查询当前时间点对应的时序数据。则从主索引文件中获取离当前时间最近的存储时间对应的文件名，根据获取的文件名，从过滤后的数据文件中确定该文件名对应的数据文件，从确定的数据文件中，获取离当前时间最近的帧数据，将获取的帧数据确定为该时序条件对应的帧数据。

第二种方式，上述查询请求包括的时序条件指定了需查询的时间点，则从主索引文件中获取在该时间点之前且离该时间点最近的存储时间对应的文件名，根据获取的文件名，从过滤后的数据文件中确定文件名对应的数据文件，从确定的数据文件中，获取该时间点对应的帧数据。

第三种方式，上述查询请求包括的时序条件指定需查询的时间段时，从主索引文件中确定第一存储时间和第二存储时间，第一存储时间和第二存储时间组成的时间区间包含该时间段；从主索引文件中获取在第一存储时间和第二存储时间组成的时间区间中的每个存储时间对应的文件名；从获取的每个文件名对应的数据文件中，获取存储时间在该时间段内的帧数据；将获取的帧数据确定为时序条件对应的帧数据。

具体地，确定时序条件指定的时间段的两个端点：左端点和右端点。从主索引文件中获取在左端点之前且离左端点最近的存储时间作为第一存储时间，从主索引文件中获取在右端点之前且离右端点最近的存储时间作为第二存储时间。将第一存储时间和第二存储时间组成一个时间区间，从主索引文件中获取在该时间区间中的每个存储时间对应的文件名，从获取的文件名对应的数据文件中获取在时序条件指定的时间段内的帧数据。

其中，对于第一存储时间对应的数据文件，从该数据文件中获取存储时间为左端点及在左端点之后的存储时间对应的帧数据。对于第二存储时间对应的数据文件，从该数据文件中获取在右端点之前的存储时间及右端点对应的帧数据。对于位于该时间段之内的存储时间对应的数据文件，获取这些数据文件中的所有帧数据。将上述获取的全部帧数据确定为最终查询到的数据。

为了便于理解第三种方式的操作，下面举例进行说明。例如，假设车辆终端需要查询车辆的GPS数据，接收的查询请求中包括的时序条件为9月1日10:00至9月1日12:00，设备描述信息包括黄色小客车。则首先根据设备描述信息对所有数据文件中的帧数据进行过滤，过滤后数据文件的帧数据中的时序数据都是黄色小客车的时序数据。然后根据时序条件查询主索引文件，从主索引文件中确定出第一存储时间和第二存储时间，假设第一存储时间为9月1日9:55，第二存储时间为9月1日11:55，则从主索引文件中获取存储时间位于9月1日9:55至9月1日11:55之间的存储时间，假设获取的存储时间分别为9月1日10:30、11:00和11:30，且这三个存储时间对应的文件名分别为file1、2和3，则获取file1中的所有帧数据，这些帧数据的存储时间在9月1日10:30至11:00之间，获取file2中的所有帧数据，这些帧数据的存储时间在9月1日11:00至11:30之间，以及获取file3中的所有帧数据，这些帧数据的存储时间在9月1日11:30至11:55之间。另外从9月1日9:55对应的数据文件file4中获取存储时间在9月1日10:00至10:30之间的帧数据，从9月1日11:55对应的数据文件中获取9月1日11:55至12:00之间的帧数据。上述获取的所有帧数据就组成了存储时间在9月1日10:00至9月1日12：00之间的帧数据。

步骤203：将获取的帧数据包括的时序数据发送给终端。

在本发明实施例中，接收终端发送的查询请求，该查询请求包括时序条件和设备描述信息；根据该查询请求和主索引文件，从存储的所有数据文件中获取查询请求对应的帧数据，该主索引文件包括数据文件的文件名和数据文件中第一帧的存储时间；将获取的帧数据包括的时序数据发送给终端。通过主索引文件来快速定位出所需查询的时序数据所在的数据文件，然后利用查询请求包括的时序条件从定位的数据文件中按时序查询出所需的时序数据，大大提高查询时序数据的效率。

实施例3

参见图3，本发明实施例提供了一种时序数据的帧存储装置，该装置用于执行上述实施例1提供的时序数据的帧存储方法。该装置具体包括：

接收模块301，用于接收数据源设备发送的存储请求，该存储请求包括待存储时序数据、数据源设备的设备标识和设备描述信息；

获取模块302，用于根据设备标识，从预先创建的存储空间中获取设备标识对应的内存段中的数据标志；

第一存储模块303，用于当数据标志指示为旧数据时，将待存储时序数据和设备描述信息存储到内存段中；

第二存储模块304，用于当数据标志指示为新数据时，将预先创建的存储空间中的所有数据组成帧数据，将帧数据存储在数据文件中。

上述获取模块302通过第一获取单元、确定单元和第二获取单元来获取设备标识对应的数据标志。

第一获取单元，用于根据设备标识，从设备标识与内存索引号的对应关系中获取对应的内存索引号；

确定单元，用于根据获取的内存索引号，从预先创建的存储空间中确定内存索引号对应的内存段；

第二获取单元，用于从确定的内存段中获取设备标识对应的数据标志。

在本发明实施例中，通过接收模块301、获取模块302、第一存储模块303和第二存储模块304存储时序数据之前，还通过存储空间创建模块来创建用于存储时序数据的存储空间，以及通过内存段划分模块在创建的存储空间中划分出每个数据源设备对应的内存段。

存储空间创建模块，用于按照预设时间段内接收多个数据源设备发送存储请求的先后顺序，依次为每个数据源设备分配连续的内存索引号；根据预设时间段内接收的需存储的时序数据的总大小，从内存中划分容量为总大小的连续的存储空间；

内存段划分模块，用于根据多个数据源设备的数目，将连续的存储空间划分为数目个内存段；将每个数据源设备的内存索引号依次对应于一个内存段，并将每个数据源设备的设备标识和内存索引号存储在设备标识与内存索引号的对应关系中。

上述第二存储模块304通过第一存储单元、创建单元和第二存储单元来将帧数据存储在新的数据文件中。

第一存储单元，用于确定当前的数据文件的大小是否达到预设的容量阈值，如果否，则将帧数据存储在当前的数据文件中；

创建单元，用于当确定当前的数据文件的大小达到预设的容量阈值时，创建一个新的数据文件；

第二存储单元，用于将帧数据存储在新的数据文件中。

在本发明实施例中，在上述第二存储单元将帧数据存储在新的数据文件中之后，还通过索引存储模块来建立该新的数据文件对应的索引。

索引存储模块，用于为新的数据文件分配文件名，并将文件名和存储帧数据的存储时间对应存储在主索引文件中。

在本发明实施例中，根据设备标识，从预先创建的存储空间中获取设备标识对应的内存段中的数据标志；当数据标志指示为旧数据时，将待存储时序数据和设备描述信息存储到内存段中；当数据标志指示为新数据时，将预先创建的存储空间中的所有数据组成帧数据，将帧数据存储在数据文件中。在本发明中时序数据只存储一份，大大减少了存储时序数据所需的存储空间的大小，提高了存储时序数据的存储效率，且同时存储了设备描述信息，从而能够支持多维度的高效查询。

实施例4

参见图4，本发明实施例提供了一种时序数据查询装置，该装置用于执行上述实施例2提供的时序数据查询方法。该装置具体包括：

接收模块401，用于接收终端发送的查询请求，该查询请求包括时序条件和设备描述信息；

获取模块402，用于根据查询请求和主索引文件，从存储的所有数据文件中获取查询请求对应的帧数据，该主索引文件包括数据文件的文件名和数据文件中第一帧的存储时间；

发送模块403，用于将获取的帧数据包括的时序数据发送给终端。

上述获取模块402通过过滤单元和获取单元来获取查询请求对于的帧数据。

过滤单元，用于根据查询请求包括的设备描述信息，过滤存储的所有数据文件中的帧数据；

获取单元，用于根据主索引文件和查询请求包括的时序条件，从过滤后的数据文件中获取时序条件对应的帧数据。

时序条件表明所需查询的时序数据满足的时间条件，该时序条件可以为一个时间点或一个时间区间，该时序条件也可以为指示为空的字符，标识该查询请求未给出所需查询的时序数据的时间特征，此时由于时序数据的时间特性，默认时序条件为当前时间点。

根据时序条件的不同，上述获取单元获取时序条件对应的帧数据的操作不同。

当查询请求包括的时序条件未指定需查询的时间点时，默认该查询请求需查询当前时间点对应的时序数据。此时上述获取单元通过第一获取子单元、第一确定子单元和第二获取子单元来获取时序条件对应的帧数据，

第一获取子单元，用于当查询请求包括的时序条件未指定需查询的时间点时，从主索引文件中获取离当前时间最近的存储时间对应的文件名；

第一确定子单元，用于根据获取的文件名，从过滤后的数据文件中确定文件名对应的数据文件；

第二获取子单元，用于从确定的数据文件中，获取离当前时间最近的帧数据，将获取的帧数据确定为时序条件对应的帧数据。

当查询请求包括的时序条件指定了需查询的时间点时，获取单元通过第三获取子单元、第二确定子单元和第四获取子单元来获取时序条件对应的帧数据。

第三获取子单元，用于当查询请求包括的时序条件指定需查询的时间点时，从主索引文件中获取在时间点之前且离时间点最近的存储时间对应的文件名；

第二确定子单元，用于根据获取的文件名，从过滤后的数据文件中确定文件名对应的数据文件；

第四获取子单元，用于从确定的数据文件中，获取时间点对应的帧数据。

当查询请求包括的时序条件指定需查询的时间段时，获取单元通过第三确定子单元、第五获取子单元、第六获取子单元和第四确定子单元来获取时序条件对应的帧数据。

第三确定子单元，用于当查询请求包括的时序条件指定需查询的时间段时，从主索引文件中确定第一存储时间和第二存储时间，第一存储时间和第二存储时间组成的时间区间包含时间段；

第五获取子单元，用于从主索引文件中获取在第一存储时间和第二存储时间组成的时间区间中的每个存储时间对应的文件名；

第六获取子单元，用于从获取的每个文件名对应的数据文件中，获取存储时间在时间段内的帧数据；

第四确定子单元，用于将获取的帧数据确定为时序条件对应的帧数据。

在本发明实施例中，接收终端发送的查询请求，该查询请求包括时序条件和设备描述信息；根据该查询请求和主索引文件，从存储的所有数据文件中获取查询请求对应的帧数据，该主索引文件包括数据文件的文件名和数据文件中第一帧的存储时间；将获取的帧数据包括的时序数据发送给终端。通过主索引文件来快速定位出所需查询的时序数据所在的数据文件，然后利用查询请求包括的时序条件从定位的数据文件中按时序查询出所需的时序数据，大大提高查询时序数据的效率。

本发明实施例所提供的时序数据的帧存储装置及时序数据查询装置可以为设备上的特定硬件或者安装于设备上的软件或固件等。所属领域的技术人员可以清楚地了解到，为描述的方便和简洁，前述描述的系统、装置和单元的具体工作过程，均可以参考上述装置实施例中的对应过程。

在本申请所提供的几个实施例中，应该理解到，所揭露方法和装置，可以通过其它的方式实现。以上所描述的装置实施例仅仅是示意性的，例如，所述单元的划分，仅仅为一种逻辑功能划分，实际实现时可以有另外的划分方式，又例如，多个单元或组件可以结合或者可以集成到另一个系统，或一些特征可以忽略，或不执行。另一点，所显示或讨论的相互之间的耦合或直接耦合或通信连接可以是通过一些通信接口，装置或单元的间接耦合或通信连接，可以是电性，机械或其它的形式。

所述作为分离部件说明的单元可以是或者也可以不是物理上分开的，作为单元显示的部件可以是或者也可以不是物理单元，即可以位于一个地方，或者也可以分布到多个网络单元上。可以根据实际的需要选择其中的部分或者全部单元来实现本实施例方案的目的。

另外，在本发明各个实施例中的各功能单元可以集成在一个处理单元中，也可以是各个单元单独物理存在，也可以两个或两个以上单元集成在一个单元中。

所述功能如果以软件功能单元的形式实现并作为独立的产品销售或使用时，可以存储在一个计算机可读取存储介质中。基于这样的理解，本发明的技术方案本质上或者说对现有技术做出贡献的部分或者该技术方案的部分可以以软件产品的形式体现出来，该计算机软件产品存储在一个存储介质中，包括若干指令用以使得一台计算机设备(可以是个人计算机，服务器，或者网络设备等)执行本发明各个实施例所述装置的全部或部分步骤。而前述的存储介质包括：U盘、移动硬盘、只读存储器(ROM，Read-Only Memory)、随机存取存储器(RAM，Random Access Memory)、磁碟或者光盘等各种可以存储程序代码的介质。

以上所述，仅为本发明的具体实施方式，但本发明的保护范围并不局限于此，任何熟悉本技术领域的技术人员在本发明揭露的技术范围内，可轻易想到变化或替换，都应涵盖在本发明的保护范围之内。因此，本发明的保护范围应以所述权利要求的保护范围为准。

Claims (10)

1.一种时序数据的帧存储方法，其特征在于，所述方法包括：

接收数据源设备发送的存储请求，所述存储请求包括待存储时序数据、所述数据源设备的设备标识和设备描述信息；

根据所述设备标识，从预先创建的存储空间中获取所述设备标识对应的内存段中的数据标志；所述数据标志的不同取值用于指示当前所述内存段中是否存储有时序数据；

当所述数据标志指示所述内存段中没有存储数据时，将所述待存储时序数据和所述设备描述信息存储到所述内存段中；

当所述数据标志指示所述内存段中存储有数据时，将所述预先创建的存储空间中的所有数据组成帧数据，将所述帧数据存储在数据文件中。

2.根据权利要求1所述的方法，其特征在于，所述根据所述设备标识，从预先创建的存储空间中获取所述设备标识对应的内存段中的数据标志，包括：

根据所述设备标识，从设备标识与内存索引号的对应关系中获取对应的内存索引号；

根据获取的所述内存索引号，从预先创建的存储空间中确定所述内存索引号对应的内存段；

从确定的所述内存段中获取所述设备标识对应的数据标志。

3.根据权利要求1所述的方法，其特征在于，所述从预先创建的存储空间中获取所述设备标识对应的内存段中的数据标志之前，还包括：

按照预设时间段内接收多个数据源设备发送存储请求的先后顺序，依次为每个数据源设备分配连续的内存索引号；

根据所述预设时间段内接收的需存储的时序数据的总大小，从内存中划分容量为所述总大小的连续的存储空间；

根据所述多个数据源设备的数目，将所述连续的存储空间划分为所述数目个内存段；

将所述每个数据源设备的内存索引号依次对应于一个内存段，并将所述每个数据源设备的设备标识和内存索引号存储在设备标识与内存索引号的对应关系中。

4.根据权利要求1所述的方法，其特征在于，所述将所述帧数据存储在数据文件中，包括：

确定当前的数据文件的大小是否达到预设的容量阈值，如果否，则将所述帧数据存储在所述当前的数据文件中；

当确定所述当前的数据文件的大小达到所述预设的容量阈值时，创建一个新的数据文件；

将所述帧数据存储在所述新的数据文件中。

5.根据权利要求4所述的方法，其特征在于，所述创建一个新的数据文件之后，还包括：

为所述新的数据文件分配文件名，并将所述文件名和存储所述帧数据的存储时间对应存储在主索引文件中。

6.一种时序数据的帧存储装置，其特征在于，所述装置包括：

接收模块，用于接收数据源设备发送的存储请求，所述存储请求包括待存储时序数据、所述数据源设备的设备标识和设备描述信息；

获取模块，用于根据所述设备标识，从预先创建的存储空间中获取所述设备标识对应的内存段中的数据标志；

第一存储模块，用于当所述数据标志指示为旧数据时，将所述待存储时序数据和所述设备描述信息存储到所述内存段中；

第二存储模块，用于当所述数据标志指示为新数据时，将所述预先创建的存储空间中的所有数据组成帧数据，将所述帧数据存储在数据文件中。

7.根据权利要求6所述的装置，其特征在于，所述获取模块包括：

第一获取单元，用于根据所述设备标识，从设备标识与内存索引号的对应关系中获取对应的内存索引号；

确定单元，用于根据获取的所述内存索引号，从预先创建的存储空间中确定所述内存索引号对应的内存段；

第二获取单元，用于从确定的所述内存段中获取所述设备标识对应的数据标志。

8.根据权利要求6所述的装置，其特征在于，所述装置还包括：

存储空间创建模块，用于按照预设时间段内接收多个数据源设备发送存储请求的先后顺序，依次为每个数据源设备分配连续的内存索引号；根据所述预设时间段内接收的需存储的时序数据的总大小，从内存中划分容量为所述总大小的连续的存储空间；

内存段划分模块，用于根据所述多个数据源设备的数目，将所述连续的存储空间划分为所述数目个内存段；将所述每个数据源设备的内存索引号依次对应于一个内存段，并将所述每个数据源设备的设备标识和内存索引号存储在设备标识与内存索引号的对应关系中。

9.根据权利要求6所述的装置，其特征在于，所述第二存储模块包括：

第一存储单元，用于确定当前的数据文件的大小是否达到预设的容量阈值，如果否，则将所述帧数据存储在所述当前的数据文件中；

创建单元，用于当确定所述当前的数据文件的大小达到所述预设的容量阈值时，创建一个新的数据文件；

第二存储单元，用于将所述帧数据存储在所述新的数据文件中。

10.根据权利要求9所述的装置，其特征在于，所述装置还包括：

索引存储模块，用于为所述新的数据文件分配文件名，并将所述文件名和存储所述帧数据的存储时间对应存储在主索引文件中。