在 node js 中使用 promise.all 进行外部 api 调用

Question

我正在使用 request-promise npm 包在 nodeJS 中进行多个 api 调用。为了让我获得所需的数据，我必须遍历所有类别，然后在每个类别中循环遍历产品数组以获取产品信息。示例类别响应如下

{
        "success": true,
        "response": [
          {
            "category_id": 9,
            "name": "Leather Wheeled luggage",
            "products": [
              "TL141911",
              "TL141888"
            ],
            "parent_category_id": 34
          },
          {
            "category_id": 10,
            "name": "Leather Luggage Weekender Duffles bags",
            "products": [
              "TL141794",
              "TL141658"

            ],
            "parent_category_id": 34
          }
        }

因为我必须循环并进行 api 调用，我正在尝试使用 Promise.all，但它没有产生正确的结果，它给我一个 404 not found 错误，有人可以帮我看看我在哪里这里出错了？以下是我尝试过的

const rp = require('request-promise');

const requestUrl = "https://stage.tuscanyleather.it/api/v1/";
const categoryRequestUrl = requestUrl + 'categories';
let tuscanApiOptions = {
    uri: categoryRequestUrl,
    headers: {
        'Authorization': 'Bearer asd343'
    },
    method: 'Get',
    json: true 
};

rp(tuscanApiOptions)
    .then((categResponse) => {
        //res.end(categResponse);  
        let ps = [];
        categResponse.response.forEach((category) => {
            if (category.products !== undefined) {
                category.products.forEach((product) =>{
                    let productApiOptions = {
                        uri: requestUrl + `product-info?code=${product}`,
                        headers: {
                            'Authorization': 'Bearer asd343'
                        },
                        method: 'Get',
                        json: true 
                    };
                    ps.push(rp(productApiOptions));
                });
                Promise.all(ps)
                    .then((values) => {
                        console.log(values); //This is where things are going wrong
                  })
                    .catch((err) =>{
                        console.log(JSON.stringify(err,null,2));
                    })
            }

        })

    })
    .catch((error) => {
        console.log(error);
        //res.status(error.statusCode).send(error.error.error_description);
    });

Answer 1

此代码应该可以帮助您调试 404：

const rp = require('request-promise');

const requestUrl = "https://stage.tuscanyleather.it/api/v1/";
const categoryRequestUrl = `${requestUrl}categories`;
const tuscanApiOptions = {
  uri: categoryRequestUrl,
  headers: {
    'Authorization': 'Bearer asd343'
  },
  method: 'Get',
  json: true 
};

// Promise of flat array of products (loses category data)
const productsP = rp(tuscanApiOptions))
  .then(({response}) => response
    .map(category => category.products) // array of arrays
      .flat() // flatten to array of products
      .filter(p => !!p) // remove empty 
  )

const prodUrl = `${requestUrl}product-info?code=`

const productDataP = productsP.then(products => 
  products.map(product => 
    rp({
      ...tuscanApiOptions,
      uri: `${prodUrl}${product}` 
    }).catch(e => `Error fetching ${prodUrl}${product} ${e.message}`)
  )
)

// Wait for all requests to resolve with data or error. 
// resultsP is an array of Promise<productdata|error>
const resultsP = Promise.all(productsDataP)

resultsP.then(console.log)             

一些建议，接受或离开：

将Array.forEach 从您的编程词汇中剔除。它会给你带来比它解决的问题更多的问题，因为它是副作用的（本质上是一个循环）。使用Array.map 返回一个新数组，然后对其进行操作。 Array.map 将状态机与数据转换分开，forEach 将它们混合在一起。

不要将let 或var 用于不会发生变异的事物。这告诉其他程序员和机器不要依赖这个值。使用const。

请参阅this article 以获得更深入的解释。

使用async/await 可能更容易做到这一点，至少在调试方面是这样。你有数据结构遍历和异步 monads (Promise)，你需要在这里解决，还有一个 404 需要调试。 awaiting 一个 promise 将值扩展到 monad 上下文之外，因此它消除了一层复杂性。

当你有一个 Promises 数组时，你 await Promise.all(arrayP) 会得到一个未包装值的数组。

const rp = require('request-promise');

const requestUrl = "https://stage.tuscanyleather.it/api/v1/";
const categoryRequestUrl = `${requestUrl}categories`;
const tuscanApiOptions = {
  uri: categoryRequestUrl,
  headers: {
    'Authorization': 'Bearer asd343'
  },
  method: 'Get',
  json: true 
};

async function main() {
  const categories = await rp(tuscanApiOptions)
  const products = categories.response
    .map(category => category.products) 
    .flat() 
    .filter(p => !!p) // remove undefined

  console.log(products) // should be flat array of products

  const prodUrl = `${requestUrl}product-info?code=`

  const requestsP = products
    .map(product => 
      rp({
        ...tuscanApiOptions,
        uri: `${prodUrl}${product}` 
      }).catch(e => `Error fetching ${prodUrl}${product} ${e.message}`)
  )

  const results = await Promise.all(requestsP)

  console.log(results)
}

main()