一个简单的无痛和ElasticSearch的reindex API的组合可以用来实现这一点。

POST _reindex
{
  "source": {
    "index": "{old_index_name}",
    "size": {batch_size}
  },
  "dest": {
    "index": "{new_index_name}"
  },
  "script": {
    "lang": "painless",
    "inline": "if (ctx._source.participants.length > 0) {ctx._routing=ctx._source.field1+'-'+ctx._source.field2}"
  }
}

允许创建最新查询

POST _reindex?wait_for_completion=false // async call - you can track query progress if your index is huge - do GET _tasks/{your taskId}
{
  "source": {
    "index": *source index name*
  },
  "dest": {
    "index": *destination index name*
  },
  "script": {
    "source": """
  ctx._routing = ctx._source.field1+'-'+ctx._source.field2;
  """
  }
}