Tổng hợp không thành công trên Tornado / Động cơ:mang lại đối tượng không xác định MotorAggregationCursor

Thực tế .aggregate() bản thân phương thức không phải là "async". Nhưng sự lặp lại con trỏ là.

Vì vậy, thay vào đó:

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

Giống như tài liệu nói.