采纳答案成功!
向帮助你的同学说点啥吧!感谢那些助人为乐的人
场景:有台原有服务器日志已经被推送到elasticsearch(7.5.0)上,用kibana在Logs位置上可以查看到,现在怎么用java去调用这些日志呢?找好好例子,都没有成功调用到日志
是调用不日志信息
如下测试代码,查询的日志根据不是在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())); }
请问能不让我去猜想你遇到什么问题吗? 我都不知道你的预期是什么……上来就说不成功,只要和预期不一样都叫不成功。 请问你的不成功指的是什么? 你期望的结果是什么?用测试代码出来的结果是什么?依赖版本也没有…… 这么提问臣妾没法给你解决问题啊。
您好,我没有理解你所谓的没有成功到日志是什么意思。
是指调用失败,还是说查询的结果和预期不一样(比如预期有数据,但查询出来是个空)?
如果是调用失败,请提供测试代码,并提供完整的报错。建议花点时间了解下elasticsearch的查询语法。
如果查询出来的结果和预期不同,请花点时间熟悉一下Elasticsearch的查询语法。
登录后可查看更多问答,登录/注册
面向未来微服务:熟练掌握Spring Cloud Alibaba
643 4
2.1k 1
2.8k 2
1.8k 3
3.8k 13
购课补贴联系客服咨询优惠详情
慕课网APP您的移动学习伙伴
扫描二维码关注慕课网微信公众号