Aha, tôi đã tìm ra giải pháp. Tổng hợp aggregate framework cho phép chúng ta thực thi một loạt các tác vụ trên một tập hợp. Đặc biệt lưu ý là $unwind , chia một mảng trong tài liệu thành tài liệu duy nhất , vì vậy chúng có thể là nhóm / được tính en masse .
MongooseJS hiển thị điều này rất dễ tiếp cận trên một mô hình. Sử dụng ví dụ trên, điều này trông như sau:
Thing.aggregate([
{ $match: { /* Query can go here, if you want to filter results. */ } }
, { $project: { tokens: 1 } } /* select the tokens field as something we want to "send" to the next command in the chain */
, { $unwind: '$tokens' } /* this converts arrays into unique documents for counting */
, { $group: { /* execute 'grouping' */
_id: { token: '$tokens' } /* using the 'token' value as the _id */
, count: { $sum: 1 } /* create a sum value */
}
}
], function(err, topTopics) {
console.log(topTopics);
// [ foo: 4, bar: 2 baz: 2 ]
});
Nó nhanh hơn đáng kể so với MapReduce trong các thử nghiệm sơ bộ trên ~ 200.000 bản ghi và do đó có khả năng mở rộng quy mô tốt hơn, nhưng điều này chỉ xảy ra sau một cái nhìn lướt qua. YMMV.
