Flux实现指定站点下按Measurement分组求中位数的技术问询

以下是针对你需求的正确Flux脚本，替换你之前误用mean()的部分即可：

// 替换为你的bucket名称和时间范围
data = from(bucket: "your-bucket-name")
  |> range(start: v.timeRangeStart, stop: v.timeRangeStop)
  // 过滤目标site，替换为你的site标识字段和值
  |> filter(fn: (r) => r._measurement == "worker-service" and r.site == "target-site-id")
  // 按measurement的uuid分组（假设uuid存在于tag `measurement_uuid`，替换为实际字段名）
  |> group(columns: ["measurement_uuid"])
  // 对每个分组计算value的中位数
  |> median(column: "_value")
  // 可选：整理输出格式，只保留需要的字段
  |> keep(columns: ["measurement_uuid", "_value"])

关键步骤说明 #

• 过滤目标Site：通过filter精准筛选属于目标site的数据，确保只处理指定范围的measurement。
• 按Measurement分组：使用group(columns: ["measurement_uuid"])将同一uuid的三个测点数据归为一组，这是实现分组聚合的核心。
• 中位数计算：用median(column: "_value")替代原来的mean()，直接计算每组内三个value的中位数，匹配你的需求。
• 精简输出：keep函数只保留uuid和中位数结果，避免冗余数据干扰。

注意事项 #

• 确保measurement_uuid是你数据中标识每个measurement的实际tag/字段名，如果是其他字段（比如uuid），直接替换group和keep里的字段名即可。
• 若你的_measurement字段不是worker-service，同步修改filter中的对应值。

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