我试图在SQS队列的消费者中实现序列化，SQS队列在多个nodeJs示例中运行。也就是说，我试图做的是确保内容以相同的顺序完成，一次一件事。我最初的想法是在documentDb（mongo）中放置某种可能使用锁文档的信号量机制，这是服务的主存储库，通过使用变更流机制等待对该文档的更改。每个示例都有自己的标识符，锁文件将包含拥有锁的人的ID。不确定这是否是最好的方法，所以我想问，是否有更好的方法来实现这一点？或者稍微修改一下就可以了？我主要担心的是可能会挨饿的情况，这将违背所有这一切的目的，也可以放置一个顺序计数器，每个示例跟踪它们在顺序中的距离，并且当它们试图获取锁时，它们可以将它们的顺序计数器与锁上有什么，如果他们落后了，就会继续等待。虽然这看起来很脆弱，如果一个示例没有完成序列步骤就死亡了，可能会拖延一切。有什么想法吗？
代码看起来像这样

const LockSchema = new Schema({
  id: String,
  owner: String,
  createdAt: { type: Date, required: true, default: Date.now },
});

LockSchema.index({ createdAt: 1 }, { expireAfterSeconds: 600 });

const Lock = mongoose.model("queue-lock", LockSchema, "locks");

const filter = [{
    $match: {
            { operationType: "delete" }
        }
    }];

const options = { fullDocument: 'updateLookup' };

let lockStream = Lock.watch(filter, options)

lockStream.on('change', event => {
  if (!event.fullDocument) {// deleted
    result = await Lock.findOneAndUpdate(
      { id: "migration-lock" },
      { $setOnInsert: { owner: whoAmI } },
      { upsert: true, new: true }
    ).lean();
    if (result.owner === whoAmI) {
      // proud owner of lock, do stuff
      await Lock.deleteOne({ id: "queue-lock" }); // when done

    } else {
      // keep waiting
    }
  }

});

字符串