使用Spring数据ElasticsearchRepository在ElasticSearch中查找唯一字段值

Question

我有一个扩展Elasticsearch chRepository的接口，并成功创建了搜索方法，例如：

<代码>页面

现在，我希望找到一个endpoint，该endpoint将返回该customerCode的所有可能主机值，以便我可以在前端构建一个下拉列表，以选择要发送到该findByCustomerCodeAndHostendpoint的值，类似于：

<代码>列表

使用ElasticsearchRepository是否可能做到这一点？

我知道我可以使用不同的关键字，如List

编辑：以下是我如何实现我想要的，但由于目前无法使用ElasticsearchRepository实现这一点，因此这不是一个实际的“答案”。

我创建了一个Spring web RestController类，该类公开了一个执行聚合查询的GetMapping RESTendpoint。

kibana控制台中的查询：

GET auditresult/_search
{
  "size": "0",
  "aggs" : {
    "uniq_custCode" : {
      "terms" : { "field" : "customerCode", "include": "<CUSTOMER_CODE>" },
        "aggs" : {
          "uniq_host" : {
           "terms" : { "field" : "host"}
          }
        }
      }
    }
  }

基于这个问题，我提出了用Java进行ElasticSearch聚合

@GetMapping("/hosts/{customerCode}")
String getHostsByCustomer(@PathVariable String customerCode) {
    SearchRequest searchRequest = new SearchRequest("auditresult");
    SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder().size(0);
    IncludeExclude ie = new IncludeExclude(customerCode, "");
    TermsAggregationBuilder aggregation =
            AggregationBuilders
                    .terms("uniq_custCode").includeExclude(ie)
                    .field("customerCode")
                    .subAggregation(
                            AggregationBuilders
                                    .terms("uniq_host")
                                    .field("host")
                    );
    searchSourceBuilder.aggregation(aggregation);
    searchRequest.source(searchSourceBuilder);
    try {
        SearchResponse searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);
        Terms cust = searchResponse.getAggregations().get("uniq_custCode");
        StringBuilder sb = new StringBuilder();
        sb.append("{\"hosts\":[");
        for (Terms.Bucket bucket : cust.getBuckets()) {
            Terms hosts = bucket.getAggregations().get("uniq_hosts");
            for (Terms.Bucket host : hosts.getBuckets()) {
                System.out.println(host.getKey());
                sb.append("\"" + host.getKey() + "\",");
            }
        }
        String out = sb.toString();
        out = out.substring(0, out.length() - 1);
        return out + "]}";
    } catch (IOException e) {
        e.printStackTrace();
        return "{\"hosts\":[]}";
    }
}

Answer 1

这里您需要的是Spring Data称为projections的东西，对于Spring Data MongoDB，您可以阅读文档来了解它是如何工作的。

唉，这在Spring Data Elasticsearch中还没有实现，我在Jira中为此创建了一个问题。