Mongodb node.js $out 聚合仅在调用 toArray() 时才有效

Question

使用"mongodb": "^3.0.6" 保存聚合查询作为$out 运算符的结果仅在调用.toArray() 时有效。

聚合步骤：

let aggregationSteps = [{
    $group: {
        _id: '$created_at',
    }
}, {'$out': 'ProjectsByCreated'}];

执行聚合：

await collection.aggregate(aggregationSteps, {'allowDiskUse': true})

预期结果：名为 ProjectsByCreated 的新集合。

结果：没有集合，查询没有抛出异常但没有被执行？ （只需 1 毫秒）

附加 toArray() 会产生预期的行为：

await collection.aggregate(aggregationSteps, {'allowDiskUse': true}).toArray();

为什么 mongodb 只在调用 .toArray() 时创建结果集合，文档在哪里这么说？我怎样才能解决这个问题？

文档似乎没有提供有关此的任何信息：

• https://mongodb.github.io/node-mongodb-native/3.0/api/Collection.html#aggregate
• https://docs.mongodb.com/manual/reference/operator/aggregation/out/index.html

Answer 1

MongoDB 承认这种行为，但他们也表示这是按设计工作的。

它已在 MongoDB JIRA $out aggregation stage doesn't take effect 中记录为错误，并且响应说这不是错误：

这种行为是有意的，并且在一段时间内没有通过节点驱动程序改变。当您通过调用 Collection.prototype.aggregate “运行”聚合时，我们创建了一个中间游标，它在请求某种 I/O 之前不会执行。这允许我们提供可链接的游标 API（例如 cursor.limit(..).sort(..).project(..)），在执行初始查询之前在构建器中构建查找或聚合选项。

... 链接 toArray 以执行 out 阶段感觉不太正确。有没有更自然的东西我没有注意到？

不幸的是，那里的链接方法只是继续构建您的聚合。以下任何方法都将导致运行初始聚合：toArray、each、forEach、hasNext、next。我们曾考虑为变更流之类的内容添加类似 exec/run 的内容，但它仍在我们的积压工作中。现在，理论上你可以只调用 hasNext 来运行第一个聚合并检索第一批（这很可能是 exec/run 无论如何都会在内部执行的操作）。

所以，看起来您必须调用其中一种方法来开始迭代光标，然后$out 才会执行任何操作。正如您已经在做的那样，添加.toArray() 可能是最安全的。请注意，to.Array() 不会像往常一样将整个结果加载到 RAM 中；因为它包含$out、the aggregation returns an empty cursor。

Answer 2

因为Aggregation 操作返回的是游标，而不是结果。 为了从光标处返回所有文档，我们需要使用toArray方法。