一网打尽:Elasticsearch 数组全量实战操作指南
from elasticsearch import Elasticsearch
# 连接到Elasticsearch
es = Elasticsearch("http://localhost:9200")
# 准备数据
data = [
{
"index": {
"_index": "test_index",
"_id": "1"
}
},
{
"name": "John Doe",
"age": 30,
"about": "I love to go rock climbing",
"interests": ["sports", "music"]
},
{
"index": {
"_index": "test_index",
"_id": "2"
}
},
{
"name": "Jane Smith",
"age": 32,
"about": "I like to collect rock albums",
"interests": ["music"]
}
# ... 更多数据项
]
# 使用bulk方法批量导入数据
response = es.bulk(index="test_index", documents=data, request_timeout=300)
# 输出结果
print(response)
这段代码演示了如何使用Elasticsearch Python API将一组数据项以数组的形式发送到Elasticsearch进行批量索引。代码中的data
变量包含了一系列操作指令和数据项,这些项将被批量导入到指定的test_index
索引中。通过调用es.bulk
方法,我们可以高效地执行批量导入。request_timeout
参数确保了请求不会超过设定的时间。最后,我们打印出了响应对象,以检查批量操作是否成功。
评论已关闭