ElasticSearch8 - 基本操作

from elasticsearch import Elasticsearch
 
# 连接到Elasticsearch
es = Elasticsearch("http://localhost:9200")
 
# 创建一个新的索引
res = es.indices.create(index='customer', ignore=400)  # 如果索引已存在会抛出错误，可以设置ignore=400忽略
print(res)
 
# 添加一个文档到索引
doc = {
    "name": "John Doe",
    "age": 30,
    "email": "john@example.com",
    "address": "123 Main St",
    "location": "europe"
}
res = es.index(index='customer', id=1, document=doc)
print(res)
 
# 获取一个文档
res = es.get(index='customer', id=1)
print(res)
 
# 更新一个文档
doc = {
    "name": "Jane Doe",
    "age": 25,
    "email": "jane@example.com",
    "address": "456 Main St",
    "location": "asia"
}
res = es.update(index='customer', id=1, document=doc)
print(res)
 
# 删除一个文档
res = es.delete(index='customer', id=1)
print(res)
 
# 删除索引
res = es.indices.delete(index='customer', ignore=[400, 404])
print(res)

这段代码展示了如何使用Elasticsearch Python API进行基本的索引操作，包括创建索引、添加文档、获取文档、更新文档和删除文档。同时，在删除索引时，使用了ignore参数来忽略可能出现的404错误，因为在Elasticsearch中，如果索引不存在，尝试删除会导致错误。