Elasticsearch 基础操作
from datetime import datetime
from elasticsearch import Elasticsearch
# 连接到Elasticsearch
es = Elasticsearch("http://localhost:9200")
# 创建一个新的文档
doc = {
'author': 'test_author',
'text': 'Sample text',
'timestamp': datetime.now(),
}
res = es.index(index="test-index", id=1, document=doc)
print(res['result'])
# 获取一个文档
get_response = es.get(index="test-index", id=1)
print(get_response['_source'])
# 更新一个文档
update_response = es.update(index="test-index", id=1, document={"doc": {"text": "Updated text"}})
print(update_response['result'])
# 删除一个文档
delete_response = es.delete(index="test-index", id=1)
print(delete_response['result'])
这段代码展示了如何使用Elasticsearch Python API连接到Elasticsearch服务器,创建一个新的文档,获取该文档,更新该文档,并删除该文档。代码使用了elasticsearch
库,它是Elasticsearch的官方Python客户端。
评论已关闭