elasticsearch - 如何使用Java高级REST客户端API编写elasticsearch-sql查询

Question

这是我的Elasticsearch-sql查询。我使用Kibana执行了此查询并获得了有效的输出。

GET _sql？format = json
{
“query”:“从eps_stbl_logs中选择计数(appId)，其中cast(时间戳记为日期)= TODAY()并且状态='已完成'”
}

这需要用restHighLevelClient Java API编写。您可以帮我编写Java API吗，因为我是Java的ElasticSearch的新手。

Answer 1

它可以像这样工作:

        Request request = new Request("GET", "/_sql");
        request.setJsonEntity("{\"query\":\"SELECT Count(appId) FROM eps_stbl_logs where cast(timestamp AS DATE) = TODAY() and status = 'COMPLETED'\"}");
        Response response = restHighLevelClient.getLowLevelClient().performRequest(request);
        String responseBody = EntityUtils.toString(response.getEntity());