InfluxDB Flux查询：按时间戳汇总多Agent运行会话数并补全缺失数据

问题背景 #

现有多Agent的会话运行数据，结构如下：

需要实现两个核心需求：

1. 按_time合并数据，计算每个时间点的RunningSessions总和
2. 处理数据缺失场景：若某时间点部分Agent未上报数据，用该Agent最后一次上报的数值参与求和

当前使用的Flux查询仅能处理无缺失的数据，无法应对Agent数据缺失的情况。

最优Flux查询方案 #

|> range(start: v.timeRangeStart, stop: v.timeRangeStop)
|> filter(fn: (r) => r["_measurement"] == "RunningSessions")
|> filter(fn: (r) => r["_field"] == "totalSessionsCount")
// 按Agent分组，用最后有效值补全缺失数据
|> group(columns: ["AgentName"])
|> fill(usePrevious: true)
// 按时间分组求总和
|> group()
|> group(columns: ["_time"])
|> sum(column: "_value")
|> group()

关键步骤说明 #

• Agent维度补全缺失值：先按AgentName分组，通过fill(usePrevious: true)将每个Agent缺失的时间点数据用最后一次上报的有效值补全，确保每个时间点所有Agent都有有效数据参与计算。
• 时间维度求和：补全数据后，按_time分组对所有Agent的会话数求和，得到每个时间点的总运行会话数。

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