Arrgregate $out mongodb insert for $out failed duplicate Error

Question

Query1：我试图使用 mongodb Aggregate $lookup 将两个集合与两个集合的选定字段组合如下

 db.col1.aggregate([
   {
       $lookup: {
          from: "col2",
          localField: "field1",    
          foreignField: "field2", 
          as: "user"
       }
   },
   {
       $unwind:"$user"
   },
   { $project: { "userfield": "$user.field",col1field:1 } },
  {$out:"new_col"}
 ])


**Error:**

*"errmsg" : "insert for $out failed: { connectionId: 4275, err: 'E11000 duplicate key error collection: db.tmp.agg_out.1 index: _id_ dup key: { : ObjectId('5b16305d145a5117552836ec') }', code: 11000, n: 0, ok: 1.0 }",
**"code" : 16996***

----------

Query2：在投影中我添加了 _id:0

 db.col1.aggregate([
   {
       $lookup: {
          from: "col2",
          localField: "field1",    
          foreignField: "field2", 
          as: "user"
       }
   },
   {
       $unwind:"$user"
   },
   { $project: { "userfield": "$user.field",col1field:1 ,**_id:0**} },
  {$out:"new_col"}
 ])

**Error:**
no error and no output 

Answer 1

您的$lookup 阶段只是在user 字段中返回多个条目，然后将这些条目展平为具有相同_id 值的各个子文档。您可以通过将$out 阶段替换为$match 来验证这一点：

db.col1.aggregate([{
    $match: { _id: ObjectId('5b16305d145a5117552836ec') }
}

这里的关键是了解$unwind 的工作原理。假设您有以下文档：

{
    _id: 1,
    users: [ 'a', 'b' ]
}

一旦你$unwind这个你会得到以下两个文件：

{
    _id: 1,
    users: 'a'
},
{
    _id: 1,
    users: 'b'
}

因此，对于两个不同的文档，您会得到相同的 _id 值！

现在，当您在投影中指定 _id: 0 时，您会从所有文档中删除 _id 字段，这将导致 MongoDB 自动创建新的 _ids，这当然会起作用。

Answer 2

好的，重复的 id 解释。另外，如果你想保留user._id，在你上一个项目阶段添加id:"$_id"。

但是对于 _id:0 的第二个查询，'没有错误和没有输出是什么意思：

• 如果您的查询运行良好，结果将插入一个名为“new_col”的新集合中，因此您必须运行 db.getCollection("new_col").find({});检索它们。 $out 阶段的控制台中没有任何内容！
• 如果您的 new_col 集合不存在或为空：无论 $out 阶段如何，您的查询都不会返回任何内容。在这种情况下，请提供 col1 和 col2 文档示例

---编辑--- 有了这些数据：

col1 : 
{ 
"_id" : 1.0, 
"field1" : "a", 
"field2" : "b"
}
col2 : 
{ 
"_id" : 1.0, 
"field1" : "a", 
"field2" : "c"
}

实现您需要的正确查询如下：

db.col1.aggregate(
[
    // Stage 1
    {
        $lookup: {
             from: "col2",
                  localField: "field1",    
                  foreignField: "field1", 
                  as: "user"
        }
    },
    // Stage 2
    {
        $unwind: {
            path : "$user",

        }
    },
    // Stage 3
    {
        $project: {
           "userfield": "$user.field1",field1:1
        }
    },

]
);

将输出：

{ 
    "_id" : 1.0, 
    "field1" : "a", 
    "userfield" : "a"
}