Elasticsearch基础索引操作演示总结

from datetime import datetime
from elasticsearch import Elasticsearch
 
# 初始化Elasticsearch客户端
es = Elasticsearch("http://localhost:9200")
 
# 创建索引
index_name = 'test_index'
doc_type = 'test_type'
 
# 创建索引
create_index_response = es.indices.create(index=index_name, ignore=400)
print("创建索引结果:", create_index_response)
 
# 索引文档
doc_id = '1'
document = {
    'name': 'John Doe',
    'age': 30,
    'birth_date': datetime.now(),
    'about': 'I love to go rock climbing'
}
 
# 索引文档
index_doc_response = es.index(index=index_name, doc_type=doc_type, id=doc_id, body=document)
print("索引文档结果:", index_doc_response)
 
# 获取文档
get_doc_response = es.get(index=index_name, doc_type=doc_type, id=doc_id)
print("获取文档结果:", get_doc_response)
 
# 更新文档
updated_document = {
    'name': 'Jane Doe',
    'age': 25,
    'birth_date': datetime.now(),
    'about': 'I like to collect rock albums'
}
update_doc_response = es.update(index=index_name, doc_type=doc_type, id=doc_id, body={'doc': updated_document})
print("更新文档结果:", update_doc_response)
 
# 删除文档
delete_doc_response = es.delete(index=index_name, doc_type=doc_type, id=doc_id)
print("删除文档结果:", delete_doc_response)
 
# 删除索引
delete_index_response = es.indices.delete(index=index_name, ignore=[400, 404])
print("删除索引结果:", delete_index_response)

这段代码展示了如何在Elasticsearch中创建索引、索引文档、获取文档、更新文档以及删除文档，并在最后删除索引。注意，在实际应用中，你需要根据自己的Elasticsearch服务器地址和端口调整Elasticsearch客户端初始化代码。