Tornado / Motorでの集約の失敗：不明なオブジェクトMotorAggregationCursorが生成されました

実際の .aggregate() メソッド自体は「非同期」ではありません。しかし、カーソルの反復はです。

代わりに：

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

ドキュメントが言うように。