Spring Boot3+Spring Data ES5实现品牌聚合查询失败求助

环境 #

Spring Boot 3 + Spring Data Elasticsearch 5 + Elasticsearch 8

核心问题 #

执行查询能返回文档结果，但始终无法获取聚合后的品牌列表，Postman中相同逻辑的查询可正常返回聚合结果。

Postman中可正常运行的查询 #

{
    "size": 0,
    "aggs": {
        "distinct_brand": {
            "terms": {
                "field": "brand",
                "size": 10000,
                "order": {
                    "_key": "asc"
                }
            }
        }
    }
}

现有实现的问题点 #

你的三个测试代码都存在核心错误：只提取了搜索命中的文档，完全没有处理聚合结果。聚合结果并不在searchHits.getSearchHits()里，而是存储在searchHits.getAggregations()中。此外部分代码还存在JSON格式错误。

测试1：StringQuery的问题 #

• JSON格式错误："match_all" : {}后面多了逗号，导致JSON结构无效
• 未提取聚合结果
• 若仅需聚合数据，建议将size设为0，减少不必要的数据传输

测试2：AggregationBuilders的问题 #

• 未提取聚合结果
• 同样，若不需要文档，可设置size为0

测试3：JsonParser和SearchRequest的问题 #

• JSON字符串格式错误："match_all" : {}后多了逗号，反序列化可能失败
• 未提取聚合结果

修正后的实现示例 #

修正测试2（推荐使用原生构建方式） #

// 构建聚合，补充排序规则
Aggregation aggregation = AggregationBuilders.terms(ta -> 
    ta.field("brand")
      .size(10000)
      .order(Map.of("_key", SortOrder.ASC))
);

// 构建查询，size设为0只返回聚合结果
Query query = NativeQuery.builder()
        .withQuery(q -> q.matchAll(ma -> ma))
        .withAggregation("distinct_brand", aggregation)
        .withPageable(PageRequest.of(0, 0))
        .build();

SearchHits<Brand> searchHits = elasticsearchOperations.search(query, Brand.class);

// 提取聚合结果
Aggregations aggregations = searchHits.getAggregations();
if (aggregations != null) {
    TermsAggregation termsAgg = aggregations.get("distinct_brand");
    if (termsAgg != null) {
        // 遍历聚合桶，提取品牌名称
        List<String> brandList = termsAgg.getBuckets().stream()
                .map(Terms.Bucket::getKey)
                .map(Object::toString)
                .collect(Collectors.toList());
        // 此处可使用brandList
    }
}

修正测试1：StringQuery #

// 修正JSON格式错误，size设为0
String queryJson = """
{
    "match_all": {},
    "size": 0,
    "aggs": {
        "distinct_brand": {
            "terms": {
                "field": "brand",
                "size": 10000,
                "order": {
                    "_key": "asc"
                }
            }
        }
    }
}
""";

Query query = new StringQuery(queryJson);
SearchHits<Brand> searchHits = elasticsearchOperations.search(query, Brand.class);

// 提取聚合结果
Aggregations aggregations = searchHits.getAggregations();
if (aggregations != null) {
    TermsAggregation termsAgg = aggregations.get("distinct_brand");
    if (termsAgg != null) {
        List<String> brandList = termsAgg.getBuckets().stream()
                .map(b -> b.getKey().toString())
                .collect(Collectors.toList());
    }
}

关键注意事项 #

1. 聚合结果提取：必须通过searchHits.getAggregations()获取，而非从文档命中结果中提取
2. size设置：如果只需要聚合数据，将size设为0可以避免返回大量无关文档，提升性能
3. JSON格式正确性：手动拼接JSON时要注意语法，避免多余逗号或缺失括号
4. 字段映射：确保Brand实体中的brand字段与Elasticsearch中的字段映射一致（比如需为keyword类型，terms聚合需要精确值，text类型会被分词导致聚合结果不符合预期）

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