我的文档结构看起来像这样
{
title : 'a product',
price : 10
}
我想做的是一个动态价格范围方面,看起来像这样
[
{
facet : '0-30',
count : 5
},
{
facet : '30-100',
count : 40
}
]
显然会有一个固定的间隔,例如 50。我曾经让 ElasticSearch 使用直方图函数为我执行此操作,但我无法让它在 mongo 中工作。我想,可以做一个地图缩减来完成它,但我想知道是否有办法添加到我的聚合管道中。
可以尝试聚合管道,在其中可以使用 $cond
运算符投影facet
字段。为了演示这一点,假设您有一个包含以下文档的集合:
db.collection.insert([
{ "title" : "Product STU", "price" : 10 },
{ "title" : "Product XYZ", "price" : 50 },
{ "title" : "Product PCT", "price" : 14 },
{ "title" : "Product DEF", "price" : 89 },
{ "title" : "Product DYQ", "price" : 34 },
{ "title" : "Product ABC", "price" : 40 },
{ "title" : "Product JKL", "price" : 50 },
{ "title" : "Product PQR", "price" : 75 },
{ "title" : "Product MNO", "price" : 81 },
{ "title" : "Product VWN", "price" : 5 },
{ "title" : "Product KLM", "price" : 63 }
]);
将实现所需结果的聚合管道如下所示:
db.collection.aggregate([
{
"$match": {
"price": { "$lte": 100, "$gte": 0 }
}
},
{
"$project": {
"title": 1,
"price": 1,
"_id": 0,
"facet": {
"$cond": [ { "$gte": [ "$price", 30 ] }, "30-100", "0-30" ]
}
}
},
{
"$group": {
"_id": "$facet",
"count": {
"$sum": 1
}
}
},
{
"$project": {
"facet": "$_id",
"_id": 0,
"count": 1
}
}
])
输出:
/* 1 */
{
"result" : [
{
"count" : 8,
"facet" : "30-100"
},
{
"count" : 3,
"facet" : "0-30"
}
],
"ok" : 1
}