- 1BlueDroid代码分析
- 2在浏览器控制台中输出js对象，为什么颜色不同，有深有浅
- 3女神节快乐！细数历史上那些有名的程序媛
- 4五大自动化测试的 Python 框架_python自动化脚本框架
- 5什么是 Dockerfile？Dockerfile格式、FROM-指定基础镜像、RUN-运行指定的命令、CMD-容器启动时要运行的命令、ENTRYPOINT-为容器指定默认运行程序_dockerfile 格式
- 6ES索引重建reindex详解_es _reindex，2024年最新2024最新阿里大数据开发高级面试题总结_阿里去es重建索引
- 7PyTorch相关笔记(不断补充)_pytorch mps 2.1
- 8【封神台 - 掌控安全靶场】尤里的复仇 Ⅰ 小芳！一二三四五六七章_[iis6up]-->iis token pipeadmin golds7n version [ii
- 9【Linux】网络层、数据链路层、DNS、ICMP协议、NAT技术_网络层和数据链路层的报文
- 10【Hadoop】四、Hadoop生态综合案例 ——陌陌聊天数据分析_基于hadoop和hive的在线社交网络情感分析:使用hadoop和hive分析社交网络数据,以了
Elasticsearch 的索引和分片管理_es索引分片
赞
踩
一、索引管理
1.索引概念：在Elasticsearch中，索引是存储和组织数据的逻辑结构。它类似于关系型数据库中的表，包含多个类型（type），每个类型又包含多个文档（document）。
2.创建索引：
创建索引使用Elasticsearch的REST API，下面是一个创建名为"my_index"的索引的示例代码：
| from elasticsearch import Elasticsearch # 创建Elasticsearch客户端 es = Elasticsearch() # 创建索引请求体 request_body = { "settings": { "number_of_shards": 5, "number_of_replicas": 1 } } # 发送创建索引请求 es.indices.create(index="my_index", body=request_body) |
说明：
- number_of_shards定义了索引被分成多少个分片（默认为5）；
- number_of_replicas定义了每个分片的副本数（默认为1）。
3.删除索引：
删除索引使用Elasticsearch的REST API，下面是一个删除名为"my_index"的索引的示例代码：
# 发送删除索引请求
es.indices.delete(index="my_index")
4.判断索引是否存在：
判断索引是否存在使用Elasticsearch的REST API，下面是一个判断名为"my_index"的索引是否存在的示例代码：
| # 判断索引是否存在 index_exists = es.indices.exists(index="my_index") if index_exists: print("索引存在") else: print("索引不存在") |
二、分片管理
- 分片概念：在Elasticsearch中，索引可以被分成多个分片，并均匀分布在集群中的多个节点上。分片提供了水平扩展性和高可用性。
- 查看索引分片信息：
查看索引分片信息使用Elasticsearch的REST API，下面是一个查看名为"my_index"的索引的分片信息的示例代码：
| # 发送获取索引分片信息的请求 response = es.indices.get(index="my_index") # 解析响应结果 shards_info = response["my_index"]["shards"] for shard_number, shard_info in shards_info.items(): print(f"分片号: {shard_number} 主分片: {shard_info[0]['primaries']} 副本分片: {shard_info[0]['replicas']}") |
3.设置分片个数：
设置分片个数使用Elasticsearch的REST API，下面是一个将名为"my_index"的索引的分片个数设置为10的示例代码：
| # 请求体 request_body = { "settings": { "number_of_shards": 10 } } # 发送修改分片个数的请求 es.indices.put_settings(index="my_index", body=request_body) |
说明：修改分片个数只能在创建索引之前进行，一旦索引创建后，分片个数就不能再修改。
4.设置副本个数：
设置副本个数使用Elasticsearch的REST API，下面是一个将名为"my_index"的索引的副本个数设置为2的示例代码：
| # 请求体 request_body = { "index": { "number_of_replicas": 2 } } # 发送修改副本个数的请求 es.indices.put_settings(index="my_index", body=request_body) |
说明：副本个数可以在索引创建之后进行修改。
5.优化分片分布：
优化分片分布使用Elasticsearch的REST API，下面是一个优化名为"my_index"的索引分片分布的示例代码：
| # 请求体 request_body = { "index": { "number_of_replicas": 0 } } # 发送优化分片分布的请求 es.indices.put_settings(index="my_index", body=request_body) |
说明：通过将副本个数设置为0，可以使得索引上的所有副本分片都被分配给不同的节点，实现分片的最佳分布。
三、总结
通过索引和分片的管理，我们可以在Elasticsearch中创建、删除和判断索引的存在性。同时也可以设置索引的分片个数和副本个数，以及优化分片的分布。这些操作可以帮助我们灵活地管理和优化Elasticsearch集群的性能和可用性。
