MongoDBの集計フィルタと、私は私が欲しい集計クエリを実行する必要がありnodejs

Question

私は、このコレクションが命名した「ポイント」

[ 
    { 'guid': 'aaa' }, 
    { 'guid': 'bbb' }, 
    { 'guid': 'ccc' }, 
] 

を頼りに、私は別の名前の「ストリーム」

[ 
    { 'title': 'pippo', 'guid': 'aaa', 'email': 'pippo@disney'}, 
    { 'title': 'pluto', 'guid': 'aaa', 'email': 'pluto@disney'}, 
    { 'title': 'goofy', 'guid': 'bbb', 'email': 'goofy@disney'}, 
    { 'title': 'duck', 'guid': 'aaa', 'email': 'duck@disney'}, 
    { 'title': 'minnie', 'guid': 'ccc', 'email': 'minnie@disney'}, 
] 

を持っています文字「o」を含むemailを検索します。私はすでにこの

db.getCollection('points').aggregate([ 
    { 
     $lookup: { 
      from: "stream", 
      localField: "guid", 
      foreignField: "guid", 
      as: "items" 
     } 
    }, 
    { 
     $project: { 
      _id: 0, 
      guid: 1, 
      items: { 
       $size: "$items" 
      } 
     } 
    } 
]); 

を行っている私は期待した結果がこの

[ 
    { 'guid': 'aaa', items: 2 }, 
    { 'guid': 'bbb', item: 1 }, 
    { 'guid': 'ccc', item: 0 }, 
] 

である私は、MySQLにあった場合は、クエリは、この

SELECT DISTINCT 
    points.guid, 
    (
     SELECT COUNT(*) 
     FROM stream 
     WHERE guid = stream.guid and stream.email like '%o%' 
    ) AS items 
FROM points 

Answer 1

回答はコメントに基づいて編集されます。

次のアグリゲーションパイプラインを試すことができます。

db.getCollection("points").aggregate([ 
         {"$lookup":{"from":"stream", "localField":"guid", "foreignField":"guid", as:"items"}}, 
         {"$unwind":"$items"}, 
         {"$group":{"_id": "$guid", "guid":{"$first":"$guid"}, "emails":{"$push":"$items.email"}}}, 
         {"$project":{"guid" :1, "emails":{"$setUnion":["$emails", [{"$literal":"io"}]]}}}, 
         {"$unwind":"$emails"}, 
         {"$match":{"emails":/[io]/}}, 
         {"$group":{"_id":"$guid", "items":{"$sum":1}}}, 
         {"$project":{"_id":0, "guid":"$_id", "items":{"$add":["$items", -1]}}} 
        ]) 

サンプル出力：

{ "items" : 3, "guid" : "aaa" } 
{ "items" : 1, "guid" : "ccc" } 
{ "items" : 1, "guid" : "bbb" } 

注：私はダミーの電子メールIDを導入している - 'OI'、条件に合致する満たす、ポイント収集からのデータが失われないようにすること。そして、このダミーフィールドを補償するために、-1が最終的にカウントから減じられる。