首页 > 其他分享 >使用Apache IoTDB进行IoT相关开发的架构设计与功能实现(9)

使用Apache IoTDB进行IoT相关开发的架构设计与功能实现(9)

时间:2023-08-26 12:33:09浏览次数:45  
标签:11 架构设计 00 填充 IoT 语句 IoTDB 参数 2017

降频聚合查询

本节主要介绍下频聚合查询的相关示例,使用分组依据子句,用于根据用户给定的分区条件对结果集进行分区,并聚合分区的结果集。IoTDB支持根据时间间隔和自定义滑动步长对结果集进行分区,不小于时间间隔,未设置则默认等于时间间隔。默认情况下,结果按时间升序排序。还可以使用Java JDBC用于执行相关查询的标准接口。

GROUP BY 语句为用户提供了三种类型的指定参数:

  • 参数1:时间轴上的显示窗口
  • 参数2:划分时间轴的时间间隔(应为正)
  • 参数3:时间滑动步长(可选,不应小于时间间隔,如果未设置,则默认等于时间间隔)

这三类参数的实际含义如下图5.2所示。其中,参数 3 是可选的。接下来,我们将给出三个典型的降频聚合示例:未指定参数 3、指定参数 3 和指定值过滤条件。

使用Apache IoTDB进行IoT相关开发的架构设计与功能实现(9)_时间轴

图5.2 三类参数的实际含义

不指定滑动步长的降频聚合查询

SQL 语句为:

  1. select count(status), max_value(temperature) from root.ln.wf01.wt01 group by ([2017-11-01T00:00:00, 2017-11-07T23:00:00),1d);

这意味着:

由于用户未指定滑动步长,因此 GROUP BY 语句将默认将滑动步长设置为与时间间隔相同的时间间隔,即 。1d

上面 GROUP BY 语句的第一个参数是显示窗口参数,它决定了最终的显示范围是 [2017-11-01T00:00:00, 2017-11-07T23:00:00)。

上面 GROUP BY 语句的第二个参数是划分时间轴的时间间隔。将此参数(1d)作为时间间隔,显示窗口的开始时间作为划分原点,将时间轴划分为几个连续区间,分别是[0,1d),[1d,2d),[2d,3d)等。

然后系统将使用 WHERE 子句中的时间和值过滤条件和 GROUP BY 语句的第一个参数作为数据过滤条件,得到满足过滤条件的数据(本例中为 [2017-11-01T00:00:00, 2017-11-07 T23:00:00]范围内的数据),并将这些数据映射到之前分段的时间轴(本例中每 1 天有映射的数据)从2017-11-01T00:00:00到2017-11-07T23:00:00:00)。

由于结果范围内都有每个时间段的数据要显示,因此 SQL 语句的执行结果如下所示:

使用Apache IoTDB进行IoT相关开发的架构设计与功能实现(9)_时间轴_02

指定滑动步长的降频聚合查询

SQL 语句为:

  1. select count(status), max_value(temperature) from root.ln.wf01.wt01 group by ([2017-11-01 00:00:00, 2017-11-07 23:00:00), 3h, 1d);

这意味着:

由于用户将滑动步长参数指定为 1d,因此 GROUP BY 语句将延长时间间隔,而不是默认。1 day3 hours

这意味着我们希望每天从 00-00-00 到 02-59-59 获取 2017:11:01 到 2017:11:07 的所有数据。

上面 GROUP BY 语句的第一个参数是显示窗口参数,它决定了最终的显示范围是 [2017-11-01T00:00:00, 2017-11-07T23:00:00)。

上面 GROUP BY 语句的第二个参数是划分时间轴的时间间隔。以此参数(3h)为时间间隔,以显示窗口的开始时间为划分原点,将时间轴划分为几个连续区间,分别是[2017-11-01T00:00:00、2017-11-01T03:00:00)、[2017-11-02T00:00:00、2017-11-02T03:00:00)、[2017-11-03T00:00:00、2017-11-03T03:00:00)等。

上面 GROUP BY 语句的第三个参数是每个时间间隔移动的滑动步长。

然后系统将使用 WHERE 子句中的时间和值过滤条件和 GROUP BY 语句的第一个参数作为数据过滤条件,得到满足过滤条件的数据(本例中为 [2017-11-01T00:00:00, 2017-11-07T23:00:00]范围内的数据),并将这些数据映射到之前分段的时间轴(本例中每 3 小时有映射的数据为每天从2017-11-01T00:00:00到2017-11-07T23:00:00:00)。

由于结果范围内都有每个时间段的数据要显示,因此 SQL 语句的执行结果如下所示:

使用Apache IoTDB进行IoT相关开发的架构设计与功能实现(9)_时间轴_03

指定值的降频聚合查询 过滤条件

SQL 语句为:

  1. select count(status), max_value(temperature) from root.ln.wf01.wt01 where time > 2017-11-01T01:00:00 and temperature > 20 group by([2017-11-01T00:00:00, 2017-11-07T23:00:00), 3h, 1d);

这意味着:

由于用户将滑动步长参数指定为 1d,因此 GROUP BY 语句将延长时间间隔,而不是默认。1 day3 hours

上面 GROUP BY 语句的第一个参数是显示窗口参数,它决定了最终的显示范围是 [2017-11-01T00:00:00, 2017-11-07T23:00:00)。

上面 GROUP BY 语句的第二个参数是划分时间轴的时间间隔。以此参数(3h)为时间间隔,以显示窗口的开始时间为划分原点,将时间轴划分为几个连续区间,分别是[2017-11-01T00:00:00、2017-11-01T03:00:00)、[2017-11-02T00:00:00、2017-11-02T03:00:00)、[2017-11-03T00:00:00、2017-11-03T03:00:00)等。

上面 GROUP BY 语句的第三个参数是每个时间间隔移动的滑动步长。

然后系统将使用 WHERE 子句中的时间和值过滤条件和 GROUP BY 语句的第一个参数作为数据过滤条件,得到满足过滤条件的数据(本例中为(2017-11-01T01:00:00,2017-11-07T23:00:00]且满足root.ln.wf01.wt01.温度>20)范围内的数据, 并将这些数据映射到之前分段的时间轴(在这种情况下,从 3-2017-11T01:00:00 到 00-2017-11T07:23:00,每天每 00 小时都有映射的数据)。

使用Apache IoTDB进行IoT相关开发的架构设计与功能实现(9)_时间轴_04

左开和右闭合范围

SQL 语句为:

  1. select count(status) from root.ln.wf01.wt01 group by((5, 40], 5ms);

在此 sql 中,时间间隔为左打开和右关闭,因此我们不会包含时间戳 5 的值,而是包含时间戳 40 的值。

我们将得到如下结果:

时间

count(root.ln.wf01.wt01.status)

10

1

15

2

20

3

25

4

30

4

35

3

40

5

使用 Fill 子句的降频聚合查询

在按填充分组中,分组依据子句不支持滑动步骤

现在,分组按填充仅支持last_value聚合函数。

在按填充分组中不支持线性填充。

上一个和以前的区别
  • PREVIOUS 将填充任何空值,只要存在它之前的值不是空值。
  • PREVIOUSUNTILLAST 不会填充时间在该时间序列的最后一个时间之后的结果。

SQL 语句为:

  1. SELECT last_value(temperature) FROM root.ln.wf01.wt01 GROUP BY([8, 39), 5m) FILL (int32[PREVIOUSUNTILLAST])

这意味着:

使用上一页填充方式填充源下频聚合查询结果。

GROUP BY 语句中 SELECT 后面的路径必须是聚合函数,否则系统会给出相应的错误提示,如下所示:

使用Apache IoTDB进行IoT相关开发的架构设计与功能实现(9)_数据_05

最后一点查询

在 IoT 设备快速更新数据的场景中,用户对 IoT 设备的最新点更感兴趣。

最后一个点查询是以三列格式返回给定时间序列的最新数据点。

SQL 语句定义为:

  1. select last <Path> [COMMA <Path>]* from < PrefixPath > [COMMA < PrefixPath >]* <DISABLE ALIGN>

这意味着:查询并返回时间序列前缀 Path.path 的最后一个数据点。

结果将以三列表格式返回。

  1. | Time | Path | Value |

示例 1:获取 root.ln.wf01.wt01.speed 的最后一点:

  1. > select last speed from root.ln.wf01.wt01

  2. | Time | Path | Value |
  3. | --- | ----------------------- | ----- |
  4. | 5 | root.ln.wf01.wt01.speed | 100 |

示例 2:获取 root.ln.wf01.wt01 的最后一个速度、状态和温度点

  1. > select last speed, status, temperature from root.ln.wf01.wt01

  2. | Time | Path | Value |
  3. | --- | ---------------------------- | ----- |
  4. | 5 | root.ln.wf01.wt01.speed | 100 |
  5. | 7 | root.ln.wf01.wt01.status | true |
  6. | 9 | root.ln.wf01.wt01.temperature| 35.7 |

自动灌装

在IoTDB的实际使用中,在进行时间序列的查询操作时,可能会出现某些时间点值为null的情况,这会阻碍用户的进一步分析。为了更好地反映数据更改的程度,用户希望自动填充缺失值。因此,IoTDB系统引入了自动填充功能。

自动填充功能是指在对单列或多列进行时间序列查询时,根据用户指定的方法和有效时间范围填充空值。如果查询点的值不为 null,则填充函数将不起作用。

注意:在当前版本中,IoTDB为用户提供了两种方法:先前和线性。上一种方法用以前的值填充空白。线性方法通过线性拟合填充空白。并且 fill 函数只能在执行时间点查询时使用。

填充功能

  • 上一个函数

当查询时间戳的值为 null 时,使用上一个时间戳的值来填充空白。形式化的先前方法如下(有关详细语法,请参见第 7.1.3.6 节):

  1. select <path> from <prefixPath> where time = <T> fill(<data_type>[previous, <before_range>], …)

所有参数的详细说明见表3-4。

**表3-4 以前的填充参数列表**

参数名称(不区分大小写)

解释

路径,前缀路径

查询路径;必填项

T

查询时间戳(只能指定一个);必填项

data_type

填充方法使用的数据类型。可选值为 int32、int64、浮点型、双精度型、布尔值、文本;可选字段

before_range

表示上一种方法的有效时间范围。当存在 [T-before_range, T] 范围内的值时,前一种方法有效。如果未指定before_range,before_range采用默认值default_fill_interval;-1 表示无穷大;可选字段

在这里,我们给出了使用前面的方法填充空值的示例。SQL 语句如下:

  1. select temperature from root.sgcc.wf03.wt01 where time = 2017-11-01T16:37:50.000 fill(float[previous, 1m])

这意味着:

由于时间序列 root.sgcc.wf03.wt01.temperature在 2017-11-01T16:37:50.000 为空,因此系统使用之前的时间戳 2017-11-01T16:37:00.000(时间戳在 [2017-11-01T16:36:50.000, 2017-11-01T16:37:50.000] 时间范围内)进行填充和显示。

示例数据

使用Apache IoTDB进行IoT相关开发的架构设计与功能实现(9)_时间间隔_06

,此语句的执行结果如下所示:

使用Apache IoTDB进行IoT相关开发的架构设计与功能实现(9)_时间间隔_07

值得注意的是,如果在指定的有效时间范围内没有值,系统将不会填充null值,如下所示:

使用Apache IoTDB进行IoT相关开发的架构设计与功能实现(9)_时间轴_08

  • 线性法

当查询时间戳的值为 null 时,使用上一个和下一个时间戳的值来填充空白。形式化的线性方法如下:

  1. select <path> from <prefixPath> where time = <T> fill(<data_type>[linear, <before_range>, <after_range>]…)

标签:11,架构设计,00,填充,IoT,语句,IoTDB,参数,2017
From: https://blog.51cto.com/u_15123639/7242529

相关文章

  • 使用Apache IoTDB进行IoT相关开发的架构设计与功能实现(7)
    显示子路径SHOWCHILDPATHSprefixPath返回前缀路径的所有子路径,前缀路径可以包含*。示例:返回root.ln的子路径:显示root.ln的子路径+------------+| childpaths|+------------+|root.ln.wf01||root.ln.wf02|+------------+以root.xx.xx.xx的形式获取所有路径:显示根的子路径。*......
  • #是男人就做架构师# 系统架构设计师 案例复盘
    前言本文对2022年系统架构设计师下午题进行复盘总结,实际考试中,试题一是必做的,剩下题目4选2即可。今年的下午题结合了实际项目,是理论结合实践的典范。试题一 会员与促销管理系统某电子商务公司拟升级其会员与促销管理系统,向用户提供个性化服务,提高用户的粘性。在项目立项之初,公司领......
  • 【IOTE】物联网射频模组和芯片级方案提供商——深圳信驰达科技将精彩亮相IOTE物联网展
    ►►►强势来袭StrongAttack主物联场,相约深圳;2023,共论商机!IOTE2023第二十届国际物联网展·深圳站将于2023年9月20-22日在深圳国际会展中心(宝安新馆)开展!汇聚全球超800+家参展企业,呈现更多数字化纷呈。届时,深圳市信驰达科技将携其特色产品和优秀解决方案亮相展会现场,与大家共襄盛......
  • IPQ6010 QCN9074|Unleashing the Power of Long-Range Transmission in IIoT, Smart C
    UnleashingthePowerofLong-RangeTransmissioninIIoT,SmartCities,andSmartPortswithIPQ6010QCN9074Intheever-evolvinglandscapeofwirelesscommunication,thepossibilitiesseemboundless.Astechnologysurgesforward,sodoesourabilitytobri......
  • 智驾车联网网络架构设计
    智能化汽车的兴起:随着汽车科技的不断发展,智能汽车已经成为一种新的趋势,智能化的汽车需要通过车辆网络来实现车辆之间的通信和数据传输。 车辆网络安全是车辆网络的重要组成部分,随着车辆网络的不断发展,车辆网络安全的重要性日益凸显。车辆网络安全的具体实践车载防火墙:安装在车辆......
  • 使用.NET Core进行微服务架构设计
    当谈到构建现代化、可扩展的应用程序架构时,微服务架构已经成为一个备受关注的话题。在这篇博客中,我们将探讨如何使用.NETCore来设计和实现微服务架构,并提供一些示例代码来帮助你入门。什么是微服务架构?微服务架构是一种软件架构模式,其中应用程序被拆分为一组小型、自治的服务,每个......
  • 使用Apache IoTDB进行IoT相关开发的架构设计与功能实现(3)
    使用ApacheIoTDB进行IoT相关开发的架构设计与功能实现(3)接下来我给大家继续介绍一下ApacheIoTDB的数据类型和相关用法在显示时间戳时,IoTDB可以支持长类型和日期时间显示类型。日期时间显示类型可以支持用户定义的时间格式。自定义时间格式的语法如下表所示:**自定义时间格式的语......
  • 入门物联网,基于IoT平台构建智慧路灯应用的实验指南【玩转loT】
    前言自从了解到古茗前端团队使用Node.js写物联网代码,身为前端开发者,我对物联网充满了兴趣。我一直很认同一个有趣的观点:新技术的出现是为了让使用的人省时省力。而关于物联网雏形的故事,也包含了这一观点:1991年,剑桥大学特洛伊计算机实验室的科学家们,常常要下楼去看咖啡煮好了没有,......
  • 深入了解Elasticsearch搜索引擎篇:倒排索引、架构设计与优化策略
    什么是倒排索引?有什么好处?倒排索引是一种用于快速检索的数据结构,常用于搜索引擎和数据库中。与传统的正排索引不同,倒排索引是根据关键词来建立索引,而不是根据文档ID。倒排索引的建立过程如下:首先,将每个文档拆分成一系列的关键词或词项,然后建立一个词项到文档的映射。对每个关键......
  • 邀请函丨IOTE第二十届国际物联网盛宴,计讯物联蓄势待发展风采
    2023年9月20-22日,以“IoT构建数字经济底座”为主题的IOTE2023第二十届国际物联网▪深圳站即将于深圳国际会展中心(宝安新馆)盛大开幕。  计讯物联将携5G/4G工业级路由器、工业级DTU、工业级网关、边缘计算网关、智慧灯杆网关、AI智能网关、水利遥测终端、环保数采仪、高精度G......