MongoDB Node.js本机驱动程序无声地吞没了“ bulkWrite”异常

Question

下面的脚本在mongo bulkWrite op语法中存在一个错误：$setOnInsert: { count:0 },不必要，因此mongo引发异常：“无法同时更新’count’和’count’”。

问题是，node.js驱动程序似乎无法捕获它。此脚本记录“成功！” 到控制台。

(async () => {

  let db = await require('mongodb').MongoClient.connect('mongodb://localhost:27017/myNewDb');

  let mongoOps = [{
    updateOne: {
      filter: { foo: "bar" },
      update: {
        $setOnInsert: { count:0 },
        $inc: { count:1 },
      },
      upsert: true,
    }
  }];

  try {
    await db.collection("myNewCollection").bulkWrite(mongoOps);
    console.log("Success!");
  } catch(e) {
    console.log("Failed:");
    console.log(e);
  }

})();

检查db.system.profile.find({})与db.setProfileLevel(2)我们可以看到异常：

{
    "op" : "update",
    "ns" : "myNewDb.myNewCollection",
    "query" : {
        "foo" : "bar"
    },
    "updateobj" : {
        "$setOnInsert" : {
            "count" : 0
        },
        "$inc" : {
            "count" : 1
        }
    },
    "keyUpdates" : 0,
    "writeConflicts" : 0,
    "numYield" : 0,
    "locks" : {
        "Global" : {
            "acquireCount" : {
                "r" : NumberLong(1),
                "w" : NumberLong(1)
            }
        },
        "Database" : {
            "acquireCount" : {
                "w" : NumberLong(1)
            }
        },
        "Collection" : {
            "acquireCount" : {
                "w" : NumberLong(1)
            }
        }
    },
    "exception" : "Cannot update 'count' and 'count' at the same time",
    "exceptionCode" : 16836,
    "millis" : 0,
    "execStats" : {},
    "ts" : ISODate("2017-10-12T01:57:03.008Z"),
    "client" : "127.0.0.1",
    "allUsers" : [],
    "user" : ""
}

为什么驾驶员会吞下这样的错误？我绝对看起来像是个错误，但我想我想先确定一下。

Answer 1

因此评论说，“这是一个错误”。具体来说，错误就在这里：

 // Return a Promise
  return new this.s.promiseLibrary(function(resolve, reject) {
    bulkWrite(self, operations, options, function(err, r) {
      if(err && r == null) return reject(err);
      resolve(r);
    });
  });

问题在于，r包装在a中的回调中的“响应”（或）Promise实际上不是null，因此尽管存在错误，也不会true并reject(err)不会调用该条件，而是resolve(r)正在发送并因此这不视为例外。

更正需要一些分类，但是您可以通过检查writeErrors当前bulkWrite()实现的响应中的属性来“解决”，也可以考虑以下其他替代方法之一：

直接使用Bulk API方法：

const MongoClient = require('mongodb').MongoClient,
      uri  = 'mongodb://localhost:27017/myNewDb';

(async () => {

  let db;

  try {

    db = await MongoClient.connect(uri);

    let bulk = db.collection('myNewCollection').initializeOrderedBulkOp();

    bulk.find({ foo: 'bar' }).upsert().updateOne({
      $setOnInsert: { count: 0 },
      $inc: { count: 0 }
    });

    let result = await bulk.execute();
    console.log(JSON.stringify(result,undefined,2));

  } catch(e) {
    console.error(e);
  } finally {
    db.close();
  }

})();

完全没问题，但是当然存在这样的问题：在没有Bulk API支持的情况下，无法在服务器实现上自然退步，而是改用传统API方法。

手动包装承诺

(async () => {

  let db = await require('mongodb').MongoClient.connect('mongodb://localhost:27017/myNewDb');

  let mongoOps = [{
    updateOne: {
      filter: { foo: "bar" },
      update: {
        $setOnInsert: { count:0 },
        $inc: { count:1 },
      },
      upsert: true,
    }
  }];

  try {
    let result = await new Promise((resolve,reject) => {

      db.collection("myNewCollection").bulkWrite(mongoOps, (err,r) => {
        if (err) reject(err);
        resolve(r);
      });
    });
    console.log(JSON.stringify(result,undefined,2));
    console.log("Success!");
  } catch(e) {
    console.log("Failed:");
    console.log(e);
  }

})();

如前所述，问题在于如何bulkWrite()以a形式返回Promise。因此，您可以使用该callback()表单进行编码并自行Promise包装，以按照您的期望进行操作。

再次指出，需要JIRA问题和Triage，这是处理异常的正确方法。但希望很快能解决。同时，从上方选择一种方法。