有关于elasticsearch的问题

来源：8-14 SentinelResource注解详解

慕仙4096060

2019-12-23

场景:有台原有服务器日志已经被推送到elasticsearch(7.5.0)上，用kibana在Logs位置上可以查看到，现在怎么用java去调用这些日志呢？找好好例子，都没有成功调用到日志

写回答

3回答

慕仙4096060

提问者

2019-12-24

是调用不日志信息

慕仙4096060

提问者

2019-12-23

如下测试代码，查询的日志根据不是在kibana的Logs中看的日志信息
/**
     * 单例模式获取连接ES客户端
     *
     * @return restClient
     */

    public static void getRestClient() {
        final CredentialsProvider credentialsProvider = new BasicCredentialsProvider();
        credentialsProvider.setCredentials(AuthScope.ANY,
                new UsernamePasswordCredentials("elastic", "my-application"));

restClient = RestClient.builder(new HttpHost("121.196.193.171", 9200, "http"))

                .setHttpClientConfigCallback(new RestClientBuilder.HttpClientConfigCallback() {
                    @Override
                    public HttpAsyncClientBuilder customizeHttpClient(HttpAsyncClientBuilder httpClientBuilder) {
                        return httpClientBuilder.setDefaultCredentialsProvider(credentialsProvider);
                    }

                }).build();
    }

    @Test
    public void CatApi() throws Exception {
        getRestClient();
        String method = "GET";
        String endpoint = "/_search";
        Response response = restClient.performRequest(method, endpoint);
        System.out.println(EntityUtils.toString(response.getEntity()));
    }