广告

扫码关注官方微信

扫码下载APP
返回顶部
首页 > 资讯 > 后端开发 > Python >ElasticSearch学习之Es集群Api操作示例
  • 560

0
分享到

ElasticSearch学习之Es集群Api操作示例

ElasticSearchEs集群Api操作Es集群Api操作 2023-01-31 18:01:39 560人浏览 安东尼

Python 官方文档：入门教程 => 点击学习

摘要

目录前言Es集群api操作_cat获取当前集群主节点信息获取集群当中节点信息获取集群健康信息获取集群索引信息获取集群别名信息_cluster查询集群健康状态查询集群统计信息查询集群状

前言

该系列默认开启Nacos 服务,还不会搭建的小伙伴可以参考往期文章~

上文，我们带大家利用Docker来快速搭建Es集群，如果还不会搭建的小伙伴，可以阅读上文，参考我的部署方式。

本期我们重点围绕es本身来给大家作一些讲解以及实战。虽然市面上已经有一些成熟的ORM框架可以很好的根SpringBoot整合，我们只要调调方法就好了,但是对于我们初学来讲，不是很友好，首先我们得弄清楚它到底是怎么进行操作的。

举个例子，哪天领导跟你讲，现在帮我拉一批数据，半小时之后给我，你难不成回复等我开发完，上完线才能查到?而且这种可能只是一次性的需求，显然是不大行的。这时，如果你可以脱离框架，知道它的一些查询语法，问题不就很快就解决了，也不用你开发再调试。

这里主要想告诉大家，学习新知识的时候，首先要弄清楚知识的本身，学习需要循序渐进，本节主要带大家学习Es集群Api操作，好了, 废话不多说直接开整吧~

Es集群Api操作

在这之前，我们需要做一些准备工作，就是上一节最后的部分，我们运行好es集群服务后,打开kibana的控制台,打开之后，我会带着大家一一操作。

_cat

它的作用是帮助开发者快速查询elasticsearch的相关信息,比如我现在想要直挂的了解es集群的状态。

我们在控制台输入GET _cat，点击运行按钮,它会输出它的全部路由,可以简单的理解为它的所有调用方式

=^.^=
/_cat/allocation
/_cat/shards
/_cat/shards/{index}
/_cat/master
/_cat/nodes
/_cat/tasks
/_cat/indices
/_cat/indices/{index}
/_cat/segments
/_cat/segments/{index}
/_cat/count
/_cat/count/{index}
/_cat/recovery
/_cat/recovery/{index}
/_cat/health
/_cat/pending_tasks
/_cat/aliases
/_cat/aliases/{alias}
/_cat/thread_pool
/_cat/thread_pool/{thread_pools}
/_cat/plugins
/_cat/fielddata
/_cat/fielddata/{fields}
/_cat/nodeattrs
/_cat/repositories
/_cat/snapshots/{repository}
/_cat/templates

获取当前集群主节点信息

语法:

GET /_cat/master

输出:

_1g6ImOFQNqC1OBObqqnvw 172.19.0.3 172.19.0.3 es02

我们可以看到当前的一个主节点是es02,虽然信息是输出了，但是看的好像不大清楚，因为没有标题。下面给大家介绍一个标题小技巧,后边加上?v就可以看到标题了

GET /_cat/master?v

输出:

id                     host       ip         node
_1g6ImOFQNqC1OBObqqnvw 172.19.0.3 172.19.0.3 es02

但是有的情况下，会有大量的标题，而我们只想看到部分信息，怎么办?比如我指向看到ip,这么做就可以了

GET /_cat/master?h=ip

输出:

172.19.0.3

当然，我们也可以连带标题

GET /_cat/master?h=ip&v

输出：

ip
172.19.0.3

当然，我们在不清楚字段意思的时候，也可以寻求帮助

GET /_cat/master?help

id   |   | node id    
host | h | host name  
ip   |   | ip address 
node | n | node name

这种方法也适用其它的_cat查询语句

获取集群当中节点信息

语法:

GET /_cat/nodes?v

输出：

ip         heap.percent ram.percent cpu load_1m load_5m load_15m node.role master name
172.19.0.3           20          73   0    0.02    0.05     0.15 dilm      *      es02
172.19.0.4           30          73   0    0.02    0.05     0.15 dilm      -      es03
172.19.0.2           27          73   0    0.02    0.05     0.15 dilm      -      es01

获取集群健康信息

语法:

GET /_cat/health?v

输出：

epoch      timestamp cluster    status node.total node.data shards pri relo init unassign pending_tasks max_task_wait_time active_shards_percent
1669950213 03:03:33  es-cluster green           3         3      6   3    0    0        0             0                  -                100.0%

重点看一下status，输出了一个green，说明它是健康状态

获取集群索引信息

GET _cat/indices?v

health status index                    uuid                   pri rep docs.count docs.deleted store.size pri.store.size
green  open   .kibana_task_manager_1   Kgl57A8fSDygmcJrnFm1pA   1   1          2            0     61.4kb         41.4kb
green  open   .apm-agent-configuration ozJ-wxmtSaSXhRjBkpYbrQ   1   1          0            0       566b           283b
green  open   .kibana_1                1CywDD-zSxGotJuIfPc_4w   1   1         15            6    146.1kb         66.8kb

可以看到一些默认的索引，以及它们的健康状态，占用的磁盘大小等信息

获取集群别名信息

GET _cat/aliases?v

alias                index                  filter routing.index routing.search is_write_index
.kibana              .kibana_1              -      -             -              -
.kibana_task_manager .kibana_task_manager_1 -      -             -              -

_cluster

用于通过restful的api形式进行集群信息的获取和操作，与_cat类似，但是_cluster是基于JSON形式进行数据返回

查询集群健康状态

GET /_cluster/health

{
  "cluster_name" : "es-cluster",
  "status" : "green",
  "timed_out" : false,
  "number_of_nodes" : 3,
  "number_of_data_nodes" : 3,
  "active_primary_shards" : 3,
  "active_shards" : 6,
  "relocating_shards" : 0,
  "initializing_shards" : 0,
  "unassigned_shards" : 0,
  "delayed_unassigned_shards" : 0,
  "number_of_pending_tasks" : 0,
  "number_of_in_flight_fetch" : 0,
  "task_max_waiting_in_queue_millis" : 0,
  "active_shards_percent_as_number" : 100.0
}

查询集群统计信息

GET /_cluster/stats

会详细列出当前集群总分片树，总主分片数，副分片数，安装的插件等集群所有统计信息,如果不明白分片是啥也没关系，先学会使用，后边会给大家总结它的原理，因为这部分需要一些前置知识,我们先上手操作。

{
  "_nodes" : {
    "total" : 3,
    "successful" : 3,
    "failed" : 0
  },
  "cluster_name" : "es-cluster",
  "cluster_uuid" : "ardUAhdGQvKKJJxei8Hs8A",
  "timestamp" : 1669951414177,
  "status" : "green",
  "indices" : {
    "count" : 3,
    "shards" : {
      "total" : 6,
      "primaries" : 3,
      "replication" : 1.0,
      "index" : {
        "shards" : {
          "min" : 2,
          "max" : 2,
          "avg" : 2.0
        },
        "primaries" : {
          "min" : 1,
          "max" : 1,
          "avg" : 1.0
        },
        "replication" : {
          "min" : 1.0,
          "max" : 1.0,
          "avg" : 1.0
        }
      }
    },
    "docs" : {
      "count" : 22,
      "deleted" : 6
    },
    "store" : {
      "size_in_bytes" : 118135
    },
    "fielddata" : {
      "memory_size_in_bytes" : 1216,
      "evictions" : 0
    },
    "query_cache" : {
      "memory_size_in_bytes" : 0,
      "total_count" : 0,
      "hit_count" : 0,
      "miss_count" : 0,
      "cache_size" : 0,
      "cache_count" : 0,
      "evictions" : 0
    },
    "completion" : {
      "size_in_bytes" : 0
    },
    "segments" : {
      "count" : 11,
      "memory_in_bytes" : 23623,
      "terms_memory_in_bytes" : 16467,
      "stored_fields_memory_in_bytes" : 3432,
      "term_vectors_memory_in_bytes" : 0,
      "norms_memory_in_bytes" : 1152,
      "points_memory_in_bytes" : 0,
      "doc_values_memory_in_bytes" : 2572,
      "index_writer_memory_in_bytes" : 0,
      "version_map_memory_in_bytes" : 0,
      "fixed_bit_set_memory_in_bytes" : 528,
      "max_unsafe_auto_id_timestamp" : -1,
      "file_sizes" : { }
    }
  },
  "nodes" : {
    "count" : {
      "total" : 3,
      "coordinating_only" : 0,
      "data" : 3,
      "ingest" : 3,
      "master" : 3,
      "ml" : 3,
      "voting_only" : 0
    },
    "versions" : [
      "7.6.2"
    ],
    "os" : {
      "available_processors" : 48,
      "allocated_processors" : 48,
      "names" : [
        {
          "name" : "linux",
          "count" : 3
        }
      ],
      "pretty_names" : [
        {
          "pretty_name" : "Centos Linux 7 (Core)",
          "count" : 3
        }
      ],
      "mem" : {
        "total_in_bytes" : 24514228224,
        "free_in_bytes" : 6337855488,
        "used_in_bytes" : 18176372736,
        "free_percent" : 26,
        "used_percent" : 74
      }
    },
    "process" : {
      "cpu" : {
        "percent" : 0
      },
      "open_file_descriptors" : {
        "min" : 444,
        "max" : 458,
        "avg" : 449
      }
    },
    "JVM" : {
      "max_uptime_in_millis" : 2533693,
      "versions" : [
        {
          "version" : "13.0.2",
          "vm_name" : "Openjdk 64-Bit Server VM",
          "vm_version" : "13.0.2+8",
          "vm_vendor" : "AdoptOpenJDK",
          "bundled_jdk" : true,
          "using_bundled_jdk" : true,
          "count" : 3
        }
      ],
      "mem" : {
        "heap_used_in_bytes" : 470693600,
        "heap_max_in_bytes" : 1556938752
      },
      "threads" : 396
    },
    "fs" : {
      "total_in_bytes" : 723860312064,
      "free_in_bytes" : 508481421312,
      "available_in_bytes" : 508481421312
    },
    "plugins" : [ ],
    "network_types" : {
      "transport_types" : {
        "security4" : 3
      },
      "Http_types" : {
        "security4" : 3
      }
    },
    "discovery_types" : {
      "zen" : 3
    },
    "packaging_types" : [
      {
        "flavor" : "default",
        "type" : "docker",
        "count" : 3
      }
    ],
    "ingest" : {
      "number_of_pipelines" : 2,
      "processor_stats" : {
        "gsub" : {
          "count" : 0,
          "failed" : 0,
          "current" : 0,
          "time_in_millis" : 0
        },
        "script" : {
          "count" : 0,
          "failed" : 0,
          "current" : 0,
          "time_in_millis" : 0
        }
      }
    }
  }
}

查询集群状态

GET /_cluster/state

会列出当前集群所有节点信息，以及所有索引的setting和mapping。同样的，json很大，数据也都很详细

结束语

本节主要带大家体验了一下它的api操作,重点带大家学习了集群相关的api，下一节带大家学习索引相关的api,这个部分大家要仔细阅读，因为都是重点，更多关于ElasticSearch Es集群Api操作的资料请关注编程网其它相关文章！

您可能感兴趣的文档:
点击免费下载>>软考高级考试备考技巧/历年真题/备考精华资料

--结束END--

本文标题: ElasticSearch学习之Es集群Api操作示例

本文链接: https://www.lsjlt.com/news/193754.html(转载时请注明来源链接)

有问题或投稿请发送至: 邮箱/279061341@qq.com    QQ/279061341

本篇文章演示代码以及资料文档资料下载

下载Word文档到电脑，方便收藏和打印～

下载Word文档
去做题
猜你喜欢
软考高级职称资格查询
软考职称历年真题下载
软考职称资料下载
热门wiki
近期文章
推荐阅读
热门问答
热门标签
编程网，编程工程师的家园，是目前国内优秀的开源技术社区之一，形成了由开源软件库、代码分享、资讯、协作翻译、讨论区和博客等几大频道内容，为IT开发者提供了一个发现、使用、并交流开源技术的平台。

  • 官方手机版

  • 微信公众号

  • 商务合作