Elasticsearch ES操作:查询数据(全部、分页、单条、组合条件)
from elasticsearch import Elasticsearch
# 连接Elasticsearch
es = Elasticsearch(hosts=["localhost:9200"])
# 索引名称
index_name = 'your_index'
# 查询所有数据
def search_all(index_name):
response = es.search(index=index_name, size=10000)
return response['hits']['hits']
# 分页查询
def search_with_pagination(index_name, page, page_size):
response = es.search(index=index_name, from_=(page - 1) * page_size, size=page_size)
return response['hits']['hits']
# 查询单条数据
def search_single_document(index_name, document_id):
response = es.get(index=index_name, id=document_id)
return response['_source']
# 组合条件查询
def search_with_query(index_name, query):
response = es.search(index=index_name, query=query)
return response['hits']['hits']
# 示例使用
if __name__ == '__main__':
# 查询所有数据
all_data = search_all(index_name)
print(all_data)
# 分页查询第1页,每页5条数据
page_data = search_with_pagination(index_name, 1, 5)
print(page_data)
# 查询ID为'123'的数据
single_doc = search_single_document(index_name, '123')
print(single_doc)
# 使用查询条件进行查询
bool_query = {
"query": {
"bool": {
"must": [
{"match": {"field1": "value1"}}
],
"filter": [
{"term": {"field2": "value2"}}
]
}
}
}
results = search_with_query(index_name, bool_query)
print(results)
这段代码展示了如何使用Elasticsearch Python API进行不同类型的搜索操作。其中包括查询所有文档、分页查询、查询单条文档以及使用查询条件进行搜索。在实际应用中,你需要根据具体的Elasticsearch集群和查询需求进行相应的调整。
评论已关闭