infuxdb子查询中的子句

Question

有一些问题将我的大脑围绕着这个问题。我在infuxdb 1.8.x中有两个表，这是相关的数据布局，

table a
-------------------------------------------
|time               |hostname|device_cache|
|6/14/2022 9:00:30PM|device1 |dm-4        |
|6/14/2022 9:00:30PM|device2 |dm-4        |
|6/14/2022 9:00:30PM|device3 |dm-8        |
-------------------------------------------

table b
-----------------------------------------------------
|time               |hostname|diskiodevice|diskiola1|
|6/14/2022 9:00:30PM|device1 |dm-0        |8        | 
|6/14/2022 9:00:30PM|device1 |dm-4        |7        |
|6/14/2022 9:00:30PM|device3 |dm-3        |9        |
|6/14/2022 9:00:30PM|device2 |dm-2        |8        |
|6/14/2022 9:00:30PM|device3 |dm-8        |15       |
|6/14/2022 9:00:30PM|device2 |dm-4        |9        |
|6/14/2022 9:00:30PM|device3 |dm-3        |1        |
-----------------------------------------------------

因此，我要做的是从表B中获取diskiola1值的所有diskiola1值，这些diskiola1值从表B中从表a定义为特定hostname输入的表A的device_cache项目。这是我尝试的：

SELECT max("diskiola1")
FROM "table b"
WHERE hostname = 'device1'
AND
time > now() - 10m
AND
"cache_device" IN
( Select distinct("device_cache") as "cache_device" FROM "table a" WHERE hostname = 'device1')
GROUP BY time(20s)

我的目标是将其作为图表中的时间序列，以在一段时间内仅用于设备_CACHE项目，以显示给定主机的diskiola1值。这些数据是给我使用的，我真的无法修改它。

有人看到我出了什么问题吗？我收到的错误是 err：错误解析查询：发现，预期;

Answer 1

不幸的是，InfuxQl不支持操作员或可预见的将来（请参阅详细信息在这里。 InfluxQl也不支持加入操作（请参阅详细信息 >）。

似乎您的“ table_a”更像是映射表，而“ table_b”实际上存储了时间序列数据。假设主机名是标签，而device_cache是​​“表A”的字段；主机名是标签，而diskiodevice和diskiola1是“表B”的字段。您可以尝试启用flux 并尝试以下示例代码

aDistinctDeviceCache = from(bucket:"yourDatabaseName/yourRentionPolicyName")
|> range(start: 2018-05-22T23:30:00Z, stop: 2018-05-23T00:00:00Z)   // start and stop can be changed
|> filter(fn:(r) => r._measurement == "table a" and r.hostname == "device1" and r._field == "device_cache")
|> distinct()

bDevice1 = from(bucket:"yourDatabaseName/yourRentionPolicyName")
|> range(start: -10m)
|> filter(fn:(r) => r._measurement == "table b" and r.hostname == "device1")
|> rename(columns: {diskiodevice: "device_cache"})

maxDiskiola1ForDevice1 = 
join(tables:{aPlus:aDistinctDeviceCache, bPlus:bDevice1}, on:["hostname", "device_cache"])
|> window(every: 20s)
|> max("diskiola1")
|> yield()

：首先从“ table_a”中获取不同的值，然后重命名“ table_b”的某些字段，以便我们可以在最后一步中将两个表连接在一起。

以下是一些更多提示，可以转换您的流向通量并转换您的 subquies 。