使用所有子文档mongo meteor获取不同的对象对

为此，请使用聚合框架，但是由于Meteor还不支持聚合，因此您需要安装聚合框架程序包-它不会起到任何作用，只是为您包装了一些Mongo方法。

只需添加流星meteorhacks:aggregate，您就可以开展业务。这将为Meteor添加适当的聚合支持。

现在，您将需要此管道来获得所需的结果。在mongo shell中，运行以下命令：

var pipeline = [
    {
        "$group": {
            "_id": "$name",
            "quantity": { "$sum": "$quantity" }
        }
    },
    {
        "$project": {
            "name": "$_id", "_id": 0, "quantity": 1
        }
    }
];

db.sales.aggregate(pipeline);

样本输出

{
    "result" : [ 
        {
            "quantity" : 7,
            "name" : "Pizza"
        }, 
        {
            "quantity" : 3,
            "name" : "Hot Coffee"
        }
    ],
    "ok" : 1
}

聚合操作的作用是使用$group流水线步骤将所有文档按name字段分组，对于每个不同的组，您可以使用累加器运算符$sum对每个组的数字字段数量进行累加总数量。下一个管道$project将把前一个管道流文档中的字段重塑为所需的结构。

在Meteor中，您可以Sales使用以下模式将这些结果发布到客户端上的集合中，前提是您已将汇总包添加到流星应用程序中：

Meteor.publish('getDistinctSalesWithTotalQuantity', function (opts) {

    var initializing = 1;

    function run(action) {

        // Define the aggregation pipeline ( aggregate(pipeline) )
        var pipeline = [
            {
                "$group": {
                    "_id": "$name",
                    "quantity": { "$sum": "$quantity" }
                }
            },
            {
                "$project": {
                    "name": "$_id", "_id": 0, "quantity": 1
                }
            }
        ];

        Sales.aggregate(pipeline).forEach(function(e){
            this[action]('distinct-sales', e.name, e)
            this.ready()
        });
    };

    // Run the aggregation initially to add some data to your aggregation collection
    run('added');

    // Track any changes on the collection we are going to use for aggregation
    var handle = Sales.find({}).observeChanges({
        added(id) {
            // observeChanges only returns after the initial `added` callbacks
            // have run. Until then, we don't want to send a lot of
            // `self.changed()` messages - hence tracking the
            // `initializing` state.
            if (initializing && initializing--) run('changed');
        },
        removed(id) {
            run('changed');
        },
        changed(id) {
            run('changed');
        },
        error(err) {
            throw new Meteor.Error('Aaaaaaaaah! Grats! You broke it!', err.message)
        }
    });

    // Stop observing the cursor when client unsubs.
    // Stopping a subscription automatically takes
    // care of sending the client any removed messages.
    this.onStop(function () {
        handle.stop();
    });
});

以上内容会观察到更改，并在必要时重新运行聚合。