Mongodb aggregation ist $group, beschränken die Länge von array

Möchte ich der Gruppe alle Dokumente nach einem Feld, aber zum einschränken der Anzahl der Dokumente gruppiert, die für jeden Wert.

Jede Nachricht hat eine conversation_ID. Ich brauche, um die 10 oder kleinere Anzahl von Nachrichten für jeden conversation_ID.

Ich bin in der Lage, die Gruppe nach den folgenden Befehl ein, kann aber nicht herausfinden, wie die Einschränkung der
Anzahl der gruppierten Dokumente abgesehen von slicing-die Ergebnisse
Message.aggregate({'$group':{_id:'$conversation_ID',msgs:{'$push':{msgid:'$_id'}}}})

Wie begrenzen Sie die Länge der Nachrichten-array für jedes conversation_ID 10?

  • Viel curlier Frage, als Sie vielleicht denken. Die große Sache ist SERVER-6074 und ähnlichen Themen. Das aggregation framework nicht unterstützt $slice oder Operationen zu "begrenzen" die Elemente geschoben. Aber es ist möglich, einfach nur schrecklich.
  • Nur stubmled auf SERVER-6074 nach ein bisschen googeln. So jetzt manuelle schneiden ist die einzige Möglichkeit?
  • Nicht nur - option. Wie gesagt, großes Thema, so dauert es ein wenig zu erklären, den Prozess. Es wäre schön, wenn andere Operatoren zu tun, obwohl dies. Abstimmung für JIRA-issues
InformationsquelleAutor ma08 | 2014-06-28
  1. 0

    Das $slice-operator ist nicht eine aggregation Betreiber, so dass Sie nicht tun dies (wie ich vorgeschlagen, in dieser Antwort vor dem edit): 

    db.messages.aggregate([
   { $group : {_id:'$conversation_ID',msgs: { $push: { msgid:'$_id' }}}},
   { $project : { _id : 1, msgs : { $slice : 10 }}}]);

    Neil ' s Antwort ist sehr ausführlich, Sie können jedoch einen etwas anderen Ansatz (wenn es passend zu Ihrem Anwendungsfall). Sie insgesamt Ihre Ergebnisse und deren Ausgabe in eine neue Sammlung:

    db.messages.aggregate([
   { $group : {_id:'$conversation_ID',msgs: { $push: { msgid:'$_id' }}}},
   { $out : "msgs_agg" }
]);

    Den $out Betreiber schreiben die Ergebnisse der aggregation zu einer neuen Kollektion. Sie können dann mit einem regulären Abfrage-Projekts Ihre Ergebnisse mit den $slice-operator:

    db.msgs_agg.find({}, { msgs : { $slice : 10 }});

    Für diesen test Unterlagen:

    > db.messages.find().pretty();
{ "_id" : 1, "conversation_ID" : 123 }
{ "_id" : 2, "conversation_ID" : 123 }
{ "_id" : 3, "conversation_ID" : 123 }
{ "_id" : 4, "conversation_ID" : 123 }
{ "_id" : 5, "conversation_ID" : 123 }
{ "_id" : 7, "conversation_ID" : 1234 }
{ "_id" : 8, "conversation_ID" : 1234 }
{ "_id" : 9, "conversation_ID" : 1234 }

    Das Ergebnis wird sein:

    > db.msgs_agg.find({}, { msgs : { $slice : 10 }});
{ "_id" : 1234, "msgs" : [ { "msgid" : 7 }, { "msgid" : 8 }, { "msgid" : 9 } ] }
{ "_id" : 123, "msgs" : [ { "msgid" : 1 }, { "msgid" : 2 }, { "msgid" : 3 }, 
                          { "msgid" : 4 }, { "msgid" : 5 } ] }

    Bearbeiten

    Ich nehme an, dies würde bedeuten das duplizieren des gesamten Nachrichten-Auflistung.
    Ist das nicht overkill?

    Gut, offensichtlich ist dieser Ansatz nicht Maßstab mit riesigen Sammlungen. Aber, da Sie erwägen, die Verwendung von großen aggregation von Rohrleitungen oder großen map-reduce jobs, die Sie wahrscheinlich nicht verwenden diese für "real-time" Anforderungen.

    Gibt es viele Nachteile dieses Ansatzes: 16 MB BSON begrenzen, wenn Sie große Dokumente mit aggregation, verschwenden Speicherplatz /memory mit Vervielfältigung, erhöhte disk-IO...

    Die Vorteile dieses Ansatzes: seine einfach zu implementieren und damit leicht zu ändern. Wenn Sie Ihre Sammlung wird nur selten aktualisiert und Sie können diese "aus" - Kollektion wie ein cache. Auf diese Weise würden Sie nicht haben, führen Sie die aggregation Vorgang mehrere Male und konnte Sie dann auch unterstützen "real-time" client-Anfragen auf die "out" - Kollektion. Zum aktualisieren Ihrer Daten haben, können Sie in regelmäßigen Abständen tun, aggregation (z.B. in einem hintergrund-job, der jede Nacht läuft).

    Wie es gesagt wurde in den Kommentaren dieses ist nicht ein einfaches problem, und es ist nicht eine perfekte Lösung für dieses (noch!). Ich zeigte Sie einem anderen Ansatz, die Sie verwenden können, ist es an Ihnen, zu bewerten und zu entscheiden, was am besten geeignete für Ihren Anwendungsfall.

    • { [MongoError: exception: Ungültiger operator "$slice'] - name: "MongoError', errmsg: 'exception: Ungültiger operator '\ ' $slice\", code: 15999, "ok": 0 }, ich bin mit Mungo für nodejs. $slice scheint nicht zu funktionieren mit aggregation. Und ich will limit mongoDB zu stoppen Gruppierung nach einem bestimmten Grenzwert erreicht hat, statt des Schneidens der Ergebnisse. Gibt es eine Möglichkeit, das zu tun? Dank
    • Ich nehme an, dies würde bedeuten das duplizieren des gesamten Nachrichten-Auflistung. Ist das nicht overkill?
    • hängt davon ab, was Ihre Anforderungen sind. Siehe mein edit.
    InformationsquelleAutor Christian P
Schreibe einen Kommentar