ES reindex脚本流程,下图为整体流程:
步骤(1):每次写入把之前的索引删除再重新创建索引,然后判断索引是否创建成功,由于创建成功返回结果是json,因此用Json Input插件去解析json获得字段,然后用Switch/case插件判断是否成功。
步骤(2):re_index
基础使用命令:
POST _reindex
{
"source": {
"index": "old_index"
},
"dest": {
"index": "new_index"
}
}
步骤三:索引别名
删除旧索引别名,对新索引进行添加别名,即reindex的新索引