我有一个包含170万条记录的mongodb集合。每条记录都是一个ID号。我需要读取每个ID号,对另一个服务执行一些请求,转换数据,将其写入不同的集合,如果所有操作都成功,则删除原始ID记录。
我想要一个脚本,它可以无限期地做这些事情,直到集合为空,具有指定的并发性(即任何时候最多3个请求)。
我想要的本质上是一个并发的while循环,即:(伪javascript)
promiseWhile(queueNotEmpty, 3){
readFromQueue
.then(doc => {
return process(doc);
})
.then(result => {
if(result == "empty") // (or whatever)
queueNotEmpty = false;
});
}
https://stackoverflow.com/questions/56263994
复制相似问题