node.js - 如何重试mongodb事务？

Question

我有两个不同的 API 端点，它们更新集合的相同字段(用户集合的钱包字段)。在这两个 API 中，事务都是使用 mongoose 实现的。当我同时击中两个端点时，一个端点成功执行，另一个端点出现“WriteConflict”错误，标签为“TransientTransactionError”。

我在 MongoDB 文档中读到它提供了有关“TransientTransactionError”错误的事务重试功能。所以，当我遇到这种错误时，请建议如何重试交易。

当我同时使用不同端点更新同一个文档时，我收到此错误。

MongoError: WriteConflict
    at Connection.<anonymous> (/Users/node_modules/mongodb-core/lib/connection/pool.js:443:61)
    at Connection.emit (events.js:196:13)
    at Connection.EventEmitter.emit (domain.js:471:20)
    at processMessage (/Users/node_modules/mongodb-core/lib/connection/connection.js:364:10)
    at TLSSocket.<anonymous> (/Users/node_modules/mongodb-core/lib/connection/connection.js:533:15)
    at TLSSocket.emit (events.js:196:13)
    at TLSSocket.EventEmitter.emit (domain.js:471:20)
    at addChunk (_stream_readable.js:290:12)
    at readableAddChunk (_stream_readable.js:271:11)
    at TLSSocket.Readable.push (_stream_readable.js:226:10)
    at TLSWrap.onStreamRead (internal/stream_base_commons.js:166:17) {
  errorLabels: [ 'TransientTransactionError' ],
  operationTime: Timestamp { _bsontype: 'Timestamp', low_: 2, high_: 1591772061 },
  ok: 0,
  errmsg: 'WriteConflict',
  code: 112,
  codeName: 'WriteConflict',
  '$clusterTime': {
    clusterTime: Timestamp { _bsontype: 'Timestamp', low_: 2, high_: 1591772061 },
    signature: { hash: [Binary], keyId: [Long] }
  },
  name: 'MongoError',
  [Symbol(mongoErrorContextSymbol)]: {}
}

提前致谢

Answer 1

文档 provides examples如何正确使用事务。单击“nodejs”以查看 Node 示例。
withTransaction驱动程序中的函数实现了重试功能。