如何使用蓝鸟并发选项的地图功能

我正在尝试使用蓝鸟的地图函数与内置的并发控制.

我想要检索一个名称列表,然后为每个名称做一些POST请求.例如,我想为每周的每一天提出每个名称的请求.但是,由于预期的服务器具有速率限制,因此需要限制并发POST请求数.

function getNames() {
    //Open mongodb connection
    //Get collection and array of names
    //return array of names in a promise 
}

function createDatesArray() {
    //Create an array of rates
    //return array of dates in a promise
    //Ex. return Promise.resolve(datesArray);
}

getNames().map(function (name) {
    return createDatesArray().map(function (date) {
        return requestData(date,name);
    },{concurrency: 5});
}).then(function () {
//do something
});

这是使用蓝鸟并发的正确方法吗？

文档链接在这里bluebird documentation.

解决方法

简短答案：是的,这将限制请求数量为5.

注意事项：请记住,您可能还会受到更多限制,例如HTTP客户端或您可能使用的任何其他池,模块和服务.

另外,Mongo连接是用来作为一个永久的连接,所以你应该只打开一个然后使用它,而不是每次打开和关闭一个.

如果createDatesArray没有做任何异步操作,那么你不需要Promise.resolve它,你可以使用map的静态变体作为Promise.map(datesArray,function(date){…})等等.我也不会巢.假设createDatesArray确实是异步的：

Promise.join(getNames(),createDatesArray(),function(names,dates){
    var tasks = [];
    names.forEach(function(name ){ // create Cartesian product of names * dates
        dates.forEach(function(date){
             tasks.push(function(){ return requestData(name,date); });
        });
    });
    return Promise.map(tasks,function(job){ return job(); },{ concurrency: 5} );
}),then(function(results){
     // do whatever
});

原文地址：https://www.jb51.cc/java/123760.html