作者: 京东物流 康睿
1.重建索引需求背景
1.1 集群版本升级
ES版本兼容性
- 同一大版本范围内升级,索引读写兼容
- 不同大版本升级,索引读写不兼容,需要重建索引
1.2 集群迁移
集群索引迁移
- 集群迁移,索引服务不停机,数据提前迁移
1.3 索引分片数量调整
分片数量变更
- 原有分片数量太少,重建变多
- 原有分片数量太多,重建变少
- ES索引分片,一旦创建,原索引是不能修改分片数量的
1.4 索引文档结构变更
文档结构变更
- 字段类型变更,已有索引字段类型是不可以修改的
- 字段属性变更,历史数据的字段属性是不会刷新的
- 文档对象结构变更
2.常用重建索引方式
2.1 Reindex初识
索引重建说明
- 重建是创建新索引,原有索引保留
- 原有索引_source必须开启,否则找不到原始数据
- 索引重建建议,严格业务场景,目标索引mapping结构建议先创建好,不使用es动态推测字段类型的方式。
POST_reindex
{
"source": {
"index": "原始索引"
},
"dest": {
"index": "新目标索引"
}
}
2.2 Url参数解读
URL参数
- refresh,目标索引是否立即刷新
- waif_for_active_shards, 重建索引分片响应设置
- Scroll, 快照查询时间
- slicing, 重建并行任务切片
- Max_docs , 单次最大数据量,条数
- requests_per_second . 单次执行的重建文档数据量
2.3 Request body参数解读
请求参数
- confilicts, 索引数据冲突如何解决,直接覆盖还是中断
- source: 原索引配置信息
- dest,新索引配置信息
- script,脚本处理,修改原索引信息后再写入新索引
2.4 Response 参数解读
响应参数
- 成功数
- 更新数
- 新增数
- 失败数
2.5 重建索引任务管控
任务管控必要性
- 重建索引是一个异步任务,由ES后台进程完成调度执行,集群可能有并行其他异步任务,有时需要中断停止或查看进度
任务管控API
- _tasks,服务端API
3.高级索引重建方式
3.1 单秒数据量阈值控制
单秒数据量控制
- requests_per_second
- 默认1000,设置-1则不限制
- 生产重建时,建议控制范围500-1000左右
- 控制重建速度,防止集群瞬间IO过大
3.2人工切片
数据切片应用
- 人为指定切片数量,并行任务
- 用于降低索引redinx速度
POST_reindex
{
"source": {
"index": "my-index-000001",
"slice": {
"id": 0, // 执行下标,从0开始,即0切第一批数据做迁移,1切第二批数据做迁移
"max": 2 // 切分分片数
}
},
"dest": {
"index": "my-new-index-000001"
}
}
3.3 自动切片
自动切片
- 仅需指定自动切片大小即可,后续的调度由es完成
POST_reindex?slices=5&refresh
{
"source": {
"index": "my-index-000001"
},
"dest": {
"index": "my-new-index-000001"
}
}
3.4 限制reindex重建数据的范围
3.4.1 query
限制查询条件
- 基于DEL语言规则编写,可以任意复杂,限制数据范围
POST_reindex
{
"source": {
"index": "my-index-000001",
"query": {
"term": {
"user.id": "kimchy"
}
}
},
"dest": {
"index": "my-new-index-000001"
}
}
3.4.2 max docs
限制数据条数
- 限制重建数据总条数,默认全部
POST_reindex
{
"max_docs": 1,
"source": {
"index": "my-index-000001"
},
"dest": {
"index": "my-new-index-000001"
}
}
3.5 多索引重建
多索引重建
- ES也支持将多个索引数据合并到一个索引里面去
- 若多个索引数据ID相同,则会相互覆盖
POST_reindex
{
"source": {
"index": ["my-index-000001", "my-index-000002"]
},
"dest": {
"index": "my-new-index-000002"
}
}
3.6 限制重建索引数据字段
限制重建索引数据字段
- source filter
- 原有数据字段过多,需要限制筛选部分进行重建
POST_reindex
{
"source": {
"index": "my-index-000001",
"_source": ["user.id", "_doc"]
},
"dest": {
"index": "my-new-index-000001"
}
}
3.7 字段重命名
字段名重命名
- 原有的数据字段名称不合理,重新按照新字段命名
- 基于脚本机制修改
- ES字段名称原始是不允许修改的,但通过脚本可以操作
3.8 修改原始文档数据
修改原始文档数据
- 基于脚本
4.跨集群索引重建
跨集群操作
- 基于集群通信,类同远程机制
- 需设置跨集群白名单,配置在dist集群
5.索引重建注意事项
5.1 数据量阈值控制
控制好索引重建速率,防止过快
5.2 索引访问交叉影响
建议先新建好dist索引