请问一下，查询万条数据，内存不断增长的解决方法。

let ids = []
let total = await TradeRecord.find(conditions).select('id').sort({'tradeAt': -1})
for (let item of total) {
ids.push(item._id)
}
for (let index = 1; index <= Math.floor(ids.length / 10) + 1; index++) {
let tradids = []
let i = index - 1 > 0 ? (index - 1) * 10 : 0
if ((index * 10) < ids.length) {
tradids = ids.slice(i, index * 10)
} else {
tradids = ids.slice(i)
}
if (tradids.length > 0) {

let ret = await TradeRecord.find({_id: {$in: tradids}})
.select('device organization restaurant user deploySite consumeInterval amount mainAccountAmount subsidyAmount giveFreeAmount balance subsidyBalance giveFreeBalance tradeAt sn deviceSerial subAccount supermarketConsume payMethod consumeType consumePayMethod deviceMode ')
.populate('organization', 'name')
.populate('restaurant', 'name')
.populate('deploySite', 'name')
.populate({
path: 'user',
select: 'department name type jobNumber cardUid fingerprint',
populate: {path: 'department', select: 'name'}
})

rowsbase.push(...ret)
}
}
}

代码如上

流式查询 + 流式写入

查完 1000 条，写文件，再查一下个 1000 条，写文件。

再不行就每次 100 条，50 条……

看不懂这个代码，但是小内存下处理就是这么个流程。

#3+1

每查 1000 条写在 csv 尾部就行了

内存有限制写入 excel 是不是炸内存了,写成 csv 试一下?

流程是 let row =[] 先查询 1000 条数据 再 push 进 row ，再循环下去。未到写入文件，就爆内存了

有没有可能流程是 使用 stream, send -> limit buffer -> rev 呢?

分片处理或者使用 stream 的方式向 excel 中追加数据，最后将 Excel 导出，应该可以解决

感谢各位回复，我去尝试一下。

应该是要复用内存的

@INCerry 能详细说一下怎么处理吗？

用了 .cursor() eachAsync 还是不行，内存控制不住

姿势不对，我这个可以
[email protected]:gogogo1024/mongodbStreamToCSV.git

@snoy 谢谢 我现在看看。