IT数码 购物 网址 头条 软件 日历 阅读 图书馆
TxT小说阅读器
↓语音阅读,小说下载,古典文学↓
图片批量下载器
↓批量下载图片,美女图库↓
图片自动播放器
↓图片自动播放器↓
一键清除垃圾
↓轻轻一点,清除系统垃圾↓
开发: C++知识库 Java知识库 JavaScript Python PHP知识库 人工智能 区块链 大数据 移动开发 嵌入式 开发工具 数据结构与算法 开发测试 游戏开发 网络协议 系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑 笔记本 显卡 显示器 固态硬盘 硬盘 耳机 手机 iphone vivo oppo 小米 华为 单反 装机 图拉丁
 
   -> 大数据 -> 【ES实战】自定义处理ES的Cat命令结果集示例 -> 正文阅读

[大数据]【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命令也是可以用同样的思路去解析结果集的。

  大数据 最新文章
实现Kafka至少消费一次
亚马逊云科技:还在苦于ETL?Zero ETL的时代
初探MapReduce
【SpringBoot框架篇】32.基于注解+redis实现
Elasticsearch:如何减少 Elasticsearch 集
Go redis操作
Redis面试题
专题五 Redis高并发场景
基于GBase8s和Calcite的多数据源查询
Redis——底层数据结构原理
上一篇文章      下一篇文章      查看所有文章
加:2022-03-15 22:37:16  更:2022-03-15 22:38:13 
 
开发: C++知识库 Java知识库 JavaScript Python PHP知识库 人工智能 区块链 大数据 移动开发 嵌入式 开发工具 数据结构与算法 开发测试 游戏开发 网络协议 系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑 笔记本 显卡 显示器 固态硬盘 硬盘 耳机 手机 iphone vivo oppo 小米 华为 单反 装机 图拉丁

360图书馆 购物 三丰科技 阅读网 日历 万年历 2024年11日历 -2024/11/24 8:33:38-

图片自动播放器
↓图片自动播放器↓
TxT小说阅读器
↓语音阅读,小说下载,古典文学↓
一键清除垃圾
↓轻轻一点,清除系统垃圾↓
图片批量下载器
↓批量下载图片,美女图库↓
  网站联系: qq:121756557 email:121756557@qq.com  IT数码