$ push不支持猫鼬批量操作

Question

我正在使用Mongoose中的批量操作以并发方式更新多个文档。

更新数据如下所示：

let docUpdates = [
    {
        id : docId1,
        status : "created",
        $push : {
            updates : {
                status: "created",
                referenceId : referenceId,
                createdTimestamp : "2022-06-14T00:00:00.000Z"
            }
        }
    },
    {
        id : docId2,
        status : "completed",
        $push : {
            updates : {
                status: "compelted",
                referenceId : referenceId,
                createdTimestamp : "2022-06-14T00:00:00.000Z"
            }
        }
    },
];

// Update documents using bulk operation
let bulkUpdate = Model.collection.initializeOrderedBulkOp();

for (let i = 0; i < docUpdates.length; i++) {
    bulkUpdate.find({_id : docUpdates[i].docId}).updateOne({ $set : docUpdates[i]})
}

当我执行上述片段时，我会收到以下错误。

(node:468) UnhandledPromiseRejectionWarning: MongoBulkWriteError: The dollar ($) prefixed field '$push' in '$push' is not allowed in the context of an update's replacement document. Consider using an aggregation pipeline with $replaceWith.
    at OrderedBulkOperation.handleWriteError (/usr/src/app/node_modules/mongoose/node_modules/mongodb/lib/bulk/common.js:884:22)

您能帮助您找到解决此错误的工作。

谢谢，
KK

Answer 1

问题不是不支持$ push，而是您通过更新文档中的参数的方式，它被解释为顶级字段。请参阅有关字段名称注意事项，特别是修改更新的文档。

您的代码updateOne（{$ set：docupdates [i]}）等同于以下内容：

updateOne({
  $set: {
    id: docId1,
    status: "created",
    $push: {
      updates: {
        status: "created",
        referenceId: referenceId,
        createdTimestamp: "2022-06-14T00:00:00.000Z"
      }
    }
  }
})

因为$ push ，您正在告诉MongoDB将名为$ push的字段设置为带有名为更新的字段的字段，该字段具有status /code>，<代码> ReferenceId 和CreateTimestamp字段。

您想做的是用两个不同的更新运算符指定更新文档。换句话说，$ push需要与$ set处于同一级别。

类似：

updateOne({
  $set: {
    id: docId1,
    status: "created"
  },
  $push: {
    updates: {
      status: "created",
      referenceId: referenceId,
      createdTimestamp: "2022-06-14T00:00:00.000Z"
    }
  }
})

如何在docupdates数组中表示。也许您可以做类似的事情：

let docUpdates = [
    {
        id : docId1,
        update : {
            $set : {
               status : "created"
            },
            $push : {
                updates : {
                    status: "created",
                    referenceId : referenceId,
                    createdTimestamp : "2022-06-14T00:00:00.000Z"
                }
            }
        }
    }
    // ... Other updates
]

并在循环中使用它：

bulkUpdate.find({_id : docUpdates[i].docId}).updateOne(docUpdates[i].update)