如果不存在特定的键值，则给定数组的推送对象到MongoDB文档的数组

Question

可以说，我现在像Pymongo一样在Mongo中有一个文档

{
    name: "abc",
    manufacturer: "xyz",
    ...
    history: [
        {"condition": "new", "price": 150, "currency": "USD", "timestamp": "aaaaaaaaaaaa"}
    ]
}

，我想更新与过滤器（否则插入）匹配（否则插入）的文档，如果该字典在那里（Mongo doc的历史记录阵列）中不存在，并将每个字典推在历史记录列表中 以上查询的查询

history = [
    {"condition": "new", "price": 150, "currency": "USD", "timestamp": "bbbbbbbbbbbb"},
    {"condition": "used", "price": 90, "currency": "USD", "timestamp": "cccccccccccc"},
]
item = {
    "name": "abcd",
    "manufacture": "xyz"
}
db.collection.update_one(filter, {"$set": item, "$addToSet": {"history": {"$each": history}}}, True)

问题是我想从 $ $ addtoset 的比较中排除时间戳字段（最终将是唯一的，最终导致字典被推开），这是根据我的研究不可能的。

因此，我试图避免进行两个单独的查询（以避免绩效问题，因为我的收藏包含数百万个文档）与我相当新的聚合管道，并希望得到任何帮助。 MongoDB中更新的文档应该看起来像

{
    name: "abcd",
    manufacturer: "xyz",
    ...
    history: [
        {"condition": "new", "price": 150, "currency": "USD", "timestamp": "aaaaaaaaaaaa"},
        {"condition": "used", "price": 90, "currency": "USD", "timestamp": "cccccccccccc"}
    ]
}

Answer 1

一种选项是将Update与Pipeline一起使用，例如：

1. 添加新历史记录并创建现有历史记录的“干净”副本 - 仅包含一个使用其属性的密钥，该键使用无时间戳并可以比较。
2. 为新历史记录执行同样的操作 - 创建一个干净的密钥副本，并在当前数组中添加键。
3. 使用$ setDifference从新清洁中删除现有的历史记录密钥。
4. $ MERGE仅使用具有所有数据的新历史记录后留下的历史记录对象。
5. 清洁数据，并将现有历史记录与新历史相结合。

db.collection.update(
{name: "abcd", manufacturer: "xyz"},
[
  {
    $addFields: {
      newHistory: [
        {condition: "new", price: 150, currency: "USD", timestamp: "bbbbbbbbbbbb"},
        {condition: "used", price: 90, currency: "USD", timestamp: "cccccccccccc"}
      ],
      oldHistoryClean: {
        $map: {
          input: "$history",
          as: "item",
          in: {
            key: 
            {$concat: ["$item.condition", {$toString: "$item.price"}, "$item.currency"]}
          }
        }
      }
    }
  },
  {
    $addFields: {
      newHistoryClean: {
        $map: {
          input: "$newHistory",
          as: "item",
          in: {
            key: 
            {$concat: ["$item.condition", {$toString: "$item.price"}, "$item.currency"]}
          }
        }
      },
      newHistory: {
        $map: {
          input: "$newHistory",
          as: "item",
          in: {
            condition: "$item.condition",
            price: "$item.price",
            currency: "$item.currency",
            timestamp: "$item.timestamp",
            key: 
            {$concat: ["$item.condition", {$toString: "$item.price"}, "$item.currency"]}
          }
        }
      }
    }
  },
  {
    $set: {
      newHistoryClean: {$setDifference: ["$newHistoryClean", "$oldHistoryClean"]}
    }
  },
  {
    $set: {
      newHistoryClean: {
        $map: {
          input: "$newHistoryClean",
          in: {
            $mergeObjects: [
              "$this",
              {
                $arrayElemAt: [
                  "$newHistory",
                  {$indexOfArray: ["$newHistory.key", "$this.key"]}
                ]
              }
            ]
          }
        }
      }
    }
  },
  {
    $set: {
      newHistoryClean: {
        $map: {
          input: "$newHistoryClean",
          as: "item",
          in: {
            condition: "$item.condition",
            price: "$item.price",
            currency: "$item.currency",
            timestamp: "$item.timestamp"
          }
        }
      }
    }
  },
  {
    $project: {
      history: {$concatArrays: ["$history", "$newHistoryClean"]},
      name: 1,
      manufacturer: 1
    }
  }
],
{
  $upsert: true
})

Playground示例