elasticsearch java客户端解析聚合json查询

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.common.unit.TimeValue;
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.search.aggregations.AggregationBuilders;
import org.elasticsearch.search.aggregations.bucket.terms.Terms;
import org.elasticsearch.search.builder.SearchSourceBuilder;

import java.io.IOException;

public class ElasticsearchAggregationExample {
    public static void main(String[] args) {
        // 创建Elasticsearch客户端
        RestHighLevelClient client = createClient();

        // 创建聚合查询请求
        SearchRequest request = new SearchRequest("index_name");
        SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
        sourceBuilder.query(QueryBuilders.matchAllQuery());
        sourceBuilder.aggregation(AggregationBuilders.terms("my_terms_agg").field("field_name"));
        sourceBuilder.size(0);
        request.source(sourceBuilder);

        try {
            // 执行聚合查询
            SearchResponse response = client.search(request, RequestOptions.DEFAULT);

            // 解析聚合结果
            Terms termsAggregation = response.getAggregations().get("my_terms_agg");
            for (Terms.Bucket bucket : termsAggregation.getBuckets()) {
                String key = bucket.getKeyAsString();
                long docCount = bucket.getDocCount();
                System.out.println("Key: " + key + ", Doc Count: " + docCount);
            }
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            // 关闭Elasticsearch客户端
            closeClient(client);
        }
    }

    private static RestHighLevelClient createClient() {
        // 创建Elasticsearch客户端
        return new RestHighLevelClient(/* 配置Elasticsearch连接信息 */);
    }

    private static void closeClient(RestHighLevelClient client) {
        // 关闭Elasticsearch客户端
        try {
            client.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}