mongodb聚合/mapreduce

Question

我正在尝试从我的 mongo-documents 对象中提取 uniq 键 + 所有 uniq 值。

假设我的文档结构如下：

{
    "userId": "1234",
    "formFields": {
        "field1": "value1",
        "field2": "value2"
    }
},
{
    "userId": "1234",
    "formFields": {
        "field3": "value3",
        "field1": "value1-edited"
    }
},
{
    "userId": "1234",
    "formFields": {
        "field3": "value3",
        "field1": "value1-edited"
    }
}

我想聚合来自用户“1234”的所有文档以获得“formFields”的不同值

结果应该是这样的：

{
    "_id": "1234",
    "formFields": {
        "field1": [
            "value1",
            "value1-edited"
        ],
        "field2": [
            "value2"
        ],
        "field3": [
            "field3"
        ],
        "field4": [
            "field4"
        ]
    }
}

formFields 中的键是动态的。 我尝试使用聚合和 mapreduce 来解决问题，但没有找到任何可以用作基础的工作示例。

谁能回答这个问题？

谢谢

问候 头盔

Answer 1

由于您有事先不知道的动态键，因此您需要获取这些字段的列表，以便在聚合管道中使用它们。获取该列表的一种方法是通过 mapReduce。下面演示了这种方法。在 Map-Reduce 操作中，formFields 子文档中的键数组生成到输出集合“uploads_keys”，然后用于生成聚合管道表达式：

var mr = db.runCommand({
    "mapreduce" : "uploads",
    "map" : function() {
        for (var key in this.formFields) { emit(key, null); }
    },
    "reduce" : function(key, stuff) { 
        return null  
    }, 
    "out": "uploads" + "_keys"
});

var groupKeys = {},
    projectKeys = { "formFields": {} };
db[mr.result].distinct("_id").forEach(function (key){    
    groupKeys[key] = { "$push": "$formFields." + key };
    projectKeys["formFields"][key] = "$" + key
});

groupKeys["_id"] = "$userId";

> printjson(groupKeys);
{
        "field1" : {
                "$push" : "$formFields.field1"
        },
        "field2" : {
                "$push" : "$formFields.field2"
        },
        "field3" : {
                "$push" : "$formFields.field3"
        },
        "_id" : "$userId"
}
> printjson(projectKeys);
{
        "formFields" : {
                "field1" : "$field1",
                "field2" : "$field2",
                "field3" : "$field3"
        }
}

然后您可以在聚合管道中使用这些变量：

db.uploads.aggregate([
    { "$group": groupKeys },
    { "$project": projectKeys }
])