elasticsearch实现得功能代码

Elasticsearch是一个分布式、RESTful搜索引擎，主要用于实时全文搜索和分析。它通过Java API或其提供的多种客户端库（如Python的elasticsearch-py）来操作。以下是使用Python客户端简单地创建索引、添加文档和查询的一个示例：

from elasticsearch import Elasticsearch

# 创建Elasticsearch实例
es = Elasticsearch([{'host': 'localhost', 'port': 9200}])

# 定义索引名和映射（数据结构）
index_name = "my_index"
doc_type = "_doc"  # 默认映射类型

# 如果索引不存在，创建它
if not es.indices.exists(index=index_name):
    es.indices.create(index=index_name)

# 添加文档（JSON格式）
doc = {
    "title": "Elasticsearch 示例",
    "content": "这是一个关于Elasticsearch的基础教程。",
}

# 批量添加文档
res = es.index(index=index_name, doc_type=doc_type, id=1, body=doc)
print(res['result'])

# 查询文档
query = {
    "match": {"content": "教程"}
}
response = es.search(index=index_name, body=query)
for hit in response["hits"]["hits"]:
    print(hit["_source"])