ElasticSearch批量更新:使用python脚本组织JSON

from elasticsearch import Elasticsearch

# 创建Elasticsearch客户端
es = Elasticsearch()

# 构建批量更新操作的JSON对象
actions = [
    {
        "_index": "your_index",
        "_type": "your_type",
        "_id": "document_id",
        "_source": {
            "field1": "new_value1"
        }
    },
    {
        "_index": "your_index",
        "_type": "your_type",
        "_id": "document_id",
        "_source": {
            "field2": "new_value2"
        }
    },
    # 添加更多的更新操作...
]

# 组织JSON数组
bulk_data = ""
for action in actions:
    bulk_data += f'{{"{action["_index"]}": {{"_id": "{action["_id"]}", "_type": "{action["_type"]}"}}}}\n'
    bulk_data += f'{{"doc": {action["_source"]}}}\n'

# 执行批量更新操作
response = es.bulk(body=bulk_data)

# 处理响应结果
if response["errors"]:
    for item in response["items"]:
        if "error" in item["update"]:
            print(f"更新文档失败：{item['update']['_id']}")
else:
    print("批量更新操作成功")