Den faktiske .aggregate()
metoden er ikke i sig selv "asynkron". Men markørens iteration er.
Så i stedet:
cursor = db.activities.aggregate(pipeline)
while (yield cursor.fetch_next):
doc = cursor.next_object()
print(doc)
Ligesom lægerne siger.