【Elasticsearch】学习笔记-p5（搜索结果处理）

# 导入Elasticsearch客户端
from elasticsearch import Elasticsearch
 
# 初始化Elasticsearch客户端
es = Elasticsearch(hosts=['localhost:9200'])
 
# 搜索查询
def search_query(index, query):
    # 执行搜索
    response = es.search(index=index, body=query)
    # 处理搜索结果
    hits = response['hits']['hits']
    for hit in hits:
        print(f"Found document: {hit['_source']}")
 
# 索引名称
index_name = 'kibana_sample_data_flights'
 
# 查询请求体
query_body = {
    "query": {
        "match": {
            "DestWeather": "Sunny"
        }
    }
}
 
# 调用搜索查询函数
search_query(index_name, query_body)

这段代码导入了Elasticsearch客户端，初始化了一个连接到本地Elasticsearch实例的客户端。然后定义了一个search_query函数，该函数接受索引名称和查询请求体作为参数，执行搜索，并打印出每个匹配文档的源数据。最后，使用具体的索引名称和查询请求体调用了这个函数。