devbox
寸_铁
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

ES常用操作命令_es命令

作者：寸_铁 | 2024-07-14 18:19:32

赞

踩

es命令

1集群操作命令

集群运行状态：用于通过附加'health'关键字来获取集群运行状况的状态。

GET /_cluster/health

集群状态：通过附加'state'关键字URL来获取有关集群的状态信息。状态信息包含版本，主节点，其他节点，路由表，元数据和块。

GET /_cluster/state

集群统计：通过使用'stats'关键字来帮助检索有关群集的统计信息。返回分片号，存储大小，内存使用率，节点数，角色，操作系统和文件系统。

GET /_cluster/stats

节点统计：用于检索集群中另外一个节点的统计信息。节点统计信息与集群几乎相同。

GET /_nodes/stats

节点热线程：检索有关群集中每个节点上的当前热线程的信息。

GET /_nodes/hot_threads

2.索引操作命令

创建索引：当用户将JSON对象传递给任何索引时，可以自动创建索引，也可以在此之前创建索引。要创建索引，需要发送带有设置，映射和别名的PUT请求，或者仅发送不带正文的简单请求。

  1. PUT index_name
  2. {
  3.   "settings" : {
  4.       "index" : {
  5.          "number_of_shards" : 3,  //分片数
  6.          "number_of_replicas" : 2  //副本数
  7.       }
  8.    }
  9. }

删除索引：需要传递带有该特定索引名称的删除请求即可。_all或*可删除所有索引。

DELETE /index_name

获取索引：返回索引相关的信息

GET index_name

索引设置：在请求末尾附加_settings关键字即可获取索引设置。

GET /index_name/_settings

索引统计：提取有关特定索引的统计信息。

GET /index_name/_stats

冲洗（flush）：索引的刷新过程可确保当前仅保留在事务日志中的所有数据也将永久保留在Lucene中。这减少了恢复时间，因为在打开Lucene索引之后，不需要从事务日志中重新索引数据。

GET/index_name/_flush

3文档操作命令

  1. 创建文档：PUT index_name/_doc/5
  2.  
  3. 查询文档：GET index_name/_doc/5
  4.  
  5. 修改文档：POST index_name/_update/5
  6.  
  7. 删除文档：DELETE index_name/_doc/5

4查询操作命令

匹配所有查询：这是最基本的查询；它返回所有内容。

  1. POST /index_name/_search
  2. {
  3.    "query":{
  4.       "match_all":{}
  5.    }
  6. }

匹配查询：此查询将文本或短语与一个或多个字段的值匹配。

  1. POST /index_name*/_search
  2. {
  3.    "query":{
  4.       "match" : {
  5.          "rating":"4.5"
  6.       }
  7.    }
  8. }

多重对比查询：此查询将一个或多个字段匹配的文本或短语匹配。

  1. POST / index_name */_search
  2. {
  3.    "query":{
  4.       "multi_match" : {
  5.          "query": "paprola",
  6.          "fields": [ "city", "state" ]
  7.       }
  8.    }
  9. }

字符串查询：该查询使用查询解析器和query_string关键字。

  1. POST /index_name*/_search
  2. {
  3.    "query":{
  4.       "query_string":{
  5.          "query":"beautiful"
  6.       }
  7.    }
  8. }

词级查询（精确值查询）：主要处理结构化数据，例如数字，日期和枚举。（terms多值查找）

  1. POST /index_name*/_search
  2. {
  3.    "query":{
  4.       "term":{"zip":"176115"}
  5.    }
  6. }

范围查询：该查询用于查找具有给定值范围之间的值的对象。为此，我们需要使用运算符，

gte −大于等于

gt −大于

lte −小于等于

lt −小于

例如：查询rating字段数值大于等于3.5的结果

  1. POST /index_name*/_search
  2. {
  3.    "query":{
  4.       "range":{
  5.          "rating":{
  6.             "gte":3.5
  7.          }
  8.       }
  9.    }
  10. }

复合查询：这些查询是不同查询的集合，这些查询通过使用布尔运算符（例如和/或，或不）或针对不同的索引或具有函数调用等彼此合并。

  1. POST /index_name/_search
  2. {
  3.    "query": {
  4.       "bool" : {
  5.          "must" : {
  6.             "term" : { "state" : "UP" }
  7.          },
  8.          "filter": {
  9.             "term" : { "fees" : "2200" }
  10.          },
  11.          "minimum_should_match" : 1,
  12.          "boost" : 1.0
  13.       }
  14.    }
  15. }

地理查询：查询处理地理位置。这些查询有助于找出学校或任何其他地理位置附近的地理对象。需要使用地理位置数据类型。

  1. PUT /geo_example
  2. {
  3.    "mappings": {
  4.       "properties": {
  5.          "location": {
  6.             "type": "geo_shape"
  7.          }
  8.       }
  9.    }
  10. }

布尔过滤器：

  1. {
  2.    "bool" : {
  3.       "must" :     [ ],
  4.       "should" :   [ ],
  5.       "must_not" : [ ],
  6.       "filter":    [ ]
  7.    }
  8. }

must ——所有的语句都 必须（must）匹配，与 AND 等价。

must_not ——所有的语句都不能（must not）匹配，与 NOT 等价。

should ——至少有一个语句要匹配，与 OR 等价。

filter——必须匹配，运行在非评分&过滤模式。

当我们需要多个过滤器时，只须将它们置入 bool 过滤器的不同部分即可。

查询某个字段是否存在：

  1. GET /my_index/posts/_search
  2. {
  3.     "query" : {
  4.         "constant_score" : {
  5.             "filter" : {
  6.                 "exists" : { "field" : "tags" }
  7.             }
  8.         }
  9.     }
  10. }

前缀检索：匹配包含的前缀字符

  1. GET /_search
  2. { "query": {
  3.   "prefix" : { "user" : "ki" }
  4.   }
  5. }

通配符检索：匹配具有匹配通配符表达式（ (not analyzed ）的字段的文档。 支持的通配符：

1）*，它匹配任何字符序列（包括空字符序列）；

2）？，它匹配任何单个字符。

为了防止非常慢的通配符查询，通配符不能以任何一个通配符*或？开头。

  1. GET /_search
  2. {
  3.     "query": {
  4.         "wildcard" : { "user" : "ki*y" }
  5.     }
  6. }

正则表达式检索：正则表达式查询允许使用正则表达式术语查询。*查询比较慢，通常需要使用一个长的前缀。

  1. GET /_search
  2. {
  3.   "query": {
  4.       "regexp":{
  5.           "name.first": "s.*y"
  6.           }
  7.       }
  8. }

模糊检索：模糊查询查找在模糊度中指定的最大编辑距离内的所有可能的匹配项，然后检查术语字典，以找出在索引中实际存在待检索的关键词。

  1. GET /_search
  2. {
  3.   "query": {
  4.       "fuzzy" : { "user" : "ki" }
  5.   }

类型检索：检索索引中，type为指定类型的全部信息。

  1. GET /my_index/_search
  2. {
  3.   "query": {
  4.       "type" : {
  5.           "value" : "xext"
  6.           }
  7.       }
  8. }

IDs检索：返回指定id的全部信息。

  1. GET /my_index/_search
  2. {
  3.   "query": {
  4.       "ids" : {
  5.           "type" : "text",
  6.               "values" : ["2", "4", "100"]
  7.           }
  8.       }
  9. }

排序查询：

  1. get /index_good/_search
  2. {
  3.     "query":{
  4.         "term":{
  5.             "title":"oppo手机"  //只有title=“oppo手机”的文档数据才会被查询到
  6.         }
  7.     },
  8.     "sort":[      // 查询结果根据【order by price desc,name asc】进行排序
  9.         {"price":{"order":"desc"}},
  10.         {"name":{"name":"asc"}}
  11.     ]
  12. }

分页查询：

  1. get /index_good/_search
  2. {
  3.     "query":{
  4.         "term":{
  5.             "title":"oppo手机"    // 只有title=“oppo手机”的文档数据才会被查询到
  6.         }
  7.     },
  8.     "sort":[      //查询结果根据【order by price desc,name asc】进行排序
  9.         {"price":{"order":"desc"}},
  10.         {"name":{"name":"asc"}}
  11.     ],
  12.     "from":5,         //从第5条数据开始取10条（es中的数据从第0条开始）
  13.     "size":10
  14. }

Mget批量查询：进行查询的时候，如果一次性查询多条数据的话，采用批量操作的api，尽可能减少网络开销次数，可以将性能大幅度提升。

  1. GET _mget
  2. {
  3.     "docs": [
  4.         {
  5.             "_index": "example",
  6.             "_type": "docs",
  7.             "_id": "1"
  8.         }
  9.         {
  10.             "_index": "example_test",
  11.             "_type": "docs",
  12.             "_id": "1"
  13.         },
  14.     ]
  15. }

bulk批量操作：es提供的一种批量增删改的操作。

create：如果文档不存在就创建，但如果文档存在就返回错误

index：如果文档不存在就创建，如果文档存在就更新

update：更新一个文档，如果文档不存在就返回错误

delete：删除一个文档，如果要删除的文档id不存在，就返回错误

索引及映射结构准备:

PUT example

  1. PUT example/docs/_mapping
  2. {
  3.   "properties": {
  4.     "id": {"type": "long"},
  5.     "name": {"type": "text"},
  6.     "counter": {"type": "integer"},
  7.     "tags": {"type": "text"}
  8.   }
  9. }

批量插入：

  1. POST example/docs/_bulk
  2.  
  3. {"index": {"_id": 1}}
  4. {"id":1, "name": "admin", "counter":"10", "tags":["red", "black"]}
  5.  
  6. {"index": {"_id": 2}}
  7. {"id":2, "name": "张三", "counter":"20", "tags":["green", "purple"]}
  8.  
  9. {"index": {"_id": 3}}
  10. {"id":3, "name": "李四", "counter":"30", "tags":["red", "blue"]}
  11.  
  12. {"index": {"_id": 4}}
  13. {"id":4, "name": "tom", "counter":"40", "tags":["orange"]}

批量更新：

  1. POST example/docs/_bulk
  2.  
  3. {"update": {"_id": 1}}
  4. {"doc": {"id":1, "name": "admin-02", "counter":"11"}}
  5.  
  6. {"update": {"_id": 2}}
  7. {"script":{"lang":"painless","source":"ctx._source.counter += params.num","params": {"num":2}}}
  8.  
  9. {"update":{"_id": 3}}
  10. {"doc": {"name": "test3333name", "counter": 999}}
  11.  
  12. {"update":{"_id": 4}}
  13. {"doc": {"name": "test444name", "counter": 888},  "doc_as_upsert" : true}

批量删除：

  1. POST example/docs/_bulk
  2.  
  3. {"delete": {"_id": 1}}
  4. {"delete": {"_id": 2}}
  5. {"delete": {"_id": 3}}
  6. {"delete": {"_id": 4}}

混合操作：

  1. POST _bulk
  2.  
  3. { "index" : { "_index" : "example", "_type" : "docs", "_id" : "1" } }
  4. { "name" : "value11111" }
  5. { "delete" : { "_index" : "example", "_type" : "docs", "_id" : "2" } }
  6. { "create" : { "_index" : "example", "_type" : "docs", "_id" : "3" } }
  7. { "tags" : "value333" }
  8. { "update" : {"_id" : "4", "_type" : "docs", "_index" : "example"} }
  9. { "doc" : {"name" : "混合444"}

msearch批量查询：批量查询多个索引中的多个条件（减少IO次数）。

  1. POST _msearch
  2.  
  3. {"index":"movies"
  4. {"query":{"match_all":{}},"from":0,"size":3}
  5. {"index":"users"}
  6. {"query":{"match_phrase":{"name.keyword":"nie"}}}
  7. {"index":"books"}
  8. {"query":{"match":{"bookName":"中国通史"}}}

query：查询上下文，会有一个相关性匹配度的分数。

fiter：过滤查询，必须满足的条件，没有匹配度分数。只回答是或不是，查询效率更高。

查询和过滤条件的合并：search API中只能包含 query 语句，所以我们需要用 filtered 来同时包含 "query" 和 "filter" 子句：

  1. GET /_search
  2. {
  3.     "query": {
  4.         "filtered": {
  5.             "query":  { "match": { "email": "business opportunity" }},
  6.             "filter": { "term": { "folder": "inbox" }}
  7.         }
  8.     }
  9. }

常用API
1、curl -sXGET  "http://localhost:9200?pretty"       查看ES版本信息
2、curl -sXGET  "http://localhost:9200/_cluster/health?pretty"    检查集群状况
3、curl -sXGET "http://localhost:9200/_cat/indices?v"    查看集群内的所有索引
4、curl -sXGET "http://localhost:9200/_cat/indices/skyeye-tcpflow-2020.05.25?v"   查看指定索引，注：skyeye-tcpflow-2020.05.25为要查看的索引名
5、curl -sXGET "http://localhost:9200/_cat/nodes?v" |sort -k9   查看集群中的所有节点信息，当集群内节点较多时（有些业务100多个节点）使用sort进行排序，查看哪些节点不在集群内
6、curl -sXGET "http://localhost:9200/_cat/master?v"   查看master节点信息，当需要查看master节点日志时，需要先确定master是哪个节点
7、curl -sXGET "http://localhost:9200/_cat/allocation?v"  查看集群内分片的部分情况，查看分片分布是否均衡
8、curl -sXGET "http://localhost:9200/_cat/thread_pool/bulk,search?v"   查看集群bulk(入库)和search(查询)线程池的情况，当查询卡慢时可以查看
9、curl -sXGET "http://localhost:9200/_cat/pending_tasks?v"   查看集群内的排队的任务有哪些
10、curl -sXGET "http://localhost:9200/_cat/tasks?v"      查看集群内当前执行的任务有哪些
11、curl -sXGET "http://localhost:9200/_cat/nodes?h=name,segments.memory&v"   查看集群内segments的占用内存的情况
12、curl -sXGET "http://localhost:9200/_cluster/allocation/explain?pretty"    当执行_clster/health发现集群内有不能分片的分片(unassigned_shards>0)时，执行该命令，该命令返回很长，可以输出到一个文件中，传给二线查看分析原因
13、curl -sXGET "http://localhost:9200/_cluster/settings?pretty"              查看集群的设置，比如：磁盘平衡，分片平衡等设置
14、curl -sXGET "http://localhost:9200/skyeye-tcpflow-2020.05.25/_settings?pretty"   查看某个索引的设置，比如：索引的total_shards_per_node,number_of_replicas等设置，注：skyeye-tcpflow-2020.05.25为要查看的索引名，需更换实际需要查看的对应索引名
15、curl -XPOST "http://localhost:9200/*2020.03*/_close"          关闭索引，批量关闭2020年3月的索引，也可以只关闭指定的某一个索引，写上对应的索引名即可，注：关闭索引并不是删除索引，一线人员可以操作
16、curl -XPOST "http://localhost:9200/*2020.03*/_open"           打开索引，批量打开2020年3月的索引，也可以只打开指定的某一个索引，写上对应的索引名即可，
    通常索引关闭再打开，叫reopen,一般使用循环的方式将一批yellow的索引进行reopen操作如：
    curl -sXGET "http://localhost:9200/_cat/indices" | grep -w yellow | awk '{print $3}'|while read line;do curl -XPOST "http://localhost:9200/$line/_close";curl -XPOST "http://localhost:9200/$line/_open";done
17、curl -XDELETE "http://localhost:9200/$index"   删除指定的索引，注：删除操作直接会将磁盘中的数据删除，一定确认之后没有问题再执行
18、curl -XPUT "http://localhost:9200/$index"      创建索引，注：$index为要创建的索引名称，
19、curl -sXGET "http://localhost:9200/_nodes/hot_threads?pretty" | less     该api返回当前集群线程在处理什么任务。在进行问题定位的时候会用到。只要了解即可，不需要去分析输出的内容，
20、curl -sXGET "http://localhost:9200/_nodes?pretty" | grep logs            查看集群配置的日志和数据的存放路径
21、curl -sXGET localhost:9200/_cat/recovery?ignore_unavailable=true | grep -v done 查看集群分片恢复情况
22、curl -sXGET "http://localhost:9200/_cat/nodes?h=name,port,segments.memory,segments.index_writer_memory,fielddata.memory_size,query_cache.memory_size,request_cache.memory_size&v" 节点内存占用情况
23、ES别名
    curl  -sXGET localhost:9200/_cat/aliases?v  查看别名
    curl -XPOST 'http://localhost:9200/_aliases'-d '{"actions" : [{ "add" : { "index" : "test1","alias" : "alias1" } }]}' 添加别名
    curl -XPOST 'http://localhost:9200/_aliases'-d '{"actions" : [{ "remove" : { "index" : "test1","alias" : "alias1" } }]}' 移除别名
24、merge
    curl -sXPOST "$http://localhost:9200/$index/_forcemerge?max_num_segments=$segment_count
25、缓存清理
    curl -sXPOST localhost:9200/_cache/clear?pretty
26、禁止计算迁移分片空间
    curl -sXPUT localhost:9200/_cluster/settings?master_timeout=10m -d '{"transient":{"cluster.routing.allocation.disk.include_relocations":"false"}}
27、设置最小master数
    curl -XPUT "http://localhost:9200/_cluster/settings" -d '{"persistent" : {"discovery.zen.minimum_master_nodes" : 2}}'
27、查询分片数调整
    curl -u es:es -XPUT 'http://localhost:9200/_cluster/settings' -H 'Content-Type: application/json' -d' { "persistent" : {"action.search.shard_count.limit" : "2000"}

ES动态参数修改
1、curl -sXPUT "http://localhost:9200/*2018.06.13*/_settings" -d '{"index.routing.allocation.total_shards_per_node":2}'           修改指定索引的total_shards_per_node，如果想修改集群内所有索引，可以将索引名称用_all参数替换
2、curl -sXPUT "http://localhost:9200/*2017.09.19/_settings" -d '{"index.refresh_interval":"120s"}'                               修改索引的refresh时间
3、curl -XPUT "http://localhost:9200/$index/_settings" -d '{"settings":{"index.unassigned.node_left.delayed_timeout":"120h"}}'    修改由于节点下线，重新分片的时机。
4、#修改每个节点并发recovery的副本数量，如果机器资源充足，修改较大的值有利于提高集群恢复的进度。recovery主要受限于网络带宽。
curl -sXPUT "http://localhost:9200/_cluster/settings" -d '{"transient":{"cluster.routing.allocation.node_concurrent_recoveries":"40"}}' 副本恢复并发数
curl -sXPUT "http://localhost:9200/_cluster/settings" -d '{"transient":{"cluster.routing.allocation.node_initial_primaries_recoveries":"20"}}' 主分片恢复并发数
5、#禁用启用集群的查询服务。在某些时候，由于大量的查询占用了很多资源，导致集群恢复严重缓慢，禁用查询可以提高恢复速速。警告：禁用后所有查询无法完成，需要在相关人认可的情况下执行该操作。
curl -sXPUT "http://localhost:9200/_cluster/settings" -d '{"transient":{"cluster.search.enabled":"false"}}'
curl -sXPUT "http://localhost:9200/_cluster/settings" -d '{"transient":{"cluster.search.enabled":"true"}}'
6、#禁止分片划分到某个节点或者某个机器，出现磁盘故障或者下线机器时会用到，执行后，分片会从对应的节点和机器移走，根据数据量大小，可能需要一定的时间才能移完
curl -sXPUT "http://localhost:9200/_cluster/settings" -d '{"persistent":{"cluster.routing.allocation.exclude._name":"es.10.208.41.16.7"}}'
curl -sXPUT "http://localhost:9200/_cluster/settings" -d '{"persistent":{"cluster.routing.allocation.exclude._ip":"10.203.159.107"}}'
7、curl -sXPUT "http://localhost:9200/*2018.06.13*/_settings" -d '{"index.number_of_replicas":0}'    修改索引的副本数量
8、curl  -sXPUT "localhost:9200/_cluster/settings" -d '{"transient":{"cluster.routing.allocation.awareness.attributes": null}}' 允许多个分片能够分配在同一机器上
9、curl -XPUT 'http://localhost:9200/_cluster/settings' -d '{"transient":{"logger.org.elasticsearch.index.engine": "TRACE"}}' 设置日志级别
10、curl -sXPUT localhost:9200/_cluster/settings?master_timeout=10m -d ' { "persistent": { "action.destructive_requires_name": "false" }}' 通配符使用
11、curl  -sXPUT http://localhost:9200/_cluster/settings -d' {"persistent" :{ "indices.recovery.max_bytes_per_sec" :"30mb" }}' 设置分片迁移速度
12、索引只读
 curl -sXPUT localhost:9200/noah_aaa_20210109/_settings?pretty -d'{"index.blocks.read_only":false}'
 curl -sXPUT localhost:9200/noah_aaa_20210109/_settings?pretty -d'{"index.blocks.read_only_allow_delete":null}'
13、规定分片划分到某个节点或者机器
    curl -sXPUT "http://$host/$index/_settings" -H "Content-Type: application/json" -d '{"settings":{"index.routing.allocation.require._name":"'$node_name'"}
    curl -sXPUT "http://$host/$index/_settings" -H "Content-Type: application/json" -d '{"settings":{"index.routing.allocation.require._ip":"'$node_ip'"}
13、分片均衡
    curl   -sXPUT "http://localhost:9200/_cluster/settings" -d '{"transient":{"cluster.routing.allocation.balance.disk.enabled":"false"}}'
    curl   -sXPUT "http://localhost:9200/_cluster/settings" -d '{"transient":{"cluster.routing.rebalance.enable":"none"}}'
14、均衡迁移的分片数
    curl -sXPUT "http://localhost:9200/_cluster/settings" -d '{"transient":{"cluster.routing.allocation.cluster_concurrent_rebalance":"20"}}'

查找索引：
curl -X GET "localhost:9200/_cat/indices?v&h=index,store.size" |grep tool

查找模板：
curl -sXGET localhost:9200/_cat/templates?v | grep index
curl -XDELETE localhost:9200/_template/index_name
sh /opt/work/search/es/bin/index.sh template.update
sh /opt/work/search/es/bin/index.sh -i skyeye-dns-2023.11.28 create

常用命令
1、删除僵尸索引
grep "can not be imported as a dangling index" /data*/es/logs/es*/es.log | sed 's/.*

\[\(.∗\)\/\(.∗\)
\].*/\2/g' | sort | uniq |while read line; do echo $lind; find /data*/es/nodes/0/indices -name ${line} | xargs rm -rf; done >/dev/null 2>&1 &
2、task管理
    curl -sXGET "localhost:9200/_tasks?actions=*search&detailed&pretty"
    curl -sXPOST "localhost:9200/_tasks/_cancel?nodes=nodeId&actions=*reindex"
3、分配过期分片
    curl -XPOST 'localhost:9200/_cluster/reroute?pretty' -H 'Content-Type: application/json' -d'
{
  "commands": [
    {
      "allocate_stale_primary": {
        "index": "index_name-2017.12.21",
        "shard": 1,
        "node": "es.$ip.3",
        "accept_data_loss": true
      }
    }
  ]
}
'
4、分空分片
curl -XPOST 'localhost:9200/_cluster/reroute?pretty' -H 'Content-Type: application/json' -d'
{
  "commands": [
    {
      "allocate_empty_primary": {
        "index": "index_name-2017.12.21",
        "shard": 1,
        "node": "es.$ip.3",
        "accept_data_loss": true
      }
    }
  ]
}
'
批量分空
curl  -u es_admin:%36.Hadoop*  -sXGET localhost:9200/_cat/shards/ | grep UNASSIGNED | grep -w p | while read line;do id=$(($RANDOM%1));index=`echo $line | awk '{print$1}'`;shard=`echo $line | awk '{print$2}'`; curl -u es_admin:%36.Hadoop* -XPOST 'localhost:9200/_cluster/reroute?pretty' -H 'Content-Type: application/json' -d'{"commands": [{ "allocate_empty_primary": {"index": "'$index'","shard":"'$shard'","node":"es.机器名称或ip.'$id'","accept_data_loss":true}}]}'; done > /dev/null 2>&1 &
5、translog 文件损坏修复
 bin/elasticsearch-translog truncate -d /data$i/es/nodes/0/indices/$index_dir/$shard_number/translog/

查看每个索引是否均衡：
curl -sXGET -ues_admin:%36.Hadoop* "http://localhost:9200/_cat/indices/*2022.08.28?h=index,ip" | sort | uniq | awk '{print $1}' | while read line;do echo $line;curl -sXGET -ues_admin:%36.Hadoop*  "http://localhost:9200/_cat/shards/*2022.08.28?h=index,ip" | grep $line | awk '{print $2}' |sort |uniq -c;done
设置当天索引保证磁盘平衡 （105为节点总数）：
curl -sXGET   -ues_admin:%36.Hadoop*  "http://localhost:9200/_cat/indices/*2022.08.28" | while read line;do index=`echo $line | awk '{print $3}'`;shard_num=`curl     -sXGET  -ues_admin:%36.Hadoop*  "http://localhost:9200/_cat/shards/$index" | wc -l`;total_shards_per_node=$(($shard_num / 105));total_shards_per_node=$(($total_shards_per_node + 1));curl -sXPUT  -ues_admin:%36.Hadoop*  "http://localhost:9200/$index/_settings" -d     '{"index.routing.allocation.total_shards_per_node":'$total_shards_per_node'}';done

查看集群write、search线程池状态
curl -ues_admin:%36.Hadoop* -sXGET "http://localhost:9200/_cat/thread_pool/?v&h=id,name,active,rejected,queue,size,type&pretty&s=type"

查看red索引：curl -sXGET localhost:9200/_cat/indices?health=red
开启行为分析索引：脚本
关闭：curl -sXGET localhost:9200/_cat/indices?health=red | awk '{print $3}' | while read index; do echo $index; curl -sXPOST localhost:9200/$index/_close; done
删除：curl -sXGET localhost:9200/_cat/indices?health=red | awk '{print $3}' | while read index; do echo $index; curl -sXDELETE localhost:9200/$index; done
重建：cd /opt/work/search/es/template/skyeye/;for index in `ll *.tmpl | awk '{print $9}' | cut -d '.' -f1`; do echo $index; sh /data/index.sh -i $index create; done

统计每个索引分片平均大小：
curl -ues_admin:%36.Hadoop* -sXGET "http://localhost:9200/_cat/indices/*2022.08.28?h=index,pri,pri.store.size&bytes=gb" | while read line;do size=`echo $line | awk '{print $3}'`;p=`echo $line | awk '{print $2}'`;index=`echo $line | awk '{print $1}'`;echo "$index $(($size/$p))";done | sort -nk2 | column –t
统计索引前三天的数据索引大小:
curl -ues_admin:%36.Hadoop* -sXGET localhost:9200/_cat/indices/index_name-2023.08.09,index_name-2023.08.08,index_name-2023.08.07

2 ES常用命令
1.    curl –sXGET localhost:9200/_cluster/health?pretty
2.    curl –sXGET localhost:9200/_cat/shards?v
3.    curl –sXGET localhost:9200/_cat/nodes?v
4.    curl –sXGET localhost:9200/_nodes/stats?pretty
5.    curl –sXGET localhost:9200/_cluster/stats?pretty
6.    curl –sXGET localhost:9200/_cat/allocations?v
7.    curl –sXGET localhost:9200/_cat/pending_tasks?v
8.    curl –sXGET localhost:9200/_cat/master?v
9.    curl –sXGET localhost:9200/_cat/recovery?v
10.查看线程池    curl –sXGET localhost:9200/_cat/thread_pool?v
11.    curl –sXGET localhost:9200/_cat/segments?v
12.    curl –XPOST localhost:9200/skyeye-dns-2023.06.07/_close?pretty
13.    curl –XPOST localhost:9200/skyeye-dns-2023.06.07/_open?pretty
14.    curl –XDELETE localhost:9200/skyeye-dns-2023.06.07?pretty

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/寸_铁/article/detail/825936
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号