如何正确使用 Promise.all 组合两个数据集并返回单个对象？

Question

我有一个现有对象data。 我正在使用 NodeJS async 函数来检索 fetchResponse 的值。 最后，我尝试使用以下for loop 将fetchResponse 嵌入到现有的data 对象中

for (let key in data) {
    for (let number in data[key]) {
        data[key][number].map( async d=> {
            const fetchResponse = await sequelize
                .query(await fetchHostDetails(d.Hostname), options);
        data[key][number]['Fetchresult'] =  fetchResponse;
        });
    }
}
return data;

我看到 data 仍然具有原始值，不包括 key value pair Fetchresult : fetchResponse

我正在尝试使用Promise.All 如下，但它仍然给出原始data 对象值。

for (let key in data) {
    for (let number in data[key]) {
        data[key][number].map( async d=> {
            const fetchResponse = await sequelize
                .query(await fetchHostDetails(d.Hostname), options);
             await Promise.all({...d, Fetchresult : fetchResponse});
        });
    }
}
return data;

const data =
{
  "error1": {
    "7": [
      {
        "ErrorType": "Error-1A",
        "Hostname": "host123.com"
      }
    ],
    "8": [
      {
        "ErrorType": "Error-1B",
        "Hostname": "host223.com"
      },
      {
        "ErrorType": "Error-1C",
        "Hostname": "host1231.com"
      }
    ]
  }
}

对于Error-1A 下的主机名，我正在低于fetchResponse

const fetchResponse =
    [
      {
        "resType": "unknow data",
        "res": "missing data"
      },
      {
        "resType": "login failed",
        "res": "login with wrong userid"
      }
    ]

同样，Error-1b 和 Error-1C 下的主机名也将有单独的 fetchResponse，但响应格式将类似于我们为 Error-1A 获得的格式。

对于data.error1[8]，我们得到fetchResponse 的2 个值，但请注意，它们是Error-1B 和Error-1C 的2 个独立值。一个显示在Error-1B之后，另一个显示在Error-1C之后。

Answer 1

在循环中使用await 对我来说没有意义。我更愿意生成一个单一的、扁平的 Promise 列表，最终有一个 Promise.all 等待它们。

请允许我使用placeholderAsyncOperation 代替您使用密钥和号码进行提取。出于演示目的，我将稍微延迟一下，然后根据参数返回一些对象。不过，我会使用您的原始输入 data。

const data =
{
  "error1": {
    "7": [
      {
        "ErrorType": "Error-1A",
        "Hostnames": "host123.com,hostabc.com,host33a.com..."
      }
    ],
    "8": [
      {
        "ErrorType": "Error-1B",
        "Hostnames": "host223.com,host2c.com,host43a.com..."
      },
      {
        "ErrorType": "Error-1C",
        "Hostnames": "host1231.com,host2abc.com,host313a.com..."
      }
    ]
  },
  "error2": {
  },
  "error3": {
  }
}

async function placeholderAsyncOperation(key, number, result) {
  await delay(1000);
  return {key, number, resultJSON: JSON.stringify(result)};
}

const delay = time_ms => new Promise(resolve => setTimeout(resolve, time_ms));


let promises = [];
for (let key in data) {
  for (let number in data[key]) {
    promises.push(data[key][number].map(val => (placeholderAsyncOperation(key, number, val))));
  }
}

Promise.all(promises.flat()).then(result => console.table(result));

注意：关于这个 sn-p：

这使用了console.table，Stack Overflow 还不能很好地支持（嵌入到页面中的输出将显示为空），所以如果你在浏览器中运行这个 sn-p，你可能必须 在运行 sn-p 之前打开浏览器的内置控制台。比如，通过按 F12 或者您的浏览器显示其控制台。

Answer 2

我首先会构建一个包含所有承诺以及键和索引的数组：

let promises = [];

for (let key in data) {
  for (let number in data[key]) {
      let p = async() => {
           const fetchResponse = await sequelize.query(
               await fetchHostDetails(d.Hostname), options
           );
           return {key, number, fetchResponse};
      };
      promises.push(p);
   }
}

现在，在您将这个“获取”数据注入原始数据之前，需要解决 Promise。所以我们使用异步函数：

const merge = async (data, promises) => {
    
    // wait for all promises
    const resolvedPromises = await Promise.all(promises);

    // inject the results into "data"
    resolvedPromises.forEach(row => {
        if (row) {
            const {key, number, fetchResponse} = row;
            data[key][number]['Fetchresult'] =  fetchResponse;
        }
    });

    return data;

};

当你调用它时，记住它是异步的：

merge(data, promises).then(newData => {

   console.log(newData);

});