获取所有索引curl --location 'http://xx.xx.xx.xx:9200/_cat/indices?v=null&h=index&s=index%3Aasc' \ --header 'Authorization: xxx' \ --data ''将所有index放入index.txt中创建账号密码凭证auth.iniuser=xxx password="xxx"修改代码 es.py# -*- coding=utf-8 -*- import os import multiprocessing index_names = 'index_1,index_2' index_list = [] from_host = 'xxx' to_host = 'xxx' def migrate_one_index_child(index_name): print(str.format("### begin to migrate index, pid: {}, index: {}", os.getpid(), ind
Xinbo
