从使用多个异步调用的函数返回

Question

因此，基本思想是编写一个方法，该方法将废弃网页以获取包含产品评级的 JSON 数据。然后在几个域（.de、.uk、.fr、.nl 等）上多次调用此方法以收集所有评级。

所以我最终使用了 scrapWebPage 方法，该方法会删除单个页面：

const scrapWebPage = async (countryAppData, productNumber) => {
    const shopUrl = `https://www.shopExample.${countryAppData.countryCode}/?q=${productNumber}`
    const avoidCORSUrl = 'https://allorigins.me/get?url=' + shopUrl + '&callback=?'

    return await axios
        .get(avoidCORSUrl, {xmlMode: false, normalizeWhitespace: true})
        .then(response => {
            const $ = cheerio.load(response.data)
            let scrapedWebPageJson

            contentForParsing = $("script").get().children[0].data                   
            scrapedWebPageJson = JSON.parse(contentForParsing)

            return scrapedWebPageJson
        })
}

scrapWebPage 还包含一些解析以返回我想要的一些 JSON 数据 - 它正确解析（经过测试）并返回 Promise。

但后来我想在多个域上调用此方法，所以我创建了getProductDataFromManyDomains：

const getProductDataFromManyDomains = (productNum) => {
    let prodData = {
        reviews: []
    }

    const appCountries = [
        {countryCode: 'nl'}, 
        {countryCode: 'pl'},
        {countryCode: 'de'}
    ]

    appCountries.forEach(async countryApp => {
        let countryData = {}

        let parsedWebPage = await scrapWebPage(countryApp, productNum)

        countryData.countryCode  = countryApp.countryCode
        countryData.ratingCount  = parsedWebPage.aggregateRating.ratingCount
        countryData.ratingValue  = parsedWebPage.aggregateRating.ratingValue
        countryData.reviews      = parsedWebPage.reviews   

        prodData.reviews.push(countryData)
    })

    return prodData
}

现在我在填充之前收到prodData...而我想接收实际数据（填充prodData）。

我不确定我应该如何构造这个getProductDataFromManyDomains 方法来实际返回数据，而不是在填充之前prodData。那可能吗？或者这里有什么好的模式来处理这样的事情？

Answer 1

使用for 循环而不是.forEach()。 for 循环将暂停等待，.forEach() 循环不会。这是因为您传递给.forEach() 的async 回调将返回一个承诺，但.forEach() 并非旨在对该承诺做任何事情，因此它不会等待它解决后再继续循环，而是@987654328使用await 进行@循环。

然后，getProductDataFromManyDomains() 将需要为 async 并将返回一个带有最终结果的承诺。

async function getProductDataFromManyDomains(productNum) {
    let prodData = {
        reviews: []
    }

    const appCountries = [
        {countryCode: 'nl'}, 
        {countryCode: 'pl'},
        {countryCode: 'de'}
    ]

    for (let countryApp of appCountries) {
        let countryData = {}

        let parsedWebPage = await scrapWebPage(countryApp, productNum)

        countryData.countryCode  = countryApp.countryCode
        countryData.ratingCount  = parsedWebPage.aggregateRating.ratingCount
        countryData.ratingValue  = parsedWebPage.aggregateRating.ratingValue
        countryData.reviews      = parsedWebPage.reviews   

        prodData.reviews.push(countryData)
    })

    // this will be the resolved value of the promise that
    //   getProductDataFromManyDomains() returns
    return prodData;
}

// usage
getProductDataFromManyDomains(productNum).then(result => {
    console.log(result);
});

您也可以并行运行多个请求，而不是一次一个，但由于您最初试图让代码一次执行一个，因此我向您展示了如何做到这一点。

如果您想并行执行它们，您只需将 Promise 累积在一个数组中并使用 Promise.all() 知道它们何时全部完成，而您不会 await 请求。

这是并行运行请求的代码版本，使用 .map() 和 Promise.all()：

function getProductDataFromManyDomains(productNum) {
    let prodData = {
        reviews: []
    }

    const appCountries = [
        {countryCode: 'nl'}, 
        {countryCode: 'pl'},
        {countryCode: 'de'}
    ]

    return Promise.all(appCounteries.map(countryApp => {

        return scrapWebPage(countryApp, productNum).then(parsedWebPage => {
            let countryData = {}
            countryData.countryCode  = countryApp.countryCode
            countryData.ratingCount  = parsedWebPage.aggregateRating.ratingCount
            countryData.ratingValue  = parsedWebPage.aggregateRating.ratingValue
            countryData.reviews      = parsedWebPage.reviews 
            return countryData;         
        });
    })).then(results => {
        // put results into prodData and make that the resolved value
        prodData.reviews = results;
        return prodData;
    });
}

getProductDataFromManyDomains(productNum).then(result => {
    console.log(result);
});