如何处理K6 Trend中同一时间戳的重复值，保留最新有效值

问题说明 #

从Datadog获取指标时，同一时间戳会返回两个值：先出现错误峰值，后出现正确值。使用K6的Trend指标收集数据时，会将两个值全部纳入统计，导致计算出的max值被错误峰值拉高。由于K6每次迭代都是全新启动，无法通过全局映射记录已处理时间戳，需要实现同一时间戳下仅保留最新值的逻辑。

当前代码直接遍历Datadog返回的所有points并添加到Trend指标，未做去重处理，是问题的核心原因。

解决方案 #

核心思路是在解析Datadog返回结果的阶段，对同一时间戳的指标点仅保留最后出现的那个值（即正确值），处理逻辑完全在单次迭代内完成，避开K6无状态的限制。

1. 修改parseMetricQuery函数，添加去重逻辑 #

使用Map结构存储每个时间戳的最新值，遍历原始指标点时，后续出现的同时间戳值会直接覆盖之前的旧值，最后再将Map转换回所需的数组格式。

修改后的代码如下：

export function parseMetricQuery(response) {
  const responseBody = response.json();
  // 检查无效响应
  if (responseBody.series === undefined || response.status != 200) {
    fail("Failed to get Datadog metric");
  }
  // 处理空响应
  if (responseBody.series.length === 0) {
    return {
      sum: 0,
      length: 0,
      average: 0,
      points: [],
      url: response.request.url,
    };
  } else {
    const rawSeries = responseBody.series[0].pointlist;
    // 用Map存储每个时间戳的最新值，后续同时间戳值自动覆盖旧值
    const latestPointsMap = new Map();
    
    rawSeries.forEach(point => {
      const timestamp = point[0];
      const value = point[1];
      latestPointsMap.set(timestamp, value);
    });
    
    // 将Map转换回[timestamp, value]格式的数组
    const series = Array.from(latestPointsMap.entries());
    const length = series.length;
    const sum = series
      .map(val => val[1])
      .reduce((prev, curr) => prev + curr, 0);
    
    return {
      sum: sum,
      length: length,
      average: sum / length,
      points: series,
      url: response.request.url,
    };
  }
}

2. 效果验证 #

修改后，parseMetricQuery返回的points数组中，每个时间戳只会保留最后出现的正确值。后续将这些值添加到K6的Trend指标时，错误峰值会被过滤，统计出的max值将符合预期（即15.57）。

关键说明 #

• 该方案无需全局状态：去重逻辑完全在单次查询的解析阶段完成，适配K6每次迭代无状态的特性。
• 适配Datadog数据特性：从日志输出看，同一时间戳的第二个值是Datadog最终计算后的正确结果，通过覆盖旧值可直接获取目标数据。

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