Den faktiska .aggregate()
Metoden är inte i sig "asynkron". Men marköriterationen är.
Så istället:
cursor = db.activities.aggregate(pipeline)
while (yield cursor.fetch_next):
doc = cursor.next_object()
print(doc)
Precis som läkarna säger.