Flask-MongoEngine & PyMongo Aggregation Abfrage

Question

Ich versuche, eine Aggregation Abfrage mit Kolben-mongoengine zu machen, und von dem, was ich gelesen habe, es klingt nicht wie es möglich ist.

Ich habe mehrere Forum-Threads, E-Mail-Ketten und ein paar Fragen zu Stack Overflow angeschaut, aber ich habe kein wirklich gutes Beispiel dafür gefunden, wie man Aggregation mit Flask-Mongoengine implementiert.

Es gibt einen Kommentar in this question ist die sagt, Sie verwenden müssen „raw pymongo und Aggregation-Funktionalität.“ Es gibt jedoch keine Beispiele dafür, wie das funktionieren könnte. Ich habe mit Python gebastelt und habe eine grundlegende Anwendung auf mit Flask Rahmen, aber Eintauchen in vollwertiges Anwendungen & Verbindungs-/Abfrage zu Mongo ist ziemlich neu für mich.

Kann jemand ein Beispiel (oder einen Link zu einem Beispiel) geben, wie ich meine Kolben-Mongoengine-Modelle verwenden könnte, aber Abfrage mit dem Aggregations-Framework mit PyMongo? benötigen diese zwei Verbindungen zu MongoDB (eine für PyMongo die Aggregation Abfrage und eine zweite für die regelmäßige Abfrage/Insert/Update über MongoEngine ausführen)?

Ein Beispiel für die Aggregation Abfrage durchführen möchte ich wie folgt (diese Abfrage wird mir genau die Informationen, die ich in der Mongo Shell wollen):

db.entry.aggregate([ 
    { '$group' : 
     { '_id' : { 'carrier' : '$carrierA', 'category' : '$category' }, 
      'count' : { '$sum' : 1 } 
     } 
    } 
]) 

Ein Beispiel für die Ausgabe dieser Abfrage:

{ "_id" : { "carrier" : "Carrier 1", "category" : "XYZ" }, "count" : 2 } 
{ "_id" : { "carrier" : "Carrier 1", "category" : "ABC" }, "count" : 4 } 
{ "_id" : { "carrier" : "Carrier 2", "category" : "XYZ" }, "count" : 31 } 
{ "_id" : { "carrier" : "Carrier 2", "category" : "ABC" }, "count" : 6 } 

Answer 1

die Klasse Ihres mit Mongoengine definiert tatsächlich eine _get_collection() Methode, die das „rohe“ Sammelobjekt wird wie im pymongo Treiber implementiert.

Ich verwende nur den Namen Model hier als Platzhalter für Ihre tatsächliche Klasse für die Verbindung in diesem Beispiel definiert:

Model._get_collection().aggregate([ 
    { '$group' : 
     { '_id' : { 'carrier' : '$carrierA', 'category' : '$category' }, 
      'count' : { '$sum' : 1 } 
     } 
    } 
]) 

So können Sie immer die pymongo Objekte zugreifen, ohne eine separate Verbindung hergestellt wird. Mongoengine ist selbst auf Pymongo gebaut.

Answer 2

aggregate ist verfügbar seit Mongoengine 0.9. Link zur API Reference.

Da kein Beispiel gibt es auch immer um ist, ist hier, wie Sie eine Aggregat Abfrage Aggregation Rahmen mit Mongoengine ausführen> 0,9

pipeline = [ 
    { '$group' : 
    { '_id' : { 'carrier' : '$carrierA', 'category' : '$category' }, 
     'count' : { '$sum' : 1 } 
    } 
    }] 

Model.objects().aggregate(*pipeline)