De werkelijke .aggregate()
methode is zelf niet "async". Maar de cursor-iteratie is.
Dus in plaats daarvan:
cursor = db.activities.aggregate(pipeline)
while (yield cursor.fetch_next):
doc = cursor.next_object()
print(doc)
Precies zoals de documenten zeggen.