我想与用户和预订集合进行内部联接,其中Reservation.userId = users._id在meteor.js中。我想与用户集合中的userObj发布我的预订集合所以我用了聚合,
Meteor.publish("Reservations", function() {
var options = {
allowDiskUse: true
};
var pipeline = [
{
$project: {
_id: 0,
reservations: "$$ROOT"
}
},
{
$lookup: {
localField: "reservations.userId",
from: "users",
foreignField: "_id",
as: "users"
}
},
{
$unwind: {
path: "$users",
preserveNullAndEmptyArrays: false
}
},
{
$project: {
"reservations._id": "$reservations._id",
"reservations.placeId": "$reservations.placeId",
"reservations.userId": "$reservations.userId",
"reservations.date": "$reservations.date",
"users._id": "$users._id",
"users.profile": "$users.profile",
_id: 0
}
}
];
return Reservations.aggregate(pipeline, options);
});
我正在使用聚合(与meteorhacks:aggregate)
但是我有这样的错误,
I20191023-17:59:56.879(3)? Exception from sub Reservations id Yu9APaNsJKhNhnnGr Error: Publish function can only return a Cursor or an array of Cursors
I20191023-17:59:56.880(3)? at Subscription._publishHandlerResult (packages/ddp-server/livedata_server.js:1132:18)
I20191023-17:59:56.882(3)? at Subscription._runHandler (packages/ddp-server/livedata_server.js:1063:10)
I20191023-17:59:56.882(3)? at Session._startSubscription (packages/ddp-server/livedata_server.js:860:9)
I20191023-17:59:56.884(3)? at Session.sub (packages/ddp-server/livedata_server.js:625:12)
我使用了jcbernack:reactive-aggregate软件包,但仍然无法正常工作。
我需要一些帮助,如何将聚合与发布一起使用?
只需将.toArray
添加到行尾,如下所示:
Reservations.aggregate(pipeline, options).toArray();
一个侧面提示,最好使用sakulstra:aggregate
,因为它是meteorhacks:aggregate
的维护分支。
添加.toArray
时出现此错误:
I20191025-22:31:31.463(3)? Exception from sub Reservations id Af7Hs2WXjmmcErenc TypeError: Reservations.aggregate(...).toArray is not a function
I20191025-22:31:31.464(3)? at Subscription._handler (server/reservation.js:41:12)
I20191025-22:31:31.464(3)? at maybeAuditArgumentChecks (packages/ddp-server/livedata_server.js:1771:12)
I20191025-22:31:31.464(3)? at DDP._CurrentPublicationInvocation.withValue (packages/ddp-server/livedata_server.js:1046:15)
I20191025-22:31:31.465(3)? at Meteor.EnvironmentVariable.EVp.withValue (packages\meteor.js:1234:12)
I20191025-22:31:31.466(3)? at Subscription._runHandler (packages/ddp-server/livedata_server.js:1044:51)
I20191025-22:31:31.466(3)? at Session._startSubscription (packages/ddp-server/livedata_server.js:860:9)
I20191025-22:31:31.466(3)? at Session.sub (packages/ddp-server/livedata_server.js:625:12)
I20191025-22:31:31.467(3)? at packages/ddp-server/livedata_server.js:559:43
但是我已经尝试过:
Reservations.aggregate(pipeline, options).forEach(function(doc) {
console.log(doc);
});
我得到了结果,但仍然无法返回此结果。