Elasticsearch Java API boolQuery

Question

Я использую эластичный поиск версии 6.4.2

Мне удалось создать запрос GET с использованием REST API, теперь я хотел бы выполнить тот же запрос с использованием API JAVA.

Это запрос:

GET _search
{
   "query":{
      "bool":{
         "must":{
            "match":{
               "tags":"kpi"
            }
         },
         "filter":{
            "range":{
               "@timestamp":{
                  "gt":"now-5m"
               }
            }
         }
      }
   }
}

Я прочитал эту документацию: https://www.elastic.co/guide/en/elasticsearch/client/java-api/current/java-compound-queries.html, но мне все еще не ясно, ищу ли я это и как его использовать. Учтите, что запрос может вернуть много результатов, которые должны быть обработаны моим Java-приложением.

Кроме того, поскольку мне приходится выполнять этот запрос каждые 5 минут, как я могу его оптимизировать (если это возможно)?

Answer 1

Это точный код, который работает:

Date dateFrom = new Date(System.currentTimeMillis() - 300 * 1000);
Date dateTo = new Date(System.currentTimeMillis());

BoolQueryBuilder query = QueryBuilders.boolQuery()
    .must(QueryBuilders.rangeQuery("@timestamp").from(dateFrom).to(dateTo))
    .must(QueryBuilders.matchQuery("tags", "kpi"));

SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
searchSourceBuilder.query(query);
SearchRequest searchRequest = new SearchRequest();
searchRequest.source(searchSourceBuilder);
System.out.println(query.toString());
SearchResponse searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);

logger.log(Level.INFO, "Status: {0}", new Object[] { searchResponse.status() });
logger.log(Level.INFO, "Took: {0}", new Object[] { searchResponse.getTook() });
logger.log(Level.INFO, "IsTerminatedEarly: {0}", new Object[] { searchResponse.isTerminatedEarly() });
logger.log(Level.INFO, "TimedOut: {0}", new Object[] { searchResponse.isTimedOut() });
logger.log(Level.INFO, "TotalShards: {0}", new Object[] { searchResponse.getTotalShards() });
logger.log(Level.INFO, "SuccessfulShards: {0}", new Object[] { searchResponse.getSuccessfulShards() });
logger.log(Level.INFO, "FailedShards: {0}", new Object[] { searchResponse.getFailedShards() });
logger.log(Level.INFO, "Total Hits: {0}", new Object[] { searchResponse.getHits().getTotalHits() });

Answer 2

Если ваш проект основан на maven, вы можете использовать клиентскую зависимостьasticsearch:

<dependency>
    <groupId>org.elasticsearch.client</groupId>
    <artifactId>transport</artifactId>
    <version>5.6.2</version>
</dependency>

Ваш необходимый запрос будет:

val query = QueryBuilders.boolQuery()
    .must(
        QueryBuilders.rangeQuery("timestamp").from(startDate)
    )
    .must(
        QueryBuilders.termQuery("tags", "kpi")
    )

и, наконец, для выполнения вашего запроса вы можете использовать client.search(query). client - это RestHighLevelClient тип.