我在使用应该查找重复项的 mongodb 函数时遇到问题

Question

我有以下函数，它应该根据电子邮件键返回重复项的 _id 值。但是，无论我尝试了什么，我都无法让函数返回任何空对象以外的任何内容。我在这里想念什么？还是有更好的方法我应该考虑？

var duplicates = [];
db.medicallists
  .aggregate([
    {
      $group: {
        _id: {
          email: "$email"
        },
        duplicate_ids: { $addToSet: "$_id" },
        count: { $sum: 1 }
      }
    },
    {
      $match: {
        count: { $gt: 1 }
      }
    },
    
  ], { allowDiskUse: true })
  .forEach(function(doc) {
    doc.duplicate_ids.shift(); // First element skipped for deleting
    doc.duplicate_ids.forEach(function(dupId) {
      duplicates.push(dupId); // Getting all duplicate ids
    });
  });
printjson(duplicates);

编辑： 这是一个示例文档：

{
_id : 5a2fed0c8023cf7ea2346067,
primary_spec : "Addiction Medicine",
first_name : "John",
last_name : "Sample",
city : "Las Vegas",
state : "NV",
phone : "1111111111",
fax : "1111111111",
email : "sample@aol.com"
}

Answer 1

我已经在类似的数据集上测试了您的特定查询，它工作正常。 printjson(duplicates); 打印出所有重复的 id。

事实上，这也会删除所有基于电子邮件的重复条目：

db.collection.aggregate([
  {
    $group: {
      _id: {
        email: "$email"
      },
      duplicate_ids: {
        $push: "$_id"
      },
      count: {
        $sum: 1
      }
    }
  },
  {
    $match: {
      count: {
        $gt: 1
      }
    }
  },
  
]).forEach(function(doc){
  doc.duplicate_ids.shift();
  db.collection.remove({
    _id: {
      $in: doc.duplicate_ids
    }
  });
})

我的起始设置是：

{
        "_id" : ObjectId("6014331de1ef9ab1f708ddd9"),
        "item" : "card",
        "email" : "zzz@yahoo.com"
}
{
        "_id" : ObjectId("6014331de1ef9ab1f708ddda"),
        "item" : "card",
        "email" : "eee@yahoo.com"
}
{
        "_id" : ObjectId("6014331de1ef9ab1f708dddb"),
        "item" : "card",
        "email" : "zzz@yahoo.com"
}
{
        "_id" : ObjectId("6014331de1ef9ab1f708dddc"),
        "item" : "card",
        "email" : "aaa@yahoo.com"
}

运行查询后，变成：

{
        "_id" : ObjectId("6014331de1ef9ab1f708ddd9"),
        "item" : "card",
        "email" : "zzz@yahoo.com"
}
{
        "_id" : ObjectId("6014331de1ef9ab1f708ddda"),
        "item" : "card",
        "email" : "eee@yahoo.com"
}
{
        "_id" : ObjectId("6014331de1ef9ab1f708dddc"),
        "item" : "card",
        "email" : "aaa@yahoo.com"
}

在 MongoDB 服务器版本上测试：4.2.7