如何将Elasticsearch JSON查询转为等效Java API（单次请求）

问题背景 #

需要将以下Elasticsearch JSON查询转为Java API，避免之前分两次请求获取min/max值的低效方式，实现单次请求完成。

原JSON查询 #

{
  "size": 0, 
  "query": {
    "match_all": {}
  },
  "aggs": {
    "min": {
      "min": {
        "field": "<The date>"
      }
    },
    "max":{
      "max": {
        "field": "<The date>"
      }
    }
  }
}

之前的尝试代码 #

MaxAggregationBuilder maxAgg = AggregationBuilders.max("max").field("date");
MinAggregationBuilder minAgg = AggregationBuilders.max("min").field("date"); // 此处存在方法调用错误

解决方案 #

你只需要在同一个SearchRequest中同时添加min和max两个聚合即可，无需拆分请求。完整实现代码如下：

完整Java代码示例 #

import org.elasticsearch.action.search.SearchRequest;
import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.search.aggregations.AggregationBuilders;
import org.elasticsearch.search.aggregations.metrics.Max;
import org.elasticsearch.search.aggregations.metrics.Min;
import org.elasticsearch.search.builder.SearchSourceBuilder;

import java.io.IOException;

public class EsMinMaxAggregation {
    public void fetchMinMaxDate(RestHighLevelClient esClient) throws IOException {
        // 1. 构建查询源，设置size=0以跳过文档内容返回
        SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
        sourceBuilder.size(0);
        sourceBuilder.query(QueryBuilders.matchAllQuery());

        // 2. 同时添加min和max聚合到同一个请求
        sourceBuilder.aggregation(AggregationBuilders.min("min").field("date"));
        sourceBuilder.aggregation(AggregationBuilders.max("max").field("date"));

        // 3. 绑定查询到指定索引的搜索请求
        SearchRequest searchRequest = new SearchRequest("your_target_index");
        searchRequest.source(sourceBuilder);

        // 4. 执行请求并解析结果
        SearchResponse response = esClient.search(searchRequest, RequestOptions.DEFAULT);
        
        Min minDateAgg = response.getAggregations().get("min");
        Max maxDateAgg = response.getAggregations().get("max");

        // 根据日期字段的存储类型提取值，这里以时间戳为例
        long minTimestamp = minDateAgg.getValueAsLong();
        long maxTimestamp = maxDateAgg.getValueAsLong();

        System.out.println("最小日期时间戳: " + minTimestamp);
        System.out.println("最大日期时间戳: " + maxTimestamp);
    }
}

关键注意点 #

• 修复了你之前代码的错误：创建MinAggregationBuilder时应该用AggregationBuilders.min()而非max()。
• SearchSourceBuilder.aggregation()支持多次调用，可在同一个请求中添加任意多个聚合。
• 设置size=0能大幅减少响应数据量，因为我们只需要聚合结果，不需要返回具体文档。
• 解析聚合结果时，通过聚合的名称（即你定义的"min"和"max"）从响应中获取对应的聚合对象，再根据字段类型提取值（如果是格式化日期字符串，可改用getValueAsString()）。

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