如何对 sequelize 查询的每个结果进行 API 调用？

Question

我有一个 cron 作业，它将查询我的数据库并找到任何状态为“已提交”或“正在处理”的项目，我希望对每个项目进行 API 调用到外部 API，然后使用回应

  const results = await myTable.findAll({
    where: {
      status: {
        [op.or]: [
          'SUBMITTED',
          'PROCESSING'
        ],
      },
    },
  })

我尝试使用 forEach，但出现错误“TypeError: Cannot read property 'Symbol(Symbol.iterator)' of undefined”

  await Promise.all(
        results.forEach(async item => {
          makeAPICall(item.id).then(response => updateDBItemStatus(item.id, response)
        }),
      )

Answer 1

使用 Promise.all 从外部 api 收集所有响应，然后更新数据库。将整个事情包装在一个异步块中。

let api_call_array = results.map( item => makeAPICall(item.id));
const api_response = await Promise.all([api_call_array])

let update_db_item = api_response.map((response, index)=> {
  return updateDBItemStatus(results[index].item.id, response)
})
const update_response = await Promise.all([update_db_item])