Flask-MongoEngine- und PyMongo-Aggregationsabfrage

Ich versuche, eine Aggregationsabfrage mit flask-mongoengine durchzuführen, und nach dem, was ich gelesen habe, klingt es nicht so, als ob es möglich wäre.

Ich habe mehrere Forenthreads, E-Mail-Ketten und einige Fragen zu Stack Overflow durchgesehen, aber ich habe kein wirklich gutes Beispiel für die Implementierung der Aggregation mit flask-mongoengine gefunden.

Es gibt einen Kommentar indiese Frage Das heißt, Sie müssen "Raw Pymongo und Aggregation Funktionalität" verwenden. Es gibt jedoch keine Beispiele dafür, wie dies funktionieren könnte. Ich habe mit Python herumgebastelt und eine Basisanwendung mit dem Flask-Framework erstellt, aber mich mit vollständigen Anwendungen und dem Verbinden / Abfragen mit Mongo zu befassen, ist für mich ziemlich neu.

Kann jemand ein Beispiel (oder einen Link zu einem Beispiel) angeben, wie ich meine Kolben-Mongo-Engine-Modelle verwenden könnte, aber eine Abfrage mit dem Aggregations-Framework mit PyMongo durchführen kann? Benötigt das zwei Verbindungen zu MongoDB (eine für PyMongo, um die Aggregationsabfrage durchzuführen, und eine zweite für die reguläre Abfrage / Einfügung / Aktualisierung über MongoEngine)?

Ein Beispiel für die Aggregationsabfrage, die ich durchführen möchte, lautet wie folgt (mit dieser Abfrage erhalte ich genau die Informationen, die ich in der Mongo-Shell haben möchte):

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 }