java - ElasticSearch Java API AggregationBuilder 过滤器/全局 "name"参数导致 JSON 格式错误

Question

我试图使用 elasticsearch java API(版本 5.5.0)构建一个简单的聚合查询，但是 AggregationBuilder 的过滤器/全局方法采用的“名称”参数导致格式错误的 JSON。

比如我试了第一个例子here ...这是相关的代码部分:

AggregationBuilder builder = 
  AggregationBuilders
  .global("agg")
  .subAggregation(AggregationBuilders.terms("genders").field("gender"));

Search search = new Search.Builder(builder.toString())
            .addIndex(INDEX_NAME)
            .addType(TYPE_NAME)
            .setParameter(Parameters.SIZE,0).build();

    JestClient jestClient = getJestClient();

    try {
        SearchResult result = jestClient.execute(search);
        System.out.println(result.getJsonString());
    } catch (IOException e) {
        e.printStackTrace();
    }

这会产生以下错误消息:

{
"error": {
"root_cause": [
  {
    "type": "parse_exception",
    "reason": "Failed to derive xcontent"
  }
],
"type": "search_phase_execution_exception",
"reason": "all shards failed",
"phase": "query",
"grouped": true,
"failed_shards": [
  {
    "shard": 0,
    "index": "index_name",
    "node": "UEjNVXkIQRSBCOpyqcq2dw",
    "reason": {
      "type": "parse_exception",
      "reason": "Failed to derive xcontent"
    }
  }
]
},
"status": 400
}

在调试和观察构建器的值时，我看到它构建了以下格式错误的 JSON(请注意来自“全局”方法的“名称”参数的第一个元素(“agg”)):

"agg"{
  "global" : { },
  "aggregations" : {
    "genders" : {
      "terms" : {
        "field" : "gender",
        "size" : 10,
        "min_doc_count" : 1,
        "shard_min_doc_count" : 0,
        "show_term_doc_count_error" : false,
        "order" : [
          {
            "_count" : "desc"
          },
          {
            "_term" : "asc"
          }
        ]
      }
    }
  }
}

有什么想法吗？

Answer 1

使用最简单的示例，根据文档(here 和 here)，稍微修改您的代码，如下所示:

AggregationBuilder builder = AggregationBuilders.global("agg").subAggregation(AggregationBuilders.terms("genders").field("gender"));
SearchResponse response = client.prepareSearch(INDEX_NAME).setTypes(TYPE_NAME).setSize(0).addAggregation(builder).get();
//Global aggResult = response.getAggregations().get("agg"); //Global result can be used to retrieve values from the aggregation directly
System.out.println(response);

上面的代码(客户端初始化后)工作正常，因此 java API 中的 AggregationBuilder 绝对没有问题。

实际上，我不明白您为什么不使用 SearchResponse 类，因为它在文档中的所有示例中无所不在。

编辑:鉴于 link ，我相信你的问题来自你如何创建你的搜索查询，因为你只使用聚合，给出你在帖子中显示的输出，而完整的查询(Jest 客户端似乎需要)应该是这样的:

{
  "size" : 0,
  "aggregations" : {
    "agg" : {
      "global" : { },
      "aggregations" : {
        "genders" : {
          "terms" : {
            "field" : "gender",
            "size" : 10,
            "min_doc_count" : 1,
            "shard_min_doc_count" : 0,
            "show_term_doc_count_error" : false,
            "order" : [
              {
                "_count" : "desc"
              },
              {
                "_term" : "asc"
              }
            ]
          }
        }
      }
    }
  }
}

另一个编辑:实际上，一种解决方法是使用传输客户端构建查询，然后通过 JEST API 将其注入(inject)到搜索中，如下所示:

AggregationBuilder builder = AggregationBuilders.global("agg")
                .subAggregation(AggregationBuilders.terms("genders")
                        .field("gender"));
SearchRequestBuilder queryBuilder= client2.prepareSearch(INDEX_NAME)
        .setTypes(TYPE_NAME).setSize(0).addAggregation(builder); //client2 is a client initialized with the transport client
Search search = new Search.Builder(queryBuilder.toString()).addIndex("_all").addType("*").build();
SearchResult res = client.execute(search);
//          System.out.println(res.toString());
System.out.println(res.getJsonString());

P.S:我也在使用 Elasticsearch 客户端 API 的 5.5.0 版本。