CN113868267B 注入时序数据的方法、查询时序数据的方法及数据库系统 （华为技术有限公司）

2接收时序数据，所述时序数据包括用于标识产生所述时序数据数,以及表示所述数据源的多个属性的指标和时间戳，所述时间戳指示所述指标产生的时将第一参数组以行存储格式存储，所述第一参数组包括所述用将第二参数组包括的表示所述数据源的多个属性的指标和所述时间戳以列存储格式根据所述第一参数组确定行标识，并根据所述行标识、所所述将第二参数组包括的表示所述数据源的多个属性的指标和所述时间戳以列存储将所述数据行包含的所述多个指标存储到多个CU中，所述多个指标与所3.根据权利要求2所述的方法，其特征在于，所述将所述第一参数组以行存储格式存查询全局缓存以得到所述索引值对应的行标识，所述全局为所述索引值分配所述行标识，在全局缓存中存存储所述多个指标的所述多个CU，以及存储所述时间戳的所述CU合并所述多个数据集中的至少两个数据集，以得到一个合并数据集，所3对所述合并数据集中的多个CU中的数据进行压缩，以及对所述多个所述将所述合并数据集写入数据存储器中，包括：将压缩后的合接收针对时序数据的查询，所述查询包括标识产生所述时序数列中包含表示所述数据源的多个属性中至少根据所述至少一个列标识，从所述多个CU中确定至少一个目标CU，每个个目标列；根据所述至少一个目标CU中的所述至少一个属性的指标和所述至少一个参数生成所确定包含所述查询时间的第一时间范围对应的目标分区，所述从所述多个合并数据集中确定第一合并数据集，所述第一合并数据从所述第一合并数据集包括的所述多个CU中确定多个第一CU，所述第一C所述根据所述行标识确定多个CU，包括：从所述多个第一CU中确定与查询全局缓存以得到所述索引值对应的行标识，所述全局4从所述协调节点获取所述时序数据，所述时序数据包括用于标识产数据源的至少一个参数,以及表示所述数据源的多个属性的指标和时间戳，所述时间戳指将第一参数组以行存储格式存储，所述第一参数组包括所述用将第二参数组包括的表示所述数据源的多个属性的指标和所述时间戳以列存储格式根据所述第一参数组确定行标识，并根据所述行标识、将所述数据行包含的所述多个指标存储到多个CU中，所述多个指标与所查询全局缓存以得到所述索引值对应的行标识，所述全局为所述索引值分配所述行标识，在全局缓存中存存储所述多个指标的所述多个CU，以及存储所述时间戳的所述CU合并所述多个数据集中的至少两个数据集，以得到一个合并数据集，所5对所述合并数据集中的多个CU中的数据进行压缩，以及对所述多个所述协调节点用于接收来自于客户端的针对时序数从所述协调节点获取所述针对时序数据的查询，所述查询包括标识产生根据所述至少一个列标识，从所述多个CU中确定至少一个目标CU，每个个目标列；所述数据节点用于：根据所述至少一个目标CU中的所述至少一个属性确定包含所述查询时间的第一时间范围对应的目标分区，所述从所述多个合并数据集中确定第一合并数据集，所述第一合并数据从所述第一合并数据集包括的所述多个CU中确定多个第一CU，所述第一C从所述多个第一CU中确定与所述行标识对应的所述多个查询全局缓存以得到所述索引值对应的行标识，所述全局67[0002]随着各种产业的发展，对数据库的需求越来越大。目前括用于标识产生时序数据的数据源的至少一个参数,以及表示数据源的至少一个属性的指二参数组包括表示数据源的至少一个属性的指标和时间个数据源会随着时间的变化得到很多条时序数据，该数据源也可以称为一条“时间线8应查询，需要通过行标识(tagID)来关联这两个参数组。行标识是通过第一参数组来确定和存储时间戳的CU中都包含该行标识。一个CU中只存储一个属性的指标或者只存储时间9据集都对应一个时间范围，该时间范围可以通过该数据集中的最小时间和最大时间来表产生时序数据的数据源的至少一个参数,以及表示数据源的至少一个属性的指标和时间[0043]该第三方面以及第三方面任一种可能的实现方式都可以参阅第一方面以及第一节点获取针对时序数据的查询，该查询包括标识产生时序数据的数据源的至少一个参数，[0048]该第四方面以及第四方面任一种可能的实现方式都可以参阅第二方面以及第二设备实施上述第一方面或者第一方面的任一种可能的实现方式所提供的一种注入时序数设备实施上述第二方面或者第二方面的任一种可能的实现方式所提供的一种查询时序数时序数据的装置实现上述第一方面或第一方面任意一种可能的实现方式中所涉及的功能。时序数据的装置实现上述第二方面或第二方面任意一种可能的实现方式中所涉及的功能。[0086]本申请实施例提供的方法可应用于数据库系统(databasesystem)中。图1A示出[0087]其中，数据库110是存储在数据存储器(datastorage)120中的有组织的数据集[0090]本申请实施例提供的数据库系统可以为分布式数据库系统(distributed以理解一个数据库系统可能包括比图1A-图1C中所示的部件更少或更多的组件，或者包括[0094]上述图1B和图1C中的数据库系统示出了计算引擎和时序引擎，在本申请的方案中，计算引擎和时序引擎的作用可以参阅图2进行理解。如图2所示的数据库系统中的[0095]计算引擎132支持至少一种类型的查询语言，比如结构化查询语言(structured将时序数据中需要行存储的部分以行存储格式存储，使用列存储引擎174将时序数据中需[0100]在查询时序数据时，计算引擎132接收来自客户端200的查询(该查询在一些场景[0107]时序数据包括用于标识产生时序数据的数据源10.73.73.3标识产生时序数据的数据源的至少一个参数与表示数据源的至少一个属性的指标和时间数以行存储的格式存储，将会时间变化的属性的指标和对应的时间戳以列存储的格式存数包括设备的名称和设备的IP地址，那么可以将设备的名称和设备的IP地址拼接在一起，10.73.73.312341234范围可以是预先配置好的。对于第一时间范围的具体取值本申请中不作限定。分区(partition)指的是该第一时间范围所对应的数据集合。通过数据行中的时间戳可以确定的是tagID＝1的I/O的指标。CU2中存储的是tagID＝1的空闲率的指标，CU3中存储的是[0162]数据集是分区的下一层级的CU的集合。小part与CU的关系可以参阅图5E进行理[0163]在同一个分区中，还可以将包含同一个行标识的CU划分到同一个数据集(part)标CU中的至少一个属性的指标和至少一个参数生成查询[0185]可以将至少目标CU中的至少一个属性的指标和至少一个参数按照时序数据注入[0193]时序扫描算子执行由上层分区算子驱动，存储层提供接口，通过全局搜索(TsStoreSearch)->分区搜索(PartitionSearch)->数据集搜索(PartSearch)这一搜索链据TsStoreScanState对象中的tagId集合扫描CU描述文件(cudesc)，找到对应列标识[0195]当上层分区算子对当前分区数据扫描完毕后会调用下层算子的重置接口通知切[0197]当时序所有数据扫描完毕后，调用TsStoreScan的算子结束接口完成对相关资源申请实施例提供的数据库系统(GaussDBTSDB)比Influxdb在查询延迟性的至少一个参数,以及表示数据源的至少一个属性的指标数以行存储的格式存储，将会时间变化的属性的指标和对应的时间戳以列存储的格式存[0205]处理单元602，用于将数据行包含的至少一个指标存储到至少一个列存储单元CU理器和微处理器的组合等等。总线804可以是外设部件互连标准(PeripheralComponent[0228]具体的，虚拟机1002是通过虚拟机软件在公共硬件资源上模拟出的虚拟的计算源抽象得到的。其中，硬件层可包括多种硬件，例如包括处理器1004(例如CPU)和存储器上述图3至图9C相关的实施例中注入时序数据的装置或查询时序数据的装置的部分或全部行上述图3至图9C部分实施例所描述的注入时序数据的方法或查询时序指令使得设备执行上述图3至图9C部分实施例所描述的注入时序数据的方法或查询时序数持注入时序数据的装置或查询时序数据的装置实现上述图3至图9C部分实施例所描述的管[0239]另外，在本申请实施例各个实施例中的各功能单元可以计算机软件产品存储在一个存储介质中，包括若干指令用以使得一台计算机设备(可以是