【ElasticSearch】批量导入导出es数据
批量导入数据到ElasticSearch可以使用_bulk API。以下是一个简单的Python脚本，使用elasticsearch包来批量导入JSON数据。
首先，安装elasticsearch包（如果尚未安装）:
pip install elasticsearch然后，编写批量导入数据的脚本：
from elasticsearch import Elasticsearch
# 连接到ElasticSearch
es = Elasticsearch("http://localhost:9200")
# 准备数据，每行是一个JSON文档，以新行符分隔
data = """
{"index":{"_index":"your_index","_id":1}}
{"field1":"value1a","field2":"value2a"}
{"index":{"_index":"your_index","_id":2}}
{"field1":"value1b","field2":"value2b"}
"""
# 执行批量导入
response = es.bulk(index="your_index", doc_type="_doc", body=data)
# 输出结果
print(response)确保替换your_index为你的目标索引，以及修改数据以符合你的需求。这个脚本会将两个文档批量导入到指定的索引中。
评论已关闭