Jadi, secara berurutan:
-
aggregate
adalah sebuah metode. Dibutuhkan 2 argumen posisi (self
, yang secara implisit diteruskan, danpipeline
) dan sejumlah kata kunci argumen (yang harus diteruskan sebagaifoo=bar
-- jika tidak ada=
tanda, itu bukan argumen kata kunci). Ini berarti Anda perlu memanggilresult = work1.aggregate(pipe, allowDiskUse=True)
. -
Kesalahan Anda tentang ukuran dokumen maksimum melekat pada Mongo. Mongo tidak pernah dapat mengembalikan dokumen (atau lariknya) yang lebih besar dari 16 megabita. Saya tidak dapat memberi tahu Anda alasannya karena Anda tidak memberikan data maupun kode Anda kepada kami, tetapi itu mungkin berarti bahwa dokumen yang Anda buat sebagai hasil akhirnya terlalu besar. Coba kurangi
$limit
parameter, mungkin? Mulailah dengan menyetelnya ke 1, jalankan pengujian, lalu tingkatkan dan lihat seberapa besar hasilnya saat Anda melakukannya.