ElasticSearch客户端操作
from elasticsearch import Elasticsearch
# 连接到Elasticsearch
es = Elasticsearch(hosts=["localhost:9200"])
# 创建一个新的索引
response = es.indices.create(index='my_index', ignore=400)
print(response)
# 获取所有索引
response = es.indices.get_alias("*")
print(response)
# 在索引中添加一个文档
doc = {
'author': 'test_author',
'text': 'Sample document',
'timestamp': '2021-01-01T12:00:00'
}
response = es.index(index='my_index', id=1, document=doc)
print(response)
# 更新一个文档
doc = {
'author': 'updated_author',
'text': 'Updated sample document',
}
response = es.update(index='my_index', id=1, document=doc)
print(response)
# 获取一个文档
response = es.get(index='my_index', id=1)
print(response)
# 删除一个文档
response = es.delete(index='my_index', id=1)
print(response)
# 删除索引
response = es.indices.delete(index='my_index', ignore=[400, 404])
print(response)
这段代码展示了如何使用Elasticsearch Python客户端库来执行基本的索引操作,包括创建索引、获取索引列表、添加/更新/获取/删除文档等。这对于需要在Python环境中与Elasticsearch交互的开发者来说是一个很好的学习资源。
评论已关闭