请稍等 ...
×

采纳答案成功!

向帮助你的同学说点啥吧!感谢那些助人为乐的人

有关于elasticsearch的问题

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

正在回答 回答被采纳积分+3

插入代码

3回答

提问者 慕仙4096060 2019-12-24 10:11:40

是调用不日志信息

0 回复 有任何疑惑可以回复我~
提问者 慕仙4096060 2019-12-23 19:44:27

如下测试代码,查询的日志根据不是在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()));
    }

0 回复 有任何疑惑可以回复我~
  • 大目 #1
    请问能不让我去猜想你遇到什么问题吗?
    我都不知道你的预期是什么……上来就说不成功,只要和预期不一样都叫不成功。
    请问你的不成功指的是什么?
    你期望的结果是什么?用测试代码出来的结果是什么?依赖版本也没有……
    
    这么提问臣妾没法给你解决问题啊。
    回复 有任何疑惑可以回复我~ 2019-12-23 20:01:11
大目 2019-12-23 19:11:48

您好,我没有理解你所谓的没有成功到日志是什么意思。

是指调用失败,还是说查询的结果和预期不一样(比如预期有数据,但查询出来是个空)?

  1. 如果是调用失败,请提供测试代码,并提供完整的报错。建议花点时间了解下elasticsearch的查询语法。

  2. 如果查询出来的结果和预期不同,请花点时间熟悉一下Elasticsearch的查询语法。

0 回复 有任何疑惑可以回复我~
问题已解决,确定采纳
还有疑问,暂不采纳
微信客服

购课补贴
联系客服咨询优惠详情

帮助反馈 APP下载

慕课网APP
您的移动学习伙伴

公众号

扫描二维码
关注慕课网微信公众号