Há uma configuração geral que você pode usar para acessar o objeto de coleção de driver subjacente e, portanto,
.aggregate()
sem instalar nenhum outro plugin. O processo básico é assim:
FooAges = new Meteor.Collection("fooAges");
Meteor.publish("fooAgeQuery", function(args) {
var sub = this;
var db = MongoInternals.defaultRemoteCollectionDriver().mongo.db;
var pipeline = [
{ "$group": {
"_id": "$age",
"name": { "$max": "$name" }
}}
];
db.collection("foo").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("fooAges", Random.id(), {
"age": e._id,
"name": e.name
});
});
sub.ready();
},
function(error) {
Meteor._debug( "Error doing aggregation: " + error);
}
)
);
});
Então você define uma coleção para a saída da agregação e dentro de uma rotina como essa você publica o serviço que você também vai assinar em seu cliente.
Dentro disso, a agregação é executada e preenchida na outra coleção (logicamente, pois na verdade não grava nada). Então você usa essa coleção no cliente com a mesma definição e todos os resultados agregados são retornados.
Na verdade, tenho um exemplo completo de aplicação de processos semelhantes dentro esta pergunta , bem como o uso do agregado de hacks de meteoros pacote esta pergunta aqui também, se você precisar de mais referência.
