如何重现ElasticSearch查询？

Question

我使用ElasticSearch查询，通过Kibana获取数据。我在Java应用程序中也需要相同的请求。Kibana生成的查询如下：

{
  "version": true,
  "size": 500,
  "sort": [
    {
      "@timestamp": {
        "order": "desc",
        "unmapped_type": "boolean"
      }
    }
  ],
  "_source": {
    "excludes": []
  },
  "aggs": {
    "2": {
      "date_histogram": {
        "field": "@timestamp",
        "fixed_interval": "30s",
        "time_zone": "Europe/Berlin",
        "min_doc_count": 1
      }
    }
  },
  "stored_fields": [
    "*"
  ],
  "script_fields": {},
  "docvalue_fields": [
    {
      "field": "@timestamp",
      "format": "date_time"
    }
  ],
  "query": {
    "bool": {
      "must": [
        {
          "query_string": {
            "query": "ORDERID=120019",
            "analyze_wildcard": true,
            "time_zone": "Europe/Berlin"
          }
        }
      ],
      "filter": [
        {
          "match_phrase": {
            "service": {
              "query": "some-service-app"
            }
          }
        },
        {
          "range": {
            "@timestamp": {
              "format": "strict_date_optional_time",
              "gte": "2020-02-24T09:12:41.685Z",
              "lte": "2020-02-24T09:27:41.685Z"
            }
          }
        }
      ],
      "should": [],
      "must_not": []
    }
  },
  "highlight": {
    "pre_tags": [
      "@kibana-highlighted-field@"
    ],
    "post_tags": [
      "@/kibana-highlighted-field@"
    ],
    "fields": {
      "*": {}
    },
    "fragment_size": 2147483647
  }
}

我试图使用ElasticSearch Java API编写相同的查询，但得到的结果完全不同，与预期的输出完全不匹配。

你能帮我想出一个正确的吗？我现在做的方式如下。

    final QueryBuilder query = QueryBuilders.boolQuery()
            .must(QueryBuilders.simpleQueryStringQuery("some-service-app").field("service"))
            .must(QueryBuilders.simpleQueryStringQuery("INFO").field("severity"))
            .must(QueryBuilders.rangeQuery("@timestamp").from(now.minusDays(15)))
            .must(QueryBuilders.simpleQueryStringQuery("ORDERID=120019"));
    final SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
    sourceBuilder.query(query);
    final SearchRequest searchRequest = new SearchRequest(targetIndexName);
    searchRequest.source(sourceBuilder);
    final SearchResponse search = client.search(searchRequest, RequestOptions.DEFAULT);

不幸的是，我的代码返回错误的结果，即使是错误的“服务”值。

你能帮我把Java请求和JSON请求联系起来吗？

Answer 1

1） 比分不会一样。过滤器不计入分数，但在java代码中，您使用的是查询，因此排序会有所不同。

阅读：https://www.elastic.co/guide/en/elasticsearch/reference/current/query-filter-context.html

2） 我想你不想重复基巴纳的提问。例如，我在json中没有找到“严重性”字段，java中缺少聚合部分，您到底在寻找什么？。。。。请分享你的映射

3） 请比较kibana和您的文档时间戳之间的日期时间。有时在时区中，kibana显示不同的时间。

4）正如注释中所说，调试时必须有生成的JSON，这可以帮助你。