Z tym samym problemem spotkałem się, gdy pobierałem około 35 000 dokumentów. Aby go rozwiązać, użyłem funkcji agregującej (sakulstra:aggregate
) iw moim przypadku niesamowicie wzmocniło żądanie. Format wyniku oczywiście nie jest taki sam, ale nadal jest łatwy w użyciu do obliczenia wszystkich potrzebnych mi rzeczy.
Przed (7000 ms):
const historicalAssetAttributes = HistoricalAssetAttributes.find({
date:{'$gte':startDate,'$lte':endDate},
assetId: {$in: assetIds}
}, {
fields:{
"date":1,
"assetId":1,
"close":1
}
}).fetch();
Po (300ms):
const historicalAssetAttributes = HistoricalAssetAttributes.aggregate([
{
'$match': {
date: {'$gte': startDate, '$lte': endDate},
assetId: {$in: assetIds}
}
}, {
'$group':{
_id: {assetId: "$assetId"},
close: {
'$push': {
date: "$date",
value: "$close"
}
}
}
}
]);