mongodb aggregation framework-Gruppe + Projekt

fand die Antwort

1. ersten ich brauche, um all die _ids

db.items.aggregate( [ 
  { '$match': { 'owner.id': '9e748c81-0f71-4eda-a710-576314ef3fa' } },
  { '$group': { _id: '$item.id', dbid: { $max: "$_id" } } } 
]);

2. dann brauche ich für die Abfrage der Dokumente

db.items.find({ _id: { '$in': "IDs returned from aggregate" } });

welche wie folgt aussieht:

db.items.find({ _id: { '$in': [ '1', '2', '3' ] } });

Nicht alle Akkus sind verfügbar in $project Bühne. Wir müssen überlegen, was wir tun können, im Projekt mit Bezug zu Akkumulatoren und was können wir tun in der Gruppe. Lassen Sie uns nehmen einen Blick auf diese:

db.companies.aggregate([{
  $match: {
    funding_rounds: {
      $ne: []
    }
  }
}, {
  $unwind: "$funding_rounds"
}, {
  $sort: {
    "funding_rounds.funded_year": 1,
    "funding_rounds.funded_month": 1,
    "funding_rounds.funded_day": 1
  }
}, {
  $group: {
    _id: {
      company: "$name"
    },
    funding: {
      $push: {
        amount: "$funding_rounds.raised_amount",
        year: "$funding_rounds.funded_year"
      }
    }
  }
}, ]).pretty()

Wo wir prüfen, wenn eine der funding_rounds ist nicht leer. Dann ist es unwind-ed $sort und zu den späteren Phasen. Wir werden sehen, ein Dokument für jedes element der funding_rounds array für jedes Unternehmen. Also, das erste, was wir hier tun, ist $sort basierend auf:

1. funding_rounds.funded_year
2. funding_rounds.funded_month
3. funding_rounds.funded_day

In der Gruppenphase, die von name des Unternehmens, das array wird immer gebaut mit $push. $push ist eigentlich ein Teil eines Dokuments als der angegebene Wert für ein Feld, das wir den Namen in einer Gruppenphase. Wir schieben Sie auf jeder gültige Ausdruck sein. In diesem Fall sind wir drängen auf Dokumente, die auf dieses array und für jedes Dokument, das schieben wir es Hinzugefügt, um das Ende des Arrays, die wir ansammeln. In diesem Fall sind wir drängen auf Dokumente, die von der gebaut raised_amount und funded_year. So, die $group Bühne ist ein Strom von Dokumenten, haben eine _id wo wir die Angabe der Namen des Unternehmens.

Beachten Sie, dass $push ist in $group Stadien, aber nicht in $project Bühne. Dies ist, weil $group Stufen sind entwickelt, um eine Sequenz von Dokumenten und sammeln Werte, basierend auf dem stream von Dokumenten.

$project auf der anderen Seite, arbeitet mit einem Dokument zu einem Zeitpunkt. Also, wir können berechnen, durchschnittlich auf ein array innerhalb eines einzelnen Dokuments innerhalb einer Projektphase. Aber etwas wie das zu tun, wo man gleichzeitig sehen wir Dokumente und für jedes Dokument, übergibt es durch die Gruppenphase schaffen, drängen auf einen neuen Wert, gut, dass ist etwas, dass die $project Bühne ist nicht nur entworfen, um zu tun. Für diese Art der operation wollen wir mit $group.

Lassen Sie uns einen Blick auf ein anderes Beispiel:

db.companies.aggregate([{
  $match: {
    funding_rounds: {
      $exists: true,
      $ne: []
    }
  }
}, {
  $unwind: "$funding_rounds"
}, {
  $sort: {
    "funding_rounds.funded_year": 1,
    "funding_rounds.funded_month": 1,
    "funding_rounds.funded_day": 1
  }
}, {
  $group: {
    _id: {
      company: "$name"
    },
    first_round: {
      $first: "$funding_rounds"
    },
    last_round: {
      $last: "$funding_rounds"
    },
    num_rounds: {
      $sum: 1
    },
    total_raised: {
      $sum: "$funding_rounds.raised_amount"
    }
  }
}, {
  $project: {
    _id: 0,
    company: "$_id.company",
    first_round: {
      amount: "$first_round.raised_amount",
      article: "$first_round.source_url",
      year: "$first_round.funded_year"
    },
    last_round: {
      amount: "$last_round.raised_amount",
      article: "$last_round.source_url",
      year: "$last_round.funded_year"
    },
    num_rounds: 1,
    total_raised: 1,
  }
}, {
  $sort: {
    total_raised: -1
  }
}]).pretty()

In der $group Bühne, wir sind mit $first und $last Akkumulatoren. Rechts, wieder können wir sehen, dass, wie mit $push - wir können nicht $first und $last im Projekt-Phasen. Da wieder -, Projekt-Phasen sind nicht entworfen, um zu sammeln Werte, die sich aus mehreren Dokumenten. Vielmehr sind Sie entwickelt, um Form Dokumente ein zu einer Zeit. Gesamt-Runden-Zahl wird berechnet, indem die $sum Betreiber. Der Wert 1 einfach zählt die Anzahl der Dokumente Durchlaufen, die Gruppe zusammen mit jedem Dokument entspricht oder gruppiert unter einem bestimmten _id Wert. Das Projekt kann kompliziert erscheinen, aber es ist nur die Ausgabe ziemlich. Es ist nur so, dass es einschließlich num_rounds und total_raised aus dem vorherigen Dokument.