Node.js UnhandledPromiseRejectionWarning 即使在捕获它之后

我正在使用 Node 7.2.1 和新版本异步/等待特征。我还将 Native ES6 Promises 与 mongoose 一起使用，如下所示 -

const mongoose = require('mongoose');
mongoose.Promise = global.Promise;

我的代码流程是这样的 -

async function getFollowers(){
    try {
        const followers = await User.getFollowersFromMongo(req.params.userId);
        res.send(followers);
    } catch (err) {
        winston.error('Printing Error = ', err);
        res.status(400).send({success: false, error: err});
    }
}

UserSchema.statics.getFollowersFromMongo = async(userId) => {
    try {
        let aggregateQuery = []; //some syntactical error in mongo query to produce exception

        const followers = await User.aggregate(aggregateQuery);
        return followers.map(follower => follower.followerData);
    }
    catch (err) {
        return Promise.reject(err);
    }
};

这段代码工作得非常好。当产生一些错误时就会出现问题。所以我特意修改了我的mongoose查询以便MongoDB会抛出一个错误。

现在，MongoDB 正如预期的那样抛出一个错误，该错误被我的代码完美捕获，并以 400 错误代码返回给客户端。

问题是，即使错误（故意的）已被我发现，Node.js仍然给我这个警告 -

error:  Printing Error = MongoError: path option to $unwind stage should be prefixed with a '$': followerData
at Function.MongoError.create (/home/node_modules/mongodb-core/lib/error.js:31:11)
at /home/node_modules/mongodb-core/lib/connection/pool.js:483:72
at authenticateStragglers (/home/node_modules/mongodb-core/lib/connection/pool.js:429:16)
at Connection.messageHandler (/home/node_modules/mongodb-core/lib/connection/pool.js:463:5)
at Socket.<anonymous> (/home/node_modules/mongodb-core/lib/connection/connection.js:317:22)
at emitOne (events.js:96:13)
at Socket.emit (events.js:188:7)
at readableAddChunk (_stream_readable.js:176:18)
at Socket.Readable.push (_stream_readable.js:134:10)
at TCP.onread (net.js:551:20)

GET /user/385/followers 400 39.868 ms - 263

(node:10158) UnhandledPromiseRejectionWarning: Unhandled promise rejection (rejection id: 1): MongoError: path option to $unwind stage should be prefixed with a '$': followerData
(node:10158) DeprecationWarning: Unhandled promise rejections are deprecated. In the future, promise rejections that are not handled will terminate the Node.js process with a non-zero exit code.

可以看出，我的请求已返回 400 状态，并且我的错误日志也已从初始方法的 catch 块中打印出来，但是Node.js仍然说错误消息未处理。

为什么在发现同样的错误后仍然这么说？

Update -感谢@dvlsg和@Bergi，该bug已在4.7.5版本中修复

猫鼬聚合与 async/await 的配合方式肯定有些奇怪。对我来说，这似乎是一个错误。如果是的话，绝对应该报告给 mongoose。

值得庆幸的是，有一个简单的解决方法：

const followers = await User.aggregate(aggregateQuery).exec();

添加显式.exec()允许我按预期捕获聚合管道错误。

我认为这里增加混乱的根本问题是还有一个额外的问题Promise漂浮在周围，被拒绝且未被处理。因为从技术上来说，你are正确处理这里预期的拒绝。不然你就看不到那个Printing error = ...正在记录。

这就是我相信正在发生的事情——

• You await User.aggregate()
• Aggregate#then()被调用通过await与...一起工作thenables（我认为）
• Aggregate#exec() is called internally by Aggregate#then()
  • 注意提供回调 https://github.com/Automattic/mongoose/blob/09a1d72178eb9cb0873e457787e10e235cead07a/lib/aggregate.js#L609 to exec()
• A new Promise inside Aggregate#exec() is created https://github.com/Automattic/mongoose/blob/09a1d72178eb9cb0873e457787e10e235cead07a/lib/aggregate.js#L562, and will be rejected https://github.com/Automattic/mongoose/blob/09a1d72178eb9cb0873e457787e10e235cead07a/lib/aggregate.js#L419
  • This是未处理的Promise， 我相信。
• 由于提供了回调Aggregate#exec() from Aggregate#then(), the Error inside Aggregate#exec()将提供给回调 https://github.com/Automattic/mongoose/blob/09a1d72178eb9cb0873e457787e10e235cead07a/lib/aggregate.js#L565-L567
• Inside the callback in Aggregate#then(), a newly created https://github.com/Automattic/mongoose/blob/09a1d72178eb9cb0873e457787e10e235cead07a/lib/aggregate.js#L608 Promise is rejected
  • 我相信这一点Promise按预期处理，因为它是从返回Aggregate#then()

我想我可以通过评论来证实我的怀疑这条线 https://github.com/Automattic/mongoose/blob/09a1d72178eb9cb0873e457787e10e235cead07a/lib/aggregate.js#L568在猫鼬中Aggregate定义。这将防止未处理的拒绝处理程序被击中。顺便说一句，我并不是建议这样做。这只是额外的证据，不是解决方案，因为现在我只有一个未拒绝的Promise漂浮在周围。

这是一种在自包含的代码中重现未捕获拒绝的最小方法，可以使用node --harmony-async-await（在节点上测试v7.2.1)

const mongoose = require('mongoose');
mongoose.Promise = global.Promise;
mongoose.connect('mongodb://localhost/temp');

const userSchema = new mongoose.Schema({
  name: 'string'
});

const User = mongoose.model('User', userSchema);

async function run() {
  try {
    await User.aggregate([]);
  }
  catch (err) {
    console.log('caught expected error:', err);
  }
}

run();