elasticsearch 多个reindex同时执行

在 Elasticsearch 中，可以使用 `_reindex` API 来执行索引数据的重建操作。如果需要同时执行多个 `_reindex` 操作，可以考虑使用多线程或多进程的方式来实现。

其中，多线程的方式可以使用 Python 的 `concurrent.futures` 模块来实现。具体的实现方式可以参考以下代码：

import concurrent.futures
from elasticsearch import Elasticsearch

es = Elasticsearch()

def reindex(index):
    target_index = f"{index}-new"
    body = {
        "source": {"index": index},
        "dest": {"index": target_index}
    }
    es.reindex(body)

if __name__ == "__main__":
    indices = ["index1", "index2", "index3"]
    with concurrent.futures.ThreadPoolExecutor(max_workers=3) as executor:
        futures = [executor.submit(reindex, index) for index in indices]
        for future in concurrent.futures.as_completed(futures):
            try:
                result = future.result()
            except Exception as exc:
                print(f"reindex failed: {exc}")

这个代码的作用是同时重建三个索引 `index1`、`index2` 和 `index3`。使用 `ThreadPoolExecutor` 来创建一个线程池，最大线程数为 3，然后提交 `_reindex` 任务到线程池中，等待任务完成即可。

当然，如果你的 Elasticsearch 集群性能足够强大，也可以同时在多个节点上执行 `_reindex` 操作，从而进一步提高重建的效率。