用Python实现Elasticsearch的数据检索和查询

from elasticsearch import Elasticsearch

# 创建Elasticsearch客户端
es = Elasticsearch()

# 创建索引
index_name = "my_index"
es.indices.create(index=index_name)

# 插入文档
doc = {
    "title": "Elasticsearch",
    "content": "Elasticsearch is a distributed search and analytics engine.",
    "tags": ["search", "analytics"]
}
es.index(index=index_name, body=doc)

# 刷新索引
es.indices.refresh(index=index_name)

# 查询文档
query = {
    "query": {
        "match": {
            "content": "search engine"
        }
    }
}
result = es.search(index=index_name, body=query)

# 处理查询结果
for hit in result["hits"]["hits"]:
    print(hit["_source"])

# 删除索引
es.indices.delete(index=index_name)