修改猫鼬的反应数据

Question

我有一个API调用，它以JSON的形式返回用户收到的所有消息。

模型数据看起来像这样：

{
    sender: ObjectId,
    reciever: ObjectId,
    message: String
}

修改API响应的JSON的正确方法是什么？

我想以这样分组的数据结束：

{
    <senderid>:[ all of the messages from this sender],
    <other_sender>:[ all of the messages from this sender]
}

我必须在javascript中手动执行此操作吗，或者是否有更快的方法利用猫鼬来执行此操作？

Answer 1

使用聚合框架将是此任务的理想选择。您可以运行以下聚合管道，该管道使用$group运算符步骤对数据进行分组以处理它们。组管道运算符类似于SQL的GROUP BY子句。在SQL中，除非使用任何聚合函数，否则不能使用GROUP BY。同样，您也必须在MongoDB中使用聚合函数。在本例中，使用$ush累加器运算符来创建消息数组。

因为模型。aggregate（）返回普通对象，然后使用lodash库的将结果数组转换为所需的哈希键。indexBy（）方法：

var pipeline = [
    {
        "$group": {
            "_id": "$sender",
            "messages": { "$push": "$message" }
        }
    }
];

Model.aggregate(pipeline,
    function(err, res) {
        if (err) return handleError(err);
        var hashmap = _.chain(res)
               .indexBy('_id')                 
               .mapValues('messages')                  
               .value();
        console.log(JSON.stringify(hashmap, undefined, 4));
    }
);

// Or use the aggregation pipeline builder.
Model.aggregate()
     .group({ "_id": "$sender", "messages": { "$push": "$message" } })
     .exec(function (err, res) {
        if (err) return handleError(err);
        var hashmap = _.chain(res)
               .indexBy('_id')                 
               .mapValues('messages')                  
               .value();
        console.log(JSON.stringify(hashmap, undefined, 4));
});

检查下面的演示。

var data = [
	{ _id: 'user1', messages: ['msg1', 'msg2'] }, 
	{ _id: 'user2', messages: ['msg3', 'msg1'] }, 
	{ _id: 'user3', messages: ['msg6', 'msg3'] },
	{ _id: 'user4', messages: ['msg4', 'msg8'] }
];

var hashmap = _.chain(data)
			   .indexBy('_id')				   
			   .mapValues('messages')
			   .tap(log)
			   .value();

function log(value) {
	pre.innerHTML += JSON.stringify(value, null, 4) + "\n"
}

<script src="//cdnjs.cloudflare.com/ajax/libs/lodash.js/3.10.1/lodash.min.js"></script>
<pre id="pre"></pre>