假设我有一个类似于以下内容的 Mongo 集合:
[
{ "foo": "bar baz boo" },
{ "foo": "bar baz" },
{ "foo": "boo baz" }
]
是否可以确定在该字段中最常出现的单词foo
(最好是计数)?
例如,我喜欢这样的结果集:
[
{ "baz" : 3 },
{ "boo" : 2 },
{ "bar" : 2 }
]
假设我有一个类似于以下内容的 Mongo 集合:
[
{ "foo": "bar baz boo" },
{ "foo": "bar baz" },
{ "foo": "boo baz" }
]
是否可以确定在该字段中最常出现的单词foo
(最好是计数)?
例如,我喜欢这样的结果集:
[
{ "baz" : 3 },
{ "boo" : 2 },
{ "bar" : 2 }
]
最近关闭了一个关于在聚合框架阶段使用的运算符的JIRA 问题。
有了它,您可以创建这样的管道 $split
$project
db.yourColl.aggregate([
{
$project: {
words: { $split: ["$foo", " "] }
}
},
{
$unwind: {
path: "$words"
}
},
{
$group: {
_id: "$words",
count: { $sum: 1 }
}
}
])
结果看起来像这样
/* 1 */
{
"_id" : "baz",
"count" : 3.0
}
/* 2 */
{
"_id" : "boo",
"count" : 2.0
}
/* 3 */
{
"_id" : "bar",
"count" : 2.0
}
在 MongoDB 3.4 中执行此操作的最佳方法是使用$split
运算符将您的字符串拆分为一个子字符串数组,如此处所述,因为我们需要$unwind
在管道中向下排列数组,所以我们需要使用运算符在子管道中执行此$facet
操作以获得最大效率。
db.collection.aggregate([
{ "$facet": {
"results": [
{ "$project": {
"values": { "$split": [ "$foo", " " ] }
}},
{ "$unwind": "$values" },
{ "$group": {
"_id": "$values",
"count": { "$sum": 1 }
}}
]
}}
])
产生:
{
"results" : [
{
"_id" : "boo",
"count" : 2
},
{
"_id" : "baz",
"count" : 3
},
{
"_id" : "bar",
"count" : 2
}
]
}
从 MongoDB 3.2 向后,唯一的方法是使用mapReduce
.
var reduceFunction = function(key, value) {
var results = {};
for ( var items of Array.concat(value)) {
for (var item of items) {
results[item] = results[item] ? results[item] + 1 : 1;
}
};
return results;
}
db.collection.mapReduce(
function() { emit(null, this.foo.split(" ")); },
reduceFunction,
{ "out": { "inline": 1 } }
)
返回:
{
"results" : [
{
"_id" : null,
"value" : {
"bar" : 2,
"baz" : 3,
"boo" : 2
}
}
],
"timeMillis" : 30,
"counts" : {
"input" : 3,
"emit" : 3,
"reduce" : 1,
"output" : 1
},
"ok" : 1
}
如果您的 MongoDB 版本不支持该语句,您应该考虑在reduce.forEach()
函数中使用方法。for...of