ElasticsearchRestTemplate的聚合查询

ElasticsearchRestTemplate是Spring Data Elasticsearch提供的一个Rest客户端，可以用于与Elasticsearch进行交互。要使用ElasticsearchRestTemplate进行聚合查询，需要使用Elasticsearch的聚合API。

以下是一个简单的示例，演示如何使用ElasticsearchRestTemplate进行聚合查询：

import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.search.aggregations.AggregationBuilders;
import org.elasticsearch.search.aggregations.bucket.histogram.DateHistogramInterval;
import org.elasticsearch.search.aggregations.bucket.histogram.Histogram;
import org.elasticsearch.search.aggregations.metrics.avg.Avg;
import org.elasticsearch.search.aggregations.metrics.sum.Sum;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.elasticsearch.core.ElasticsearchRestTemplate;
import org.springframework.stereotype.Service;

import java.util.Date;

@Service
public class AggregationService {

    @Autowired
    private ElasticsearchRestTemplate elasticsearchRestTemplate;

    public void aggregate() {
        SearchResponse response = elasticsearchRestTemplate.getClient().prepareSearch("my_index")
                .setQuery(QueryBuilders.matchAllQuery())
                .addAggregation(AggregationBuilders.dateHistogram("histogram")
                        .field("timestamp")
                        .dateHistogramInterval(DateHistogramInterval.DAY)
                        .subAggregation(AggregationBuilders.sum("sum").field("value"))
                        .subAggregation(AggregationBuilders.avg("average").field("value")))
                .execute().actionGet();

        Histogram histogram = response.getAggregations().get("histogram");
        for (Histogram.Bucket entry : histogram.getBuckets()) {
            Date date = (Date) entry.getKey();
            Sum sum = entry.getAggregations().get("sum");
            Avg avg = entry.getAggregations().get("average");

            // Do something with the aggregations
        }
    }
}

在这个示例中，我们使用ElasticsearchRestTemplate执行一个聚合查询。我们首先使用`QueryBuilders.matchAllQuery()`创建一个查询，然后使用`.addAggregation()`添加一个聚合。在这个聚合中，我们使用`AggregationBuilders.dateHistogram()`创建一个日期直方图聚合，聚合字段为`timestamp`，聚合间隔为每天。我们还添加了两个子聚合，一个求和聚合和一个平均值聚合。

在执行查询后，我们从响应中获取`Histogram`对象，并遍历每个直方图条目。对于每个条目，我们从聚合中获取求和和平均值，并对它们进行操作。