ES实战自定义处理ES的Cat命令结果集示例

Posted 顧棟

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了ES实战自定义处理ES的Cat命令结果集示例相关的知识,希望对你有一定的参考价值。

处理ES的Cat命令结果集示例

_cat/health为例
一般的返回结果为

health status index                                            uuid                   pri rep docs.count docs.deleted store.size pri.store.size
green  open   .kibana                                          i2DCHBCIQpmNv844IfH86w   1   0          2            0      6.9kb          6.9kb
green  open   .monitoring-alerts-2                             Qd_LW97SQmKJeeuS3tjnvg   1   0          1            0        7kb            7kb
green  open   .monitoring-data-2                               hK915HnWRyuRKkgMiLkCaA   5   1          8            0     31.1kb         15.5kb
green  open   .watches                                         0my1zAAwRNe_G8rsd69WNA   1   0          0            0       160b           160b
green  open   action-20210318                                  LPw2WFbCSsK01OW1s1976w   1   0          0            0       159b           159b
green  open   action-20210319                                  oOUVkHM0SqKKfMTr09Ti8g   1   0          0            0       159b           159b
green  open   action-20210320                                  cUx0TcpiQi2yxrxpEr-hdQ   1   0          0            0       159b           159b

里面包含了10个数据项,第一行为表头,每一项的数据项的长度不固定,分割符可以视为是数量不等的空格符。
采用RESTClient进行操作

   public static void getCustomIndex() throws IOException 

        Response response = client.performRequest("GET", "_cat/indices?v&s=index");
        List<String> indices = new ArrayList<>();
        // 示例代码,默认请求成功。没有对错误信息进行处理
        String all = EntityUtils.toString(response.getEntity(), StandardCharsets.UTF_8);
        BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(new ByteArrayInputStream(all.getBytes(StandardCharsets.UTF_8))));
        String line;
        // 示例只展示前几个索引
        int i = 10;
        // 去掉第一行的表头
        String firstLine = bufferedReader.readLine();
        if (null == firstLine) 
            return;
        
        // 读取每一行索引信息
        while ((null != (line = bufferedReader.readLine())) && i > 0) 
            // 将每个数据项之间不定量的空格变为一个空格,作为分隔符
            line = line.replaceAll("\\\\s+", " ");
            // 为了简单使用的数组
            String[] a = line.split(" ");
            // 一些逻辑处理,比如只留.开头的索引,在实际使用中,可以获取close状态的索引。文档数为0的索引
            if (!a[2].startsWith(".")) 
                indices .add(a[2]);
            
            i--;
        
        indices.forEach(System.out::println);
        

    

对于其他的_cat命令也是可以用同样的思路去解析结果集的。

以上是关于ES实战自定义处理ES的Cat命令结果集示例的主要内容,如果未能解决你的问题,请参考以下文章

ES实战Rally 离线使用实现自定义track压测

ES实战Rally 离线使用实现自定义track压测

ES实战分片无法分配

ES实战索引的路由

Elasticsearch自定义脚本完成性能测试

记一次ES查询结果集失败