使用Spring数据Elasticsearch、ElasticsearchRepository从Elasticsearch获取聚合信息

Question

我希望从ES中获得聚合结果，例如，对于与术语匹配的文档，avgSize（名称为“size”的字段的平均值）、totalhits，以及将来的一些其他聚合，我认为ElasticsearchRepository没有任何方法可调用。我构建了查询和聚合生成器，如下所示。我想使用我的存储库接口，但我不确定返回的ObjectType应该是什么？它应该是我的DTO中的文档类型吗？此外，我还看到了一些示例，其中searchQuery直接传递给ElasticsearchTemplate，但是拥有扩展ElasticsearchRepository的存储库接口有什么意义

存储库界面

public interface CCFilesSummaryRepository extends ElasticsearchRepository<DataReferenceSummary, UUID> {

}

弹性配置

@Configuration
@EnableElasticsearchRepositories(basePackages = "com.xxx.repository.es")
public class ElasticConfiguration {
    @Bean
    public ElasticsearchOperations elasticsearchTemplate() throws UnknownHostException {
        return new ElasticsearchTemplate(elasticsearchClient());
    }
    @Bean
    public Client elasticsearchClient() throws UnknownHostException {
        Settings settings = Settings.builder().put("cluster.name", "elasticsearch").build();
        TransportClient client = new PreBuiltTransportClient(settings);
        client.addTransportAddress(new TransportAddress(InetAddress.getLocalHost(), 9200));
        return client;
    }
}

服务方式

  public DataReferenceSummary createSummary(final DataSet dataSet) {
    try {


      QueryBuilder queryBuilder = QueryBuilders.matchQuery("type" , dataSet.getDataSetCreateRequest().getContentType());
      AvgAggregationBuilder avgAggregationBuilder =  AggregationBuilders.avg("avg_size").field("size");
      ValueCountAggregationBuilder valueCountAggregationBuilder = AggregationBuilders.count("total_references")
              .field("asset_id");

      SearchQuery searchQuery = new NativeSearchQueryBuilder()
              .withQuery(queryBuilder)
              .addAggregation(avgAggregationBuilder)
              .addAggregation(valueCountAggregationBuilder)
              .build();


      return ccFilesSummaryRepository.search(searchQuery).iterator().next();


    } catch (Exception e){
      e.printStackTrace();
    }
    return null;

  }

DataReferernce摘要现在只是一个POJO，我在构建过程中收到一个错误，上面写着无法构建Bean CCFilesSummaryRepository， illegalArgumentException DataReferernceSummary。不是一个amanged对象




Answer 1

首先，数据引用摘要必须是一个用文档注释的类。

在Spring Data Elasticsearch 3.2.0（当前版本）中，需要将存储库返回类型定义为聚合页面

从即将发布的4.0版开始，您必须将返回类型定义为SearchHits