提出多个获取请求，但限制为10个请求/分钟nodejs

Question

我很快就会解释我的问题。 我正在使用nodejs从URL中检索响应，我必须向该URL提出多个请求。

我只有一个限制：每分钟我不能提出10个以上的请求。 我该如何处理这个问题？

我也试图也遵循堆栈溢出响应：向只能处理20个请求的API请求几分钟请求，

但是该方法不起作用，因为它不等待所有承诺及其给出未定义的结果，

实际上我正在使用该代码，但不是等待所有响应，它使我直接不确定，以后所有请求都完成了：

async function rateLimitedRequests(array, chunkSize) {
var delay = 3000 * chunkSize;
var remaining = array.length;
var promises = [];

var addPromises = async function(newPromises) {
    Array.prototype.push.apply(promises, newPromises);
    if (remaining -= newPromises.length == 0) {
        await Promise.all(promises).then((data) => {
            console.log(data);
        });
    }
};

(async function request() {
    addPromises(array.splice(0, chunkSize).map(apiFetch));
    if (array.length) {
        setTimeout(request, delay);
    }
})();

}

Answer 1

您可以通过实现Promise.all方法来做。

例如：

const [响应1，响应2，响应3] =等待Promise.All（[[
axios.get（url_here），axios.get（url_here），axios.get（url_here）];

console.log（wendesp1）;

console.log(response3);

console.log(response2);

对于场景2，我们在下面的评论部分讨论

function rateLimiter(array = [], chunkSize = 10 ) {

    const delay = 10 * 1000;

    return new Promise((resolve, reject) => {
        let results = [];
        const callback = (iteration = 0) => {
            const process = array.slice(iteration * chunkSize, chunkSize);
            if(!process.length) return resolve(results);

            Promise.all(process).then(responses => {
                results = [ ...results, ...responses ];
                const processLength = array.slice((iteration + 1) * chunkSize, chunkSize).length;
                
                if(!processLength) return resolve(results);
                setTimeout(() => {
                    callback(iteration + 1);
                }, delay)
            })
        }

        callback();

    })
}

let results = await rateLimiter([ axios.get('URL_HERE'), axios.get('URL_HERE') ], 20);