Elasticsearch嵌套对象聚合：获取属性对象Top3结果

没问题，刚接触Elasticsearch不用慌，我来帮你搞定这个嵌套对象的Top3聚合需求～根据你的文档结构，我分两种常见场景给出解决方案：

场景1：针对每个属性字段单独获取Top3值 #

如果你的需求是分别统计Size、Brand、Color等每个字段中出现频率最高的前3个值，可以直接用terms聚合——因为你的attribute是普通object类型（非数组嵌套），无需额外的nested聚合：

GET /你的索引名/_search
{
  "size": 0, // 不返回原始文档，只返回聚合结果
  "aggs": {
    "top_size_values": {
      "terms": {
        "field": "source.detail.attribute.Size.keyword", // 用keyword字段确保精确匹配
        "size": 3 // 指定返回Top3
      }
    },
    "top_brand_values": {
      "terms": {
        "field": "source.detail.attribute.Brand.keyword",
        "size": 3
      }
    },
    "top_color_values": {
      "terms": {
        "field": "source.detail.attribute.Color.keyword",
        "size": 3
      }
    }
    // 其他属性字段（Type、Model、Manufacturer）可以按照同样的方式添加聚合
  }
}

这个查询会分别返回每个属性字段的Top3高频值，结果里每个聚合项会包含具体值和对应的出现次数。

场景2：合并所有属性键值对，取Top3高频项 #

如果你的需求是把attribute下所有键值对（比如Brand:Sandisk、Size:32 Gb）合并统计，取出现频率最高的前3个组合，可以用**脚本化聚合（scripted_metric）**来实现：

GET /你的索引名/_search
{
  "size": 0,
  "aggs": {
    "top3_attribute_pairs": {
      "scripted_metric": {
        "init_script": "state.attributes = [:]", // 初始化存储统计结果的map
        "map_script": """
          // 从原始文档中获取attribute对象
          def attribute = ctx._source.source.detail.attribute;
          // 遍历每个属性键值对
          for (entry in attribute.entrySet()) {
            def key = entry.getKey();
            def valueArr = entry.getValue();
            def attrValue = valueArr[0]; // 取数组第一个元素作为属性值
            def keyValuePair = key + ':' + attrValue;
            // 累加统计次数
            if (state.attributes.containsKey(keyValuePair)) {
              state.attributes[keyValuePair] += 1;
            } else {
              state.attributes[keyValuePair] = 1;
            }
          }
        """,
        "combine_script": """
          // 单分片内排序并取Top3
          return state.attributes.entrySet().stream()
            .sorted(Collections.reverseOrder(Map.Entry.comparingByValue()))
            .limit(3)
            .collect(Collectors.toMap(Map.Entry::getKey, Map.Entry::getValue));
        """,
        "reduce_script": """
          // 合并所有分片的结果，再排序取最终Top3
          def finalStats = [:];
          for (shardResult in states) {
            for (entry in shardResult.entrySet()) {
              def pair = entry.getKey();
              def count = entry.getValue();
              finalStats[pair] = (finalStats.get(pair) ?: 0) + count;
            }
          }
          return finalStats.entrySet().stream()
            .sorted(Collections.reverseOrder(Map.Entry.comparingByValue()))
            .limit(3)
            .collect(Collectors.toMap(Map.Entry::getKey, Map.Entry::getValue));
        """
      }
    }
  }
}

特殊处理：如果数组第二个元素是权重 #

注意到你的文档里每个属性值是数组（比如Size: ["32 Gb",4]），如果第二个元素是权重值，想要按权重总和排序取Top3，只需要修改map_script里的累加逻辑：

// 替换map_script中的累加部分
state.attributes[keyValuePair] = (state.attributes.get(keyValuePair) ?: 0) + valueArr[1];

这样聚合结果会按照权重总和来排序，返回权重最高的Top3属性键值对。

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