如何在Apache IoTDB中查询多时间序列各自的最后N条数据？

问题背景 #

使用Apache IoTDB 1.3.6，需要同时查询多个时间序列各自的最后N条数据点。这些序列时间戳不同步，要求每个序列独立返回最近的N条记录，最终结果合并后按设备分组（每个设备对应N行）。

以两个序列为例：

• root.power.liantiechang.yihaogaolu.kuangcao._00034ea4
• root.power.liantiechang.5haogaolu.benti._00244dc9

目标是获取每个序列的最后4条数据，最终得到8行结果（每个设备4行）。

可复现示例数据 #

-- 创建时间序列
CREATE TIMESERIES `root.power.liantiechang.yihaogaolu.kuangcao._00034ea4` WITH DATATYPE=FLOAT;
CREATE TIMESERIES `root.power.liantiechang.5haogaolu.benti._00244dc9` WITH DATATYPE=FLOAT;

-- 插入序列1 (_00034ea4) 数据，时间戳1000-6000，间隔1000
INSERT INTO `root.power.liantiechang.yihaogaolu.kuangcao`(timestamp, _00034ea4) VALUES (1000, 10.0);
INSERT INTO `root.power.liantiechang.yihaogaolu.kuangcao`(timestamp, _00034ea4) VALUES (2000, 20.0);
INSERT INTO `root.power.liantiechang.yihaogaolu.kuangcao`(timestamp, _00034ea4) VALUES (3000, 30.0);
INSERT INTO `root.power.liantiechang.yihaogaolu.kuangcao`(timestamp, _00034ea4) VALUES (4000, 40.0);
INSERT INTO `root.power.liantiechang.yihaogaolu.kuangcao`(timestamp, _00034ea4) VALUES (5000, 50.0);
INSERT INTO `root.power.liantiechang.yihaogaolu.kuangcao`(timestamp, _00034ea4) VALUES (6000, 60.0);

-- 插入序列2 (_00244dc9) 数据，时间戳1500-5500，间隔1000
INSERT INTO `root.power.liantiechang.5haogaolu.benti`(timestamp, _00244dc9) VALUES (1500, 15.0);
INSERT INTO `root.power.liantiechang.5haogaolu.benti`(timestamp, _00244dc9) VALUES (2500, 25.0);
INSERT INTO `root.power.liantiechang.5haogaolu.benti`(timestamp, _00244dc9) VALUES (3500, 35.0);
INSERT INTO `root.power.liantiechang.5haogaolu.benti`(timestamp, _00244dc9) VALUES (4500, 45.0);
INSERT INTO `root.power.liantiechang.5haogaolu.benti`(timestamp, _00244dc9) VALUES (5500, 55.0);

已尝试的查询及结果 #

尝试1：通配符 + ORDER BY TIME DESC LIMIT 4 #

SELECT * FROM `root.power.liantiechang`.**
ORDER BY `TIME` DESC LIMIT 4;

结果：仅返回全局时间戳最大的4行，每行两列中有一列为null：

+-----------------------------+-------------------------------------------------+-----------------------------------------------------+
| `Time`|`root.power.liantiechang.5haogaolu.benti._00244dc9`|`root.power.liantiechang.yihaogaolu.kuangcao._00034ea4`|
+-----------------------------+-------------------------------------------------+-----------------------------------------------------+
|1970-01-01T08:00:06.000+08:00| `null`| 60.0|
|1970-01-01T08:00:05.500+08:00| 55.0| `null`|
|1970-01-01T08:00:05.000+08:00| `null`| 50.0|
|1970-01-01T08:00:04.500+08:00| 45.0| `null`|
+-----------------------------+-------------------------------------------------+-----------------------------------------------------+

尝试2：添加ALIGN BY DEVICE #

SELECT * FROM `root.power.liantiechang`.**
ALIGN BY DEVICE
ORDER BY `TIME` DESC LIMIT 4;

结果：仍为全局前4行，设备交替出现：

+-----------------------------+-------------------------------------------+---------+---------+
| `Time`| Device|_00244dc9|_00034ea4|
+-----------------------------+-------------------------------------------+---------+---------+
|1970-01-01T08:00:06.000+08:00|`root.power.liantiechang.yihaogaolu.kuangcao`| `null`| 60.0|
|1970-01-01T08:00:05.500+08:00| `root.power.liantiechang.5haogaolu.benti`| 55.0| `null`|
|1970-01-01T08:00:05.000+08:00|`root.power.liantiechang.yihaogaolu.kuangcao`| `null`| 50.0|
|1970-01-01T08:00:04.500+08:00| `root.power.liantiechang.5haogaolu.benti`| 45.0| `null`|
+-----------------------------+-------------------------------------------+---------+---------+

尝试3：使用LAST函数 #

SELECT last * FROM `root.power.liantiechang`.** ORDER BY `TIME` DESC LIMIT 4;

结果：仅返回每个序列的最新数据点，共2行：

+-----------------------------+-----------------------------------------------------+-----+--------+
| `Time`| Timeseries|Value|DataType|
+-----------------------------+-----------------------------------------------------+-----+--------+
|1970-01-01T08:00:06.000+08:00|`root.power.liantiechang.yihaogaolu.kuangcao._00034ea4`| 60.0| FLOAT|
|1970-01-01T08:00:05.500+08:00| `root.power.liantiechang.5haogaolu.benti._00244dc9`| 55.0| FLOAT|
+-----------------------------+-----------------------------------------------------+-----+--------+

LAST函数不支持指定数量（如last 4），执行会报错：

Msg: org.apache.iotdb.jdbc.IoTDBSQLException: 701: Constant operand is not allowed: 4

预期结果 #

希望获取每个序列的最后4条数据，按设备分组，每个设备内按时间戳降序排列，格式如下：

------ --------- -------
`Time`   Device    value
6000   device1   60.0
5000   device1   50.0
4000   device1   40.0
3000   device1   30.0
5500   device2   55.0
4500   device2   45.0
3500   device2   35.0
2500   device2   25.0
------ --------- -------

解决方案 #

1. IoTDB 1.3.6的限制 #

Apache IoTDB 1.3.6不支持在单个查询中直接为每个序列独立返回最后N条数据，因为LIMIT是全局生效的，而非针对每个序列；LAST函数仅能返回单条最新记录，无法指定数量。

2. 推荐实现方式：使用UNION ALL拼接单序列查询 #

针对每个序列单独查询其最后N条数据，再通过UNION ALL合并结果，最后按设备和时间戳排序。

示例SQL（获取每个序列最后4条）：

SELECT 
  `Time`,
  'root.power.liantiechang.yihaogaolu.kuangcao' AS Device,
  _00034ea4 AS value
FROM `root.power.liantiechang.yihaogaolu.kuangcao`
ORDER BY `Time` DESC LIMIT 4

UNION ALL

SELECT 
  `Time`,
  'root.power.liantiechang.5haogaolu.benti' AS Device,
  _00244dc9 AS value
FROM `root.power.liantiechang.5haogaolu.benti`
ORDER BY `Time` DESC LIMIT 4

ORDER BY Device, `Time` DESC;

说明：

• 每个子查询单独针对一个设备（序列所属的设备节点）查询，通过ORDER BY Time DESC LIMIT 4获取该设备对应序列的最后4条数据；
• 使用AS别名统一输出列名（Device和value），确保UNION ALL可以合并；
• 最后外层的ORDER BY Device, Time DESC实现按设备分组，且每个设备内按时间戳降序排列。

3. 后续版本优化（可选） #

IoTDB 1.4.0及以上版本支持窗口函数（如ROW_NUMBER()），可以更简洁地实现该需求。例如：

SELECT `Time`, Device, value
FROM (
  SELECT 
    `Time`,
    Device,
    value,
    ROW_NUMBER() OVER (PARTITION BY Device ORDER BY `Time` DESC) AS rn
  FROM `root.power.liantiechang`.**
  ALIGN BY DEVICE
) t
WHERE rn <=4
ORDER BY Device, `Time` DESC;

但该方案不适用于1.3.6版本。

内容的提问来源于stack exchange，提问作者MGS