Så i rækkefølge:
-
aggregate
er en metode. Det kræver 2 positionsargumenter (self
, som er implicit bestået, ogpipeline
) og et vilkårligt antal søgeord argumenter (som skal sendes somfoo=bar
-- hvis der ikke er nogen=
tegn, det er ikke et søgeordsargument). Det betyder, at du skal kalderesult = work1.aggregate(pipe, allowDiskUse=True)
. -
Din fejl om maksimal dokumentstørrelse er iboende for Mongo. Mongo kan aldrig returnere et dokument (eller array deraf) større end 16 megabyte. Jeg kan ikke fortælle dig hvorfor, fordi du hverken har givet os dine data eller din kode, men det betyder sandsynligvis, at det dokument, du bygger som et slutresultat, er for stort. Prøv at mindske
$limit
parameter, måske? Start med at sætte den til 1, kør en test, øg den og se på, hvor stort resultatet bliver, når du gør det.