InfluxDB 是否可以进行具有相同源和目标测量但具有不同/新标签的连续查询？

Question

下面是我提出这个问题的场景。

要求： 在 influxDb 中预先聚合时间序列数据，粒度为设备中每个传感器的秒、分钟、小时、天和周。

当前提案： 当设备载入时，为设备的每个传感器创建五个连续查询（每个粒度级别一个，即秒、分钟...），保留策略与原始时间序列数据的保留策略不同。

当前提案的限制： 随着设备/传感器（时间序列数据源）数量的增加，influx 会因过多的连续查询（不推荐）而变得臃肿，并且会对 influxDb 实例本身造成影响。

问题： 为了避免上述问题，是否有可能在同一源测量（即原始时间序列测量）上创建连续查询，但是可以使用引入的新标签在测量中区分聚合，以区分连续查询的结果与原始的结果测量中的时间序列数据。

示例：

CREATE CONTINUOUS QUERY "strain_seconds" ON "database"
RESAMPLE EVERY 5s FOR 1m
BEGIN
  SELECT MEAN("strain_top") AS "STRAIN_TOP_MEAN" INTO "database"."raw"."strain" FROM "database"."raw"."strain" GROUP BY time(1s),*
END

Answer 1

据我所知，并从文档中看到，不可能在连续查询中应用新标签。

如果我正确理解了要求，这是您可以解决的一种方法。

CREATE CONTINUOUS QUERY "strain_seconds" ON "database"
RESAMPLE EVERY 5s FOR 1m
BEGIN
  SELECT MEAN("strain_top") AS "STRAIN_TOP_MEAN" INTO "database"."raw"."strain" FROM "database"."strain_seconds_retention_policy"."strain" GROUP BY time(1s),*
END

这会将数据保存在相同的度量中，但保留策略不同 - strain_seconds_retention_policy。当您执行select 时，您指定了从中选择的相应保留策略。
请注意，不能同时从多个保留策略执行select。如果您不指定一个，则使用默认的一个（而不是全部）。如果这是您需要的东西，那么可以使用另一种方法。

我不太明白为什么您需要为每个设备和每个传感器定义一个连续查询。您只需要定义五个（每秒 1 个、分钟、小时、天、周）并执行您已经执行的 group by *（全部）。只要源数据点有一个带有相应设备和传感器 id 的标签，重新采样的数据点也会有它。任何新添加的设备（数据）只会由这 5 个查询自动处理并保存到相应的保留策略中。

如果您确实想应用其他标签，您可以在自定义脚本中处理数据库外部的数据，并使用您需要的任何其他标签将其写回，而不是使用连续查询