ClientSession 无法序列化为 BSON - Mongodb Transaction答案

【问题标题】：ClientSession cannot be serialized to BSON - Mongodb TransactionClientSession 无法序列化为 BSON - Mongodb Transaction
【发布时间】：2022-01-24 08:55:13
【问题描述】：

我对 mongodb 事务还很陌生，所以我不知道我做错了什么。我已按照文档中的说明进行操作，但仍然出现此错误

{
"status": 400,
"name": "Error",
"message": "ClientSession cannot be serialized to BSON."
}

这是我的代码

    async createInsurance(params) {
    const session = await db99.startSession();
    try {
      session.startTransaction();
      const doc = await db.insurance
        .find({ session })
        .sort({ createdAt: -1 })
        .limit(1)
        .lean();
      const latest = doc[0];
      const payload = { ...params, id: latest ? latest.id + 1 : 1 };
      const data = await db.insurance.create(payload, { session });

      await mongoTransaction.commitWithRetry(session);
      const result = defaultResult('SuccessCreateInsurance', SuccessCreateInsurance[this.lang], data, 200);
      return result;
    } catch (error) {
      logger.log('error', 'ProductService-createInsurance', { error });
      throw error;
    } finally {
      await session.endSession();
    }
  }

有什么我错过的吗？

【问题讨论】：

是否有.create 收集方法？我知道.insertOne 和.insertMany 都采用第二个参数，即options。你试过那个吗？ mongodb.github.io/node-mongodb-native/4.2/interfaces/…mongodb.github.io/node-mongodb-native/4.2/interfaces/…
@TamilVendhanKanagarasu 我认为这不是问题，因为错误在 .find 方法上仍然存在（我也尝试了 findOne，但没有用）
你使用的是原生驱动还是像mongoose这样的ORM？对于.findOne、.find等，必须在第三个参数中传递会话属性。

标签： node.js mongodb

【解决方案1】：

Model.create 的文档表明必须以数组的形式传递文档才能指定选项：

[options] «Object» 选项传递给 save()。要指定选项，文档必须是数组，而不是展开。

改变

const payload = { ...params, id: latest ? latest.id + 1 : 1 };

到

const payload = [{ ...params, id: latest ? latest.id + 1 : 1 }];

【讨论】：

【解决方案2】：

原来我必须在 find 方法的第三个参数上传递 session 并将有效负载包装为 create 方法的数组，因为它只能采用数组。代码将如下所示

async createInsurance(params) {
    const session = await db99.startSession();
    session.startTransaction();
    try {
      const doc = await db.insurance
        .findOne(null, null, { session })
        .sort({ createdAt: -1 })
        .limit(1)
        .lean();
      const latest = doc[0];
      const payload = { ...params, id: latest ? latest.id + 1 : 1 };
      const data = await db.insurance.create([payload], { session });

      await session.commitTransaction();
      const result = defaultResult('SuccessCreateInsurance', SuccessCreateInsurance[this.lang], data, 200);
      return result;
    } catch (error) {
      await session.abortTransaction();
      logger.log('error', 'ProductService-createInsurance', { error });
      throw error;
    } finally {
      await session.endSession();
    }
  }

【讨论】：