$ groupと$ pushをサブ文書に含むMongoDb集約クエリ

Question

MongoDb集約の$group引数に関する質問があります。次のように私のデータ構造が見えます：

マイ"イベント"コレクションは、この単一のドキュメントが含まれています

{ 
    "_id": ObjectId("mongodbobjectid..."), 
    "name": "Some Event", 
    "attendeeContainer": { 
     "min": 0, 
     "max": 10, 
     "attendees": [ 
      { 
       "type": 1, 
       "status": 2, 
       "contact": ObjectId("mongodbobjectidHEX1") 
      }, 
      { 
       "type": 7, 
       "status": 4, 
       "contact": ObjectId("mongodbobjectidHEX2") 
      } 
     ] 
    } 
} 

マイ"連絡先"コレクションはこれらの文書が含まれています

{ 
    "_id": ObjectId("mongodbobjectidHEX1"), 
    "name": "John Doe", 
    "age": 35 
}, 
{ 
    "_id": ObjectId("mongodbobjectidHEX2"), 
    "name": "Peter Pan", 
    "age": 60 
} 

何I "イベント"コレクションのaggregateクエリを実行し、fulを使用して次の結果を取得しますL「連絡先」データ：

"$unwind" : "$attendeeContainer.attendees", 
"$lookup" : { "from" : "contactinfo", "localField" : "attendeeContainer.attendees.contact","foreignField" : "_id", "as" : "contactInfo" }, 
"$unwind" : "$contactInfo", 
"$group" : { "_id": "$_id", 
       "name": { "$first" : "$name" }, 
       ... 
       "contact": { "$push": { "contact": "$contactInfo"} } 
      } 

しかし、これは「接触」配列は、「イベント」であることにつながる：

{ 
    "_id": ObjectId("mongodbobjectid..."), 
    "name": "Some Event", 
    "attendeeContainer": { 
     "min": 0, 
     "max": 10, 
     "attendees": [ 
      { 
       "type": 1, 
       "status": 2, 
       "contact": { 
        "_id": ObjectId("mongodbobjectidHEX1"), 
        "name": "John Doe", 
        "age": 35 
       } 
      }, 
      { 
       "type": 7, 
       "status": 4, 
       "contact": { 
        "_id": ObjectId("mongodbobjectidHEX2"), 
        "name": "Peter Pan", 
        "age": 60 
       } 
      } 
     ] 
    } 
} 

私は（短縮版）は次のようになり、今使っているの引数各「attendeeContainer.attendees」にあるアレイの1つのドキュメントではなく、（グループ化されているため） 「連絡先」配列を「attendeeContainer.attendees」にプッシュするには？私が試したようなもの

（上記所望の出力に示すように）：明らかに許可されていません

"attendeeContainer.attendees.contact": { "$push": { "contact": "$contactInfo"} } 

しかし、MongoDBのを「」 $groupステージ。

db.event.aggregate([ 
    { "$unwind": "$attendeeContainer.attendees" }, 
    { 
     "$lookup" : { 
      "from" : "contactinfo", 
      "localField" : "attendeeContainer.attendees.contact", 
      "foreignField" : "_id", 
      "as" : "attendeeContainer.attendees.contactInfo" 
     } 
    }, 
    { "$unwind": "$attendeeContainer.attendees.contactInfo" }, 
    { 
     "$group": { 
      "_id" : "$_id", 
      "name": { "$first": "$name" }, 
      "min" : { "$first": "$attendeeContainer.min" }, 
      "max" : { "$first": "$attendeeContainer.max" }, 
      "attendees": { "$push": "$attendeeContainer.attendees" }    
     } 
    }, 
    { 
     "$project": { 
      "name": 1, 
      "attendeeContainer.min": "$min", 
      "attendeeContainer.max": "$min", 
      "attendeeContainer.attendees": "$attendees" 
     } 
    } 
]) 

---

デバッグのヒント

でパイプラインをデバッグ：

Answer 1

は鍵がattendeeContainerサブドキュメントを作成するために、最終的な$projectパイプラインを使用している、以下の集約パイプラインを実行してみてください第4ステージでは、結果は

​​

パイプラインの結果

{ 
    "_id" : ObjectId("582c789282a9183adc0b53f5"), 
    "name" : "Some Event", 
    "min" : 0, 
    "max" : 10, 
    "attendees" : [ 
     { 
      "type" : 1, 
      "status" : 2, 
      "contact" : ObjectId("582c787682a9183adc0b53f3"), 
      "contactInfo" : { 
       "_id" : ObjectId("582c787682a9183adc0b53f3"), 
       "name" : "John Doe", 
       "age" : 35 
      } 
     }, 
     { 
      "type" : 7, 
      "status" : 4, 
      "contact" : ObjectId("582c787682a9183adc0b53f4"), 
      "contactInfo" : { 
       "_id" : ObjectId("582c787682a9183adc0b53f4"), 
       "name" : "Peter Pan", 
       "age" : 60 
      } 
     } 
    ] 
} 

と最終$projectパイプラインはあなたの望ましい結果が得られます：

db.event.aggregate([ 
    { "$unwind": "$attendeeContainer.attendees" }, 
    { 
     "$lookup" : { 
      "from" : "contactinfo", 
      "localField" : "attendeeContainer.attendees.contact", 
      "foreignField" : "_id", 
      "as" : "attendeeContainer.attendees.contactInfo" 
     } 
    }, 
    { "$unwind": "$attendeeContainer.attendees.contactInfo" }, 
    { 
     "$group": { 
      "_id": "$_id", 
      "name": { "$first": "$name" }, 
      "min" : { "$first": "$attendeeContainer.min" }, 
      "max" : { "$first": "$attendeeContainer.max" }, 
      "attendees": { "$push": "$attendeeContainer.attendees" }    
     } 
    }, 
    { 
     "$project": { 
      "name": 1, 
      "attendeeContainer.min": "$min", 
      "attendeeContainer.max": "$min", 
      "attendeeContainer.attendees": "$attendees" 
     } 
    }/**/ 
]) 

希望/実際の出力

{ 
    "_id" : ObjectId("582c789282a9183adc0b53f5"), 
    "name" : "Some Event", 
    "attendeeContainer" : { 
     "min" : 0, 
     "max" : 10, 
     "attendees" : [ 
      { 
       "type" : 1, 
       "status" : 2, 
       "contact" : ObjectId("582c787682a9183adc0b53f3"), 
       "contactInfo" : { 
        "_id" : ObjectId("582c787682a9183adc0b53f3"), 
        "name" : "John Doe", 
        "age" : 35 
       } 
      }, 
      { 
       "type" : 7, 
       "status" : 4, 
       "contact" : ObjectId("582c787682a9183adc0b53f4"), 
       "contactInfo" : { 
        "_id" : ObjectId("582c787682a9183adc0b53f4"), 
        "name" : "Peter Pan", 
        "age" : 60 
       } 
      } 
     ] 
    } 
}