【elasticsearch】es数据库同步

from elasticsearch import Elasticsearch, helpers import logging import time """ 用于数据库同步 将源es的下的文档同步到目标es下对应的索引 注意同步前先使用delete_es_new.sh，删除目标es对应索引下的文档，但不要删除索引，然后进行同步 """ # 配置日志 logging.basicConfig(level=logging.INFO) logger = logging.getLogger(__name__) # 源ES SOURCE_ES = { 'hosts': ['http://ip:9200'], 'http_auth': ('elastic', 'Tinipigu123'), 'timeout': 30 } # 目标ES TARGET_ES = { 'hosts': ['http://ip:9200'], 'http_auth': ('elastic', 'Tinipigu123'), 'timeout': 30 } # 需要迁移的索引列表 INDICES_TO_MIGRATE = ['cases', 'mcp_schemas', 'work_orders'] # def migrate_index(source_es, target_es, index_name, batch_size=1000): """ 迁移单个索引的所有数据 """ # 检查源索引是否存在 # 获取源索引的mapping和settings try: mapping = source_es.indices.get_mapp