Log for debugging of concurrent req.
This commit is contained in:
@@ -201,10 +201,17 @@ class OlxCrawler {
|
|||||||
i,
|
i,
|
||||||
i + NUMBER_OF_CONCURRENT_REQ_SCRAPER_API
|
i + NUMBER_OF_CONCURRENT_REQ_SCRAPER_API
|
||||||
);
|
);
|
||||||
|
//
|
||||||
|
console.log(
|
||||||
|
`OLX - Sending requests from ${i} to ${i +
|
||||||
|
NUMBER_OF_CONCURRENT_REQ_SCRAPER_API}.`
|
||||||
|
);
|
||||||
|
console.log(`OLX - Urls sent to scrape: `, concurrentUrlsToScrape);
|
||||||
|
//
|
||||||
const concurrentReqScraperApi = concurrentUrlsToScrape.map(url =>
|
const concurrentReqScraperApi = concurrentUrlsToScrape.map(url =>
|
||||||
this.scrapeAd(url)
|
this.scrapeAd(url)
|
||||||
);
|
);
|
||||||
|
|
||||||
const concurrentReqData = await Promise.all(concurrentReqScraperApi);
|
const concurrentReqData = await Promise.all(concurrentReqScraperApi);
|
||||||
|
|
||||||
concurrentReqData.forEach(reqData => scrapedData.push(reqData));
|
concurrentReqData.forEach(reqData => scrapedData.push(reqData));
|
||||||
|
|||||||
Reference in New Issue
Block a user