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

Question

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

获取_sql？格式=json { "query": "从 eps_stbl_logs 中选择 Count(appId)，其中cast(timestamp AS DATE) = TODAY() 且状态 = 'COMPLETED'" }

这需要用restHighLevelClient java API编写。由于我是使用 Java 进行 ElasticSearch 的新手，您能帮忙编写 java API吗？

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());