Tengo un bucle while en una función que uso para consultar un servicio web API. El ciclo maneja la paginación en las respuestas del servidor API para que la función pueda devolver todas las entradas en la base de datos.
Necesito adaptarme a la limitación de velocidad del servicio web. La mejor manera puede ser establecer un retraso entre las solicitudes. ¿Cómo puedo agregar un retraso de 1000ms entre cada una de las solicitudes que manejan la paginación en esta función?
var db = new Discogs().database(); const getALL = async (id) => { let releases = []; let currentPage = 1; let totalPages = null while (totalPages === null || currentPage < totalPages) { let response = db.getArtistReleases(id); let results = await response; if (totalPages === null) { totalPages = parseInt(results.pagination.pages); } releases.push(results); currentPage++; } return Promise.all(releases); }Ejecuto la función en la llamada API de back-end de mi aplicación
const response = getAll( req.body.artistId ); response.then(results => { }) .catch((error) => { });Para adaptarme al límite de velocidad de la API, reescribí la función que maneja la paginación y las llamadas a la biblioteca API después de esta solución.
También se agregó la función sleep(ms) para pausar la ejecución durante un número determinado de segundos si se acerca el límite de velocidad.
const getAll = async (id) => { return new Promise(resolve => { let mainReleases = [] let perMinuteRateLimit = 60; let rateLimitThrottleSeconds = 4; let latestResults; db.getArtistReleases(id, {page: 1, per_page: 75}, (err, results, rateLimit) => { if (err) { console.log("Discogs API Error: " + err); } latestResults = results; mainReleases.push(latestResults.releases); async.whilst( (cb) => cb(null, latestResults['pagination'].urls.next), (iteration_cb) => { var q = url.parse(latestResults['pagination'].urls.next, true); console.log("Discogs API - Artist Releases Query Page " + q.query['page'] + " of " + latestResults['pagination'].pages + "..."); db.getArtistReleases(id, {page : q.query['page']}, (err, res, rateLimit) => { latestResults = res; mainReleases.push(latestResults.releases); if (rateLimit['used'] > perMinuteRateLimit*0.9) { sleep(rateLimitThrottleSeconds * 1000).then(() => { console.log("near Discogs API rate limit -- throttling requests\n" + JSON.stringify(rateLimit)); iteration_cb(null, res); }); } else { iteration_cb(null, res); } }); }, (err, results) => { resolve(mainReleases); } ) }); }); }; function sleep(ms) { return new Promise((resolve) => setTimeout(resolve, ms)); }la cola parece una gran solución, pero con esto pude obtener los resultados que necesitaba rápidamente a expensas de la escalabilidad probablemente.