Wie kann convert string to date mit mongo-aggregation?

Wie Sie erwähnt haben, müssen Sie zuerst ändern Sie das schema so, dass die created_at Feld enthält Datum-Objekte im Gegensatz zu string-wie ist die aktuelle situation, dann können Sie Abfrage Ihre Sammlung entweder über die find() - Methode oder die aggregation framework. Ersteres wäre wohl der einfachste Ansatz.

Konvertieren created_at Feld "bis Datum", benötigen Sie zum Durchlaufen der cursor wieder durch den find() Methode mit der forEach() Methode, innerhalb der Schleife umwandeln der created_at Feld, um ein Datum-Objekt und aktualisieren Sie das Feld mit der $Satz Betreiber.

Nutzen der Verwendung der Bulk-API für bulk-updates, die bieten eine bessere performance als Sie senden die Operationen auf dem server in den Reihen von sagen wir 1000, das gibt Ihnen eine bessere Leistung, wie Sie nicht senden jede Anfrage an den server, nur einmal alle 1000 Anfragen.

Folgenden veranschaulicht diesen Ansatz, der im ersten Beispiel wird der Bulk-API verfügbar in MongoDB Versionen >= 2.6 and < 3.2. Es aktualisiert alle
die Dokumente in der Kollektion durch die änderung der created_at Felder für Datum Felder:

var bulk = db.collection.initializeUnorderedBulkOp(),
    counter = 0;

db.collection.find({"created_at": {"$exists": true, "$type": 2 }}).forEach(function (doc) {
    var newDate = new Date(doc.created_at);
    bulk.find({ "_id": doc._id }).updateOne({ 
        "$set": { "created_at": newDate}
    });

    counter++;
    if (counter % 1000 == 0) {
        bulk.execute(); //Execute per 1000 operations and re-initialize every 1000 update statements
        bulk = db.collection.initializeUnorderedBulkOp();
    }
})
//Clean up remaining operations in queue
if (counter % 1000 != 0) { bulk.execute(); }

Nächsten Beispiel gilt für die neue MongoDB-version 3.2 die seit veraltet die Bulk-API und ein neuer Satz von apis, die mit bulkWrite():

var cursor = db.collection.find({"created_at": {"$exists": true, "$type": 2 }}),
    bulkOps = [];

cursor.forEach(function (doc) { 
    var newDate = new Date(doc.created_at);
    bulkOps.push(         
        { 
            "updateOne": { 
                "filter": { "_id": doc._id } ,              
                "update": { "$set": { "created_at": newDate } } 
            }         
        }           
    );   

    if (bulkOps.length === 1000) {
        db.collection.bulkWrite(bulkUpdateOps);
        bulkOps = [];
    }
});         

if (bulkOps.length > 0) { db.collection.bulkWrite(bulkOps); }

Einmal die schema-änderung ist abgeschlossen, Sie können dann die Abfrage Ihrer Sammlung für das Datum:

var dt = new Date("2016/01/01");
db.collection.find({ "created_at": { "$gt": dt } });

Und sollten Sie wünschen, um die Abfrage mithilfe der aggregation-framework, führen Sie das folgende pipeline, um das gewünschte Ergebnis zu erhalten. Es verwendet die $match Betreiber, die ähnlich wie die find() Methode:

var dt = new Date("2016/01/01");
db.collection.aggregate([
    {
        "$match": { "created_at": { "$gt": dt } }
    }
])

InformationsquelleAutor chridam

Wenn wir Dokumente:

db.doc.save({ "_id" : 1, "created_at" : "2016/01/01 12:10:10" })
db.doc.save({ "_id" : 2, "created_at" : "2016/01/04 12:10:10" })

Einfache Abfrage:

db.doc.find({ "created_at" : {"$lte": Date()} })

Aggregat-Abfrage:

db.doc.aggregate([{ 
     "$match": { "created_at": { "$lte": Date() } }
}])

• Datum () - Methode gibt das aktuelle Datum als string.
• new Date () - Konstruktor liefert ein Date-Objekt mit der Isodatum() wrapper.
• Isodatum () - constructor liefert ein Date-Objekt mit der Isodatum()
  wrapper.

Mehr Informationen über die Art der Datum hier und hier

InformationsquelleAutor alex10