起因

一次需求中涉及两个索引，其中一个是本次新建的索引，需要将原始ES索引中的部分数据导入到当前新建的索引中。

分析

对于新所以的数据初始化有两个思路，因为我们的数据都是在HIVE中清洗完成之后再打到ElasticSearch的，所以可以从HIVE中捞取对应的数据重新打到ElasticSearch即可。但是这里有一个局限性的问题，因为HIVE表数量巨大，我们只保留的近7天的清洗结果，如果按照需求的时间跨度则需要重新清洗近3个月的数据，之后再将数据打到ES。

但是这样的话又会有另外一个问题，HIVE表数据在清洗过程中使用到的数据是会经常变动的，比如某个商品最近几天是挂靠在A品类下，但是上个月因为做活动是挂靠在B品类下的，这就导致事后隔了一段时间之后重新清洗的结果无法反应出当时这条数据正确的关联关系的情况。如果产品产品认可当前方案，那么也不失为可行方案之一。

那么，既然我们在原始的索引中有这部分数据，所以自然使用reindex命令来完成这一操作就最为方便了

代码

POST _reindex?wait_for_completion=false&slices=5&refresh
{
  "source": {
    "index": "SOURCE_ES_INDEX",
    "type": "SOURCE_ES_TYPE",
    "query": {
      "range": {
        "last_modify_time": {
          "gte": "2023-01-01 00:00:00",
          "lte": "2023-07-24 23:59:59"
        }
      }
    }
  },
  "dest": {
    "index": "TARGET_ES_INDEX",
    "type": "TARGET_ES_TYPE"
  }
}

简单说下这条语句，公司生产环境使用的ES版本为5.4.2的，所以除了index参数外，还需要有对应的type参数，但是Elasticsearch在 7.X版本中去除了type的概念，所以如果你的ES版本较新的话，可以不用这个type参数，即：

Continue reading