Elasticsearch中Composite与Metric聚合结合异常问题排查

因为chargingPeriods是nested类型数组，Elasticsearch中nested类型的每个元素都是独立的子文档。如果直接在复合桶中对chargingPeriods.power执行max聚合，ES会回到根文档上下文，把当前匹配的所有根文档中所有chargingPeriods元素的power值全部纳入计算，自然得到全局最大值，而非当前复合桶对应的子文档的最大值。

需要在复合桶内嵌套三层聚合：

• 先用nested聚合进入chargingPeriods的嵌套上下文，确保只处理当前根文档下的嵌套子元素；
• 再用filter聚合筛选出属于当前复合桶时间区间的chargingPeriods子元素；
• 最后在筛选后的结果上执行max聚合，得到该复合桶内的power最大值。

{
  "query": {
    "term": {
      "messageType": "你的目标messageType值"
    }
  },
  "aggs": {
    "composite_buckets": {
      "composite": {
        "sources": [
          {
            "groupId": {
              "terms": {
                "field": "groupId"
              }
            }
          },
          {
            "time_interval": {
              "date_histogram": {
                "field": "payload.request.data.chargingPeriods.startDateTime",
                "fixed_interval": "2m"
              }
            }
          }
        ]
      },
      "aggs": {
        // 进入nested上下文
        "nested_charging_periods": {
          "nested": {
            "path": "payload.request.data.chargingPeriods"
          },
          "aggs": {
            // 筛选当前复合桶时间区间内的子元素
            "filter_current_time_slot": {
              "filter": {
                "range": {
                  "payload.request.data.chargingPeriods.startDateTime": {
                    "gte": "{{time_interval}}",
                    "lt": "{{time_interval}}+2m"
                  }
                }
              },
              "aggs": {
                // 计算该桶内的power最大值
                "max_power": {
                  "max": {
                    "field": "payload.request.data.chargingPeriods.power"
                  }
                }
              }
            }
          }
        }
      }
    }
  }
}

• 必须通过nested聚合切换到嵌套子文档的上下文，否则无法针对单个chargingPeriods元素做精准聚合；
• filter聚合的作用是确保只计算当前复合桶时间区间对应的子元素，避免跨区间的子元素干扰；
• 请确保nested聚合的path参数与索引中chargingPeriods的实际嵌套路径完全一致。

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