Wie kann ich anfügen, Mongo DB aggregation der Ergebnisse zu einer bestehenden Sammlung?

Ich versuche mehrere Insertionen auf ein existierendes Mongo-DB-Sammlung mit dem folgenden code

db.dados_meteo.aggregate( [
                  { $match : { "POM" : "AguiardaBeira" } },
                  { $project : {
                     _id : { $concat: [
                        "0001:",
                      { $substr: [ "$DTM", 0, 4 ] },
                      { $substr: [ "$DTM", 5, 2 ] },
                      { $substr: [ "$DTM", 8, 2 ] },
                      { $substr: [ "$DTM", 11, 2 ] },
                      { $substr: [ "$DTM", 14, 2 ] },
                      { $substr: [ "$DTM", 17, 2 ] }
                       ] },
                    "RNF" : 1, "WET":1,"HMD":1,"TMP":1 } },
                  { $out : "dados_meteo_reloaded" }
              ] )

Aber jedes mal, wenn ich die $match-Parameter und stellen Sie eine neue aggregation, Mongo DB löscht die bisherigen Dokumente und fügt die neuen Ergebnis.

Könnten Sie mir helfen?

InformationsquelleAutor Hugo | 2015-02-26
  1. 8

    Die kurze Antwort ist: "Sie können nicht":

    Wenn die Sammlung angegeben, indem das $out Betrieb bereits existiert, dann wird nach Abschluss der aggregation, die $Stadium der atomar ersetzt die bestehende Kollektion mit den neuen Ergebnissen Sammlung. Die $operation ändert nicht alle Indizes, die gab es auf der vorherigen Kollektion. Wenn die aggregation fehl, ist der $die operation lässt keine änderungen zu der bereits bestehenden Sammlung.

    Als Problemumgehung können Sie die Kopie der Sammlung angegebene Dokument $out zu einer "ständigen" Sammlung nur nach der aggregation, die in einer mehrere Möglichkeiten (nicht die ist ideal, wenn):

    • copyTo() ist die einfachste, Verstand die Warnung. Verwenden Sie nicht andere für kleine Ergebnisse.
    • Verwenden JS: db.out.find().forEach(function(doc) {db.target.insert(doc)})
    • Verwenden mongoexport /mongoimport
    • kann nicht glauben, dass Sie nicht haben, eine Möglichkeit zum Anhängen. und das ist ein db, der hat Millionen in die Finanzierung? erbärmlich.
    • Ori, deine Antwort sieht gut aus. möglicherweise werden Sie wollen, um es zu Bearbeiten, und fügen Sie diese option aus, stackoverflow.com/a/37433640/2834978. db.col1.insert(db.col2.Aggregat(...).toArray())
    InformationsquelleAutor Ori Dar
  2. 5

    Ab Mongo 4.2 die neue $merge aggregation operator (ähnlich wie $out) ermöglicht Zusammenführen das Ergebnis einer aggregation pipeline in der angegebenen Sammlung:

    Angesichts dieser input:

    db.source.insert([
  { "_id": "id_1", "a": 34 },
  { "_id": "id_3", "a": 38 },
  { "_id": "id_4", "a": 54 }
])
db.target.insert([
  { "_id": "id_1", "a": 12 },
  { "_id": "id_2", "a": 54 }
])

    den $merge aggregation der Bühne kann als solches verwendet werden:

    db.source.aggregate([
  //{ $whatever aggregation stage, for this example, we just keep records as is }
  { $merge: { into: "target" } }
])

    produzieren:

    //> db.target.find()
{ "_id" : "id_1", "a" : 34 }
{ "_id" : "id_2", "a" : 54 }
{ "_id" : "id_3", "a" : 38 }
{ "_id" : "id_4", "a" : 54 }

    Beachten Sie, dass die $merge Betreiber kommt mit viele Optionen um festzulegen, wie die Zusammenführung eingefügten Datensätze in Konflikt mit vorhandenen Datensätzen.

    In diesem Fall (mit den default-Optionen), diese:

    • hält die Ziel-Auflistung der vorhandenen Dokumente (dies ist der Fall von { "_id": "id_2", "a": 54 })

    • fügt Dokumente aus der Ausgabe der aggregation pipeline in die Ziel-Sammlung, wenn Sie nicht bereits vorhanden (auf der Grundlage der _id - dies ist der Fall von { "_id" : "id_3", "a" : 38 })

    • ersetzt die Ziel-Auflistung der Datensätze, wenn die aggregation pipeline erzeugt Dokumente in die bestehenden Ziel-Auflistung (auf der Grundlage der _id - dies ist der Fall von { "_id": "id_1", "a": 12 } ersetzt durch { "_id" : "id_1", "a" : 34 })

    InformationsquelleAutor Xavier Guihot
  3. 1

    Es ist nicht die schönste Sache überhaupt, aber als eine alternative syntax (von einem post-processing-Archiv/anfügen)...

    JS:

    db.targetCollection.insertMany(db.runCommand(
{
    aggregate: "sourceCollection",
    pipeline: 
    [
        { $skip: 0 },
        { $limit: 5 },
        { 
            $project:
            {
                myObject: "$$ROOT",
                processedDate: { $add: [new ISODate(), 0] }
            }
        }
    ]
}).result)

    Ich bin mir nicht sicher, wie diese stacks gegen die forEach-Variante, aber ich finde es intuitiver zu Lesen.

    InformationsquelleAutor Jesse MacNett
Schreibe einen Kommentar