Wie die bluebird Parallelität option für die map-Funktion

Ich bin versucht, bluebird ' s map-Funktion mit der integrierten Steuerung der Gleichzeitigkeit.

Möchte ich zum abrufen einer Liste der Namen, dann machen Sie eine Reihe von POST-Anfragen für jeden Namen. Zum Beispiel möchte ich eine Anfrage für jeden Namen für jeden Tag der Woche. Jedoch, ich muss Gas, die Anzahl der gleichzeitigen Anforderungen POST, weil der vorgesehene server hat rate Grenzen.

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
});

Ist dies die richtige Art und Weise zu verwenden bluebird ist Parallelität?

Den link zur Dokumentation hier bluebird Dokumentation.

InformationsquelleAutor aefhm | 2014-07-14
  1. 15

    Kurze Antwort: ja , dies begrenzt die Anzahl der Anfragen zu 5.

    Achtung: denken Sie daran, Sie könnten immer noch anfällig sein, um Grenzen mehr gesetzt, wie der HTTP-client ist, oder jede andere pools, Module und Dienstleistungen, die Sie möglicherweise verwenden.

    Auch, eine Mongo-Verbindung verwendet werden soll wie eine persistente, also sollten Sie wohl nur öffnen und dann nutzen Sie Sie, anstatt Sie zu öffnen und zu schließen, jedes mal.

    Wenn createDatesArray tut man nicht alles asynchron, Sie nicht zu Versprechen.zu lösen, können Sie stattdessen verwenden Sie die statische Variante von map als Promise.map(datesArray, function(date){ ... }) etc. Ich würde auch kein nest. Vorausgesetzt createDatesArray ist tatsächlich async:

    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
});
    • Süß. Ich mache Versprechen.mit auf der mongo-Verbindung an anderer Stelle. Ich wusste nicht, dass der statische Variante von der Karte nahm der Parallelität option. Dein code-Beispiel ist eine sehr gut lesbare Ansatz. TY.
    InformationsquelleAutor Benjamin Gruenbaum
Schreibe einen Kommentar