MongoDB 4.0.3批量更新$cond存储报错及discount计算优化需求

报错原因 #

你在$set里直接用聚合表达式（$cond、$arrayElemAt）给discount赋值，但MongoDB 4.0的传统更新语法不允许这种操作——它会把带$前缀的$cond当成要存储的字段名，而非聚合操作符，因此触发MongoBulkWriteError。

解决方案 #

改用聚合管道式更新，MongoDB 4.0支持将聚合管道作为updateOne的参数，这样就能在更新时引用文档现有字段完成计算，同时保持批量操作的低成本高效性。

修正后的代码如下：

bulk.find({ productUrl: p.productUrl })
  .upsert()
  .updateOne([
    {
      $set: {
        productDescription: p.productDescription,
        productName: p.productName,
        slug: slugify(p.productName, {
          lower: true,
          strict: true,
        }),
        // 按规则计算discount字段
        discount: {
          $cond: [
            // 处理price数组为空或只有1个元素的情况
            { $lte: [{ $size: { $ifNull: ["$price", []] } }, 1] },
            null,
            {
              $cond: [
                // 新价格小于数组最后一个价格时计算比值
                { $lt: [p.productPrice, { $arrayElemAt: ["$price.value", -1] }] },
                { $divide: [p.productPrice, { $arrayElemAt: ["$price.value", -1] }] },
                0
              ]
            }
          ]
        },
        // 模拟$setOnInsert逻辑：仅插入新文档时设置默认值
        views: { $cond: ["$isInserted", 0, "$views"] },
        added: { $cond: ["$isInserted", new Date(), "$added"] }
      }
    },
    // 推送新价格到price数组
    {
      $push: {
        price: { value: p.productPrice, date: new Date() }
      }
    }
  ]);

关键说明 #

1. 用聚合管道数组替代传统更新文档，让$cond、$arrayElemAt被当作聚合操作符执行，而非存储字段。
2. 用$ifNull处理新文档（无price字段）的情况，避免$size运算报错。
3. 通过$isInserted变量区分更新/插入操作，实现原$setOnInsert的默认值设置逻辑。
4. 该方案兼容MongoDB 4.0.3版本，批量处理10万条数据的性能符合低成本要求。

内容的提问来源于stack exchange，提问作者Jedi Schmedi