Mongodb Meteor 中的平均聚合查询

截至Meteor 0.6.5，collection API还不支持聚合查询，因为没有(直接的)方法对它们进行实时更新.然而，你仍然可以自己编写它们，并在Meteor.publish中提供它们，尽管结果是静态的.在我看来，这样做仍然更可取，因为您可以合并多个聚合并使用客户端收集API.

Meteor.publish("someAggregation", function (args) {
    var sub = this;
    // This works for Meteor 0.6.5
    var db = MongoInternals.defaultRemoteCollectionDriver().mongo.db;

    // Your arguments to Mongo's aggregation. Make these however you want.
    var pipeline = [
        { $match: doSomethingWith(args) },
        { $group: {
            _id: whatWeAreGroupingWith(args),
            count: { $sum: 1 }
        }}
    ];

    db.collection("server_collection_name").aggregate(        
        pipeline,
        // Need to wrap the callback so it gets called in a Fiber.
        Meteor.bindEnvironment(
            function(err, result) {
                // Add each of the results to the subscription.
                _.each(result, function(e) {
                    // Generate a random disposable id for aggregated documents
                    sub.added("client_collection_name", Random.id(), {
                        key: e._id.somethingOfInterest,                        
                        count: e.count
                    });
                });
                sub.ready();
            },
            function(error) {
                Meteor._debug( "Error doing aggregation: " + error);
            }
        )
    );
});

以上是分组/计数聚合的示例.值得注意的是:

• 当你这样做的时候，你自然会在server_collection_name上做一个聚合，并将结果推送到另一个名为client_collection_name的集合.
• 这个订阅将不会是实时的，并且可能会在参数更改时更新，所以我们使用一个非常简单的循环，将所有结果推出.
• 聚合的结果没有Mongo对象，因此我们生成了一些自己的任意对象.
• 对聚合的回调需要封装在光纤中.我这里使用Meteor.bindEnvironment，但也可以使用Future进行更低级的控制.

如果您开始结合这些出版物的结果，您需要仔细考虑随机生成的IDS是如何影响合并框的.然而，这个简单的实现只是一个标准的数据库查询，只是它更方便地与Meteor API客户端一起使用.

TL;DR version:几乎任何时候你从服务器推出数据时，publish都比method好.

有关聚合不同方法的更多信息，请参见100.