Python MongoDB聚合按_id删除文档

Question

嗯，我正在使用 python 和 MongoDB，但我在聚合方面遇到了很多问题。

我的主要收藏有这种结构

{
"_id": {
    "$oid": "5bef5692d0c24110b0004671"
},
"dateAdded": {
    "$date": "2018-10-16T23:45:22.974Z"
},
"phoneNumber": "xxxxxxxx",
"phoneType": "pay",
"duration": 0,
"apiCallsCount": 3,
"tenant": {
    "$oid": "5b3fd3f99a8f4e04900c4e17"
},
"sessionStatus": "EXPIRED"

}

我的第二个收藏有这个结构

{
    "_id": {
        "$oid": "5bf46869d0c2410decc4e050"
    },
    "dateAdded": {
        "$date": "2018-11-20T20:02:49.281Z"
    },
    "resolutionStatus": "Complete",
    "finalResult": "OK",
    "intention": "Query_one",
    "call": {
        "$oid": "5bef5692d0c24110b0004671"
    },
    "duration": 0,
    "dateExpired": {
        "$date": "2018-11-20T20:04:01.732Z"
    },
    "queryType": "phone",
    "tenant": {
        "$oid": "5b3fd3f99a8f4e04900c4e17"
    }
}

首先，我需要在特定日期之前从第一个集合中获取所有文档，接下来使用 _id 获取所有这些文档，我需要获取第二个集合中的所有文档（第一个集合中的 _id 与调用第二个集合）并将其从集合中删除。

我认为我需要查找，我的聚合看起来像这样，但不起作用。我不知道我需要什么来解决这个问题。

self.db.get_collection(first_collection).aggregate([
   {
      $lookup:
         {
              from: second_collection,
              localField: "_id",
              foreignField: "call",
              as: "inventory_docs"
          }
   }
])

Answer 1

聚合大量用于读取，但很少用于写入。因此，聚合$out 和$merge 中只有两个阶段能够将数据写入数据库 - 这在您的情况下没有用，尽管它们可能比使用普通.find() 和执行此操作不可行.deleteMany().

你可以分两步完成，试试下面的基本代码：

1) 首先从first_collection 中获取要从second_collection 中删除的所有文档中的_id。

ids = list(self.db.get_collection(first_collection).find({dateAdded : {$lte : inputDate }},{ _id :1 })) // Use `$lte` or `$lt`.

2) 从second_collection 中删除所有文档，其中call 字段的值存在于上述步骤中返回的任何ids 中：

from bson.objectid import ObjectId

if ids:  /** Checking to only execute this deletion operation when ids is not empty */
   convertedIds = [] // From Step 1, `ids` is an arrays of strings, We need to convert back to type `ObjectId()`'s to match with `call` field in DB.
   for id in ids:
       convertedIds.append(ObjectId(id))
   deletedDocs = self.db.get_collection(second_collection).delete_many({ call : {$in : convertedIds }});
   print(deletedDocs.deleted_count) // Just give no.of docs deleted

以防万一您想退回已删除的文档，请尝试使用 .findAndModify() 而不是 .deleteMany()。我认为 pymongo 的 .findAndModify() 相当于 .find_and_modify() 已被弃用，您可能需要使用 .find_one_delete() 但为了使用它，您不能将数组传递给过滤器中的 call 字段，如上：@ 987654342@。因此，您需要在 ids 上进行迭代并执行 { call : id } - 但这会导致多次删除数据库调用 - 我不想这样做并且会坚持使用 .delete_many()，除非我真的需要返回已删除的文档信息。

参考： .delete_many(), .find_one_and_delete() & $in