Agregasi Gagal pada Tornado/Motor:menghasilkan objek yang tidak diketahui MotorAggregationCursor

.aggregate() metode itu sendiri tidak "async". Tapi iterasi kursornya adalah.

Jadi sebagai gantinya:

cursor = db.activities.aggregate(pipeline)
while (yield cursor.fetch_next):
    doc = cursor.next_object()
    print(doc)

Seperti yang dikatakan dokumen.