RestHighLevelClient对多个字段进行分组 计数 script

您好！针对您的问题，您可以使用Elasticsearch的聚合功能来对多个字段进行分组计数。以下是一个使用RestHighLevelClient执行此操作的示例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.bucket.MultiBucketsAggregation;
import org.elasticsearch.search.aggregations.bucket.terms.Terms;
import org.elasticsearch.search.builder.SearchSourceBuilder;

import java.io.IOException;

public class Example {

    public void groupCount(RestHighLevelClient client) throws IOException {

        // 构建搜索请求
        SearchRequest searchRequest = new SearchRequest("your_index");
        SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();

        // 添加查询条件
        searchSourceBuilder.query(QueryBuilders.matchAllQuery());

        // 添加聚合
        searchSourceBuilder.aggregation(AggregationBuilders
                // 定义分组字段
                .terms("group_by_field")
                // 添加子聚合，计算每个分组的数量
                .subAggregation(AggregationBuilders.count("count"))
                // 根据多个字段进行分组
                .field("field1")
                .field("field2")
                .size(10));

        // 设置搜索源
        searchRequest.source(searchSourceBuilder);

        // 执行搜索请求
        SearchResponse searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);

        // 处理搜索结果
        Terms terms = searchResponse.getAggregations().get("group_by_field");
        for (Terms.Bucket bucket : terms.getBuckets()) {
            // 获取分组字段的值
            String groupByFieldValue = bucket.getKeyAsString();
            // 获取分组数量
            long count = ((MultiBucketsAggregation) bucket.getAggregations().get("count")).getBucketByKey(groupByFieldValue).getDocCount();
            // 处理分组结果
            System.out.println(groupByFieldValue + ": " + count);
        }
    }
}

在上面的代码中，我们首先构建了一个搜索请求，然后添加了一个查询条件。接下来，我们使用`AggregationBuilders.terms()`方法定义了一个分组聚合，并使用`.field()`方法指定了需要分组的字段。我们还添加了一个子聚合来计算每个分组的数量。最后，我们执行了搜索请求，并从搜索结果中获取了分组结果。

希望这可以帮助到您！