Elasticsearch查询如何转换为正确的AggregationBuilder代码

你现有代码存在两处核心逻辑错误，和提供的原生DSL逻辑不匹配：

• 布尔查询结构嵌套错误：将customerId的匹配条件错误写在了must_not语句块内部，导致过滤逻辑完全偏离预期
• 聚合选型错误：你写的FilterAggregationBuilder是聚合级别的过滤，仅对当前聚合内部生效，不会作为全局查询条件过滤文档；而你的原生DSL是先全局过滤符合条件的文档，再对全量匹配文档做求和，不需要嵌套filter聚合层。

import org.elasticsearch.index.query.BoolQueryBuilder;
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.search.aggregations.AggregationBuilder;
import org.elasticsearch.search.aggregations.AggregationBuilders;
import org.elasticsearch.action.search.SearchRequest;
import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.search.builder.SearchSourceBuilder;
import org.elasticsearch.search.aggregations.metrics.Sum;

// 构建全局布尔查询条件，和原生DSL完全对齐
BoolQueryBuilder queryCondition = QueryBuilders.boolQuery()
        .must(QueryBuilders.matchQuery("customerId", "13b7e2e8-8bf0-435b-b7f7-949c2e69b1d7"))
        .mustNot(QueryBuilders.matchQuery("state", "Cancelled"));

// 构建求和聚合
AggregationBuilder sumAgg = AggregationBuilders.sum("totalStakes")
        .field("totalStake");

// 组装查询参数
SearchSourceBuilder sourceBuilder = new SearchSourceBuilder()
        .query(queryCondition)
        .aggregation(sumAgg);
// 不需要返回文档明细的话可以加.size(0)，大幅提升查询性能，需要保留hits则删除该行
// sourceBuilder.size(0);

// 绑定索引，执行查询（索引名替换成你实际使用的索引）
SearchRequest request = new SearchRequest("你的业务索引名")
        .source(sourceBuilder);
SearchResponse response = highLevelClient.search(request, RequestOptions.DEFAULT);

// 解析聚合结果
Sum totalStakesResult = response.getAggregations().get("totalStakes");
double totalStakesValue = totalStakesResult.getValue();

上述代码执行后返回的结构和你给出的预期格式完全一致：全局过滤后的文档会参与求和计算，聚合结果直接从aggregations.totalStakes.value字段获取，不需要额外解析filter聚合的嵌套层级。

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