在Elasticsearch中按照每个类别查询N个项可以使用聚合功能来实现。以下是一个示例代码,演示如何在Elasticsearch中按照每个类别查询N个项:
from elasticsearch import Elasticsearch
# 创建Elasticsearch客户端
es = Elasticsearch()
# 指定索引和类型
index = 'your_index'
doc_type = 'your_type'
# 指定每个类别查询N个项
category_count = 5
# 构建查询语句
query = {
"size": 0,
"aggs": {
"categories": {
"terms": {
"field": "category.keyword",
"size": category_count
},
"aggs": {
"top_items": {
"top_hits": {
"size": N
}
}
}
}
}
}
# 执行查询
response = es.search(index=index, doc_type=doc_type, body=query)
# 解析查询结果
categories = response['aggregations']['categories']['buckets']
for category in categories:
category_name = category['key']
top_items = category['top_items']['hits']['hits']
print(f"Category: {category_name}")
for item in top_items:
item_name = item['_source']['name']
print(f"Item: {item_name}")
print("--------------------------------------")
在上面的示例中,我们使用terms
聚合来按照category
字段进行分组,并使用size
参数指定每个类别返回的项数。然后,我们在每个类别的聚合结果中使用top_hits
聚合来获取具体的项。最后,我们解析聚合结果并打印出每个类别和对应的项。
请注意,你需要根据你的实际需求修改索引名称、类型、字段名称、项数等参数。
上一篇:按照每个客户的首个订单筛选数据框
下一篇:按照每个类别的权重分配总量