Cuối cùng đã quản lý để làm cho nó hoạt động. Hầu hết các ví dụ đều bỏ sót connect()
một phần.
Mã làm việc của tôi:
Book.getDataSource().connector.connect(function(err, db) {
var collection = db.collection('Book');
var author = Book.getDataSource().ObjectID(authorId);
collection.aggregate([
{ $match: { authorId: author } },
{ $group: {
_id: authorId,
total: { $sum: "$price" }
}}
], function(err, data) {
if (err) return callback(err);
return callback(null, data);
});
});