MongoDB Aggregations Limit Lookup

Question

Ich benutze $ lookup in PyMongo, um zwei Sammlungen erfolgreich "beizutreten" (das funktioniert). Ich habe ein Problem, bei dem die zweite Sammlung, der ich beitrete, die BSON-Dokumentgröße überschreiten kann, wenn alle Datensätze zurückgegeben werden.

Suche $ limit zu verwenden, um die Anzahl der Datensätze zu beschränken, die unter „match_docs“ zB dürfen teilnehmen: 100 Datensätze maximal aus „Kommentare“ pro OBJ_ID:

db.indicators.aggregate([ 
    { 
    "$lookup": { 
     "from": "comments", 
     "localField": "_id", 
     "foreignField": "obj_id", 
     "as": "match_docs" 
    } 
    } 
]) 

Ich habe versucht, verschiedene Arten von $ limit, und es scheint nur die Gesamtzahl der Ergebnisse insgesamt zu begrenzen, nicht nur für den Beitritt.

Answer 1

Wenn Sie ein $unwind sofort tun, um ein $lookup folgenden wird die Pipeline optimiert werden, grundsätzlich die 2 Stufen Kombination hilft, die 16MB Grenze zu umgehen, die von den $lookup Rückkehr eine große Anzahl von Dokumenten führen könnten.

Beachten Sie, dass diese Optimierung nicht helfen kann, wenn ein einzelnes Dokument in der Fremdsammlung plus die Größe des Dokuments in der lokalen Sammlung 16 MB überschreitet.

Answer 2

Ich konnte es herausfinden.

$ Lookup -> $ Spiel -> $ Projekt

db.indicators.aggregate([{ 
    "$lookup": { 
     "from": "comments" 
     , "localField": "_id" 
     , "foreignField": "obj_id" 
     , "as": "match_docs" 
    } 
}, { 
    "$match": { 
     "match_docs": { 
      "$exists": True 
     } 
    } 
}, { 
    "$project": { 
     "match_docs_agg": { 
      "$slice": ["$match_docs", 3] 
     } 
    } 
}])