弹性Java客户端从HTTP API返回不同的结果

前端之家收集整理的这篇文章主要介绍了弹性Java客户端从HTTP API返回不同的结果前端之家小编觉得挺不错的,现在分享给大家,也给大家做个参考。

我有一个使用Elasticsearch Java API(5.6.7)的应用程序来执行聚合查询(术语).我使用curl和HTTP API(显示相关信息)创建了以下搜索文档:

{
  "from" : 0,"size" : 0,"sort" : [
    {
      "@timestamp" : {
        "order" : "desc"
      }
    }
  ],"aggregations" : {
    "level" : {
      "terms" : {
        "field" : "level.keyword","size" : 10,"min_doc_count" : 1,"shard_min_doc_count" : 0,"show_term_doc_count_error" : false,"order" : [
          {
            "_count" : "desc"
          },{
            "_term" : "asc"
          }
        ]
      }
    }
  }
}

既然已经在我的Java程序中实现了查询,我注意到结果与HTTP API结果不同!

两者都返回与分片,命中数等完全相同的元信息:

{
  "took": 1,"timed_out": false,"_shards": {
    "total": 5,"successful": 5,"skipped": 0,"Failed": 0
  },"hits": {
    "total": 3659,"max_score": 0.0,"hits": [

    ]
  }

但是,从Java API返回的聚合不包含任何存储桶:

  "aggregations": {
    "level": {
      "doc_count_error_upper_bound": 0,"sum_other_doc_count": 0,"buckets": [

      ]
    }

虽然HTTP API中的相同聚合确实包含存储桶:

  "aggregations": {
    "level": {
      "doc_count_error_upper_bound": 0,"buckets": [
        {
          "key": "INFO","doc_count": 2691
        },{
          "key": "WARN","doc_count": 776
        },{
          "key": "ERROR","doc_count": 192
        }
      ]
    }

我100%确定搜索文档是相同的(从Java应用程序日志中复制它).

问:什么可能导致这种差异?

编辑
我构建查询的java代码是(包含很多对其他类的引用):

    // Start building the search itself
    SearchRequestBuilder srch = client.prepareSearch(indices.toArray(new String[indices.size()]))
            .setTypes(types.toArray(new String[types.size()])).setFrom(0).setSize(0);
    // Conditional sort order
    if (t.getOrder() != null)
        srch.addSort(t.getOrder().getBuilder());
    // Add aggregationbuilders to this search
    for (NivoStatistic stat : t.getStatistics())
    {
        logger.log(Level.FINER,"Adding statistic {0}",stat.getName());
        srch.addAggregation(stat.getContent());
    }
    // Use a search template    
    NivoQuery qry = t.getQuery();
    SearchTemplateRequestBuilder srchTemplate = new SearchTemplateRequestBuilder(client)
            .setRequest(srch.request())
            .setScript(qry.getTemplateString())
            .setScriptType(ScriptType.INLINE)
            .setScriptParams(qry.getParameterValues())
            ;
    logger.log(Level.FINER,"Prepared search: {0}",srchTemplate.request().getRequest().toString());

上一个日志语句的输出是我用来通过curl -XPOST进行POST的http:// localhost:9200 / …

后执行通过

    // Execute the search
    try
    {
        SearchResponse resp = srchTemplate.get().getResponse();
        logger.log(Level.FINER,"Search returned: {0}",resp.toString());
        if (resp.status() == RestStatus.OK && resp.getAggregations() != null)
        {
            for (Aggregation agg : resp.getAggregations().asList())
            {
                // Update response
                t.getResponse().addStat(new NivoStatsHit(agg));
            }
        }
    }
    catch (ElasticsearchException e)
    {
        throw new ApiException(ApiExceptionCode.SEARCH_10061,"Database error: " + e.getDetailedMessage());
    }
最佳答案
我开始用Elasticserach 5.6.3测试你的代码,虽然起初它看起来很可行,但我意识到并不那么容易.所有似乎都归结为搜索模板的使用.

代码的主要内容是您使用的搜索模板与聚合相结合.在我的测试中,也是,甚至大小和工作;-).不知道它对你有什么用.或者您可能没有意识到结果也会让您自己回复文档,因为它与您的帖子无关.您正在记录的查询看起来是正确的,但结果显示聚合,大小和来自被忽略.

所以,在这一点上,我开始研究为什么搜索模板和聚合似乎不起作用(fyi,resp.getAggregations()返回null).我发现了这个 – https://github.com/elastic/elasticsearch/issues/22766.

我尝试将搜索模板构建器与普通搜索请求组合在一起,但我失败了.

原文链接:https://www.f2er.com/java/437480.html

猜你在找的Java相关文章