Elasticsearch 8.X 使用入门
from elasticsearch import Elasticsearch
# 连接到Elasticsearch
es = Elasticsearch("http://localhost:9200")
# 创建一个新的索引
res = es.indices.create(index='customer', ignore=400) # 如果索引已存在会抛出错误,使用ignore=400忽略
print(res['acknowledged']) # 输出: True 表示成功创建索引
# 添加一条文档到索引
doc = {
'name': 'John Doe',
'age': 30,
'email': 'john@example.com',
'address': '123 Main St',
'city': 'Anytown',
'state': 'CA',
'postcode': '12345'
}
res = es.index(index='customer', id=1, document=doc)
print(res['result']) # 输出: 'created' 或 'updated' 表示文档添加或更新成功
# 搜索索引中的文档
res = es.search(index='customer', query={'match': {'name': 'John'}})
print(res['hits']['hits']) # 输出匹配的文档列表
# 删除索引
res = es.indices.delete(index='customer', ignore=[400, 404])
print(res['acknowledged']) # 输出: True 表示成功删除索引
这段代码展示了如何使用Elasticsearch Python API进行基本的索引操作,包括创建索引、添加文档、搜索文档和删除索引。代码简洁明了,注重于核心功能的演示,对于初学者具有很好的教育价值。
评论已关闭