node.js - NodeJS 执行 then() 之后的下一个进程

This question already has answers here:

Using async/await with a forEach loop

(26 个回答)

1年前关闭。

我正在尝试在 forEach 内部执行 upsert，因为请求是使用 Sequelize.upsert 方法的对象数组。我这样做:

async createInfo (req, res){
   newsData = req.body.news,
   newsList = [];

    newsData.forEach(async values => {
        var news = {};
        news.inserted_id = values.inserted_id;
        if(news.inserted_id == null){
            do {
                news.inserted_id = crypto.getRandom(5);
                var check = await InstitutionNews.count({where: {inserted_id: news.inserted_id}});
            } while (check > 0);
        }
        News.upsert({
            institution_id: institution_id,
            inserted_id: news.inserted_id,
            news_date: values.news_date,
            news_title: values.news_title,
            description: values.news_description,
            created_by: created_by
        }).then(ResNews => {
            news.news_date = values.news_date;
            news.news_title = values.news_title;
            news.description = values.news_description;
            newsList.push(news);
        })
    })

    console.log("TEST")
}

但过程在 then() 处停止。它没有像 console.log 那样执行下一个代码。

有没有办法在 then() 之后执行下一行代码。我需要 then() 因为我想将 news 对象推送到 newsList 数组中。因为我需要 newsList 作为 if else 条件来执行下一个过程。

谢谢。

最佳答案

由于听起来您需要等待完成 forEach 才能执行另一步骤，因此我建议使用类似 Promise.all 的内容:

async function createInfo(req, res) {
  const newsData = req.body.news
  const newsList = []

  try {
    await Promise.all(
      newsData.map(
        async (values) => {
          const news = {}
          news.inserted_id = values.inserted_id

          // ...

          News.upsert({...})
            .then(ResNews => {
              // ...
              newsList.push(news)
            })
        }
      )
    )
    console.log('newsList', newList)
    // do other work
  } catch (error) {
    // handle errors appropriately
  }
}

这样，您将创建一系列 promise 并等待所有 promise 解决/完成。

您当前使用 forEach 的方法在这种情况下不起作用，因为它不会在执行“下一步”之前等待每个异步调用完成。由于 Promise.all 返回单个 Promise，您可以在继续下一步之前“等待”解决该问题。

这是一个简单的示例，它在某种程度上可以完成您要执行的操作:

async function createInfo() {
  const newsData = [1, 2, 3, 4, 5]
  const newsList = []

  await Promise.all(
    newsData.map(
      async (values) => {
        const temp = await Promise.resolve('temp')
        console.log('first async call inside values of', values)

        Promise.resolve('resolved')
          .then((result) => {
            newsList.push(`resolved with ${values}`)
          })
      }
    )
  )
  console.log('newsList after')
  console.log(newsList)
}

createInfo()

编辑

这是 @Bergi 在评论中正确指出的替代解决方案:

async function createInfo(req, res) {
  const newsData = req.body.news

  try {
    const newList = await Promise.all(
      newsData.map(
        async (values) => {
          const news = {}

          news.inserted_id = values.inserted_id

          // ...

          // since it doesn't look like you're using any
          // data that you'd get back from the `News.upsert` call, wait for
          // it to finish and just simply return your `news` object

          await News.upsert({...})

          news.news_date = values.news_date
          news.news_title = values.news_title
          news.description = values.news_description

          return news
        }
      )
    )
    console.log('newsList', newList)
    // do other work
  } catch (error) {
    // handle errors appropriately
  }
}

关于node.js - NodeJS 执行 then() 之后的下一个进程，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/57546768/

上一篇：node.js - Sequelize manytomany 关系不会创建关系

下一篇：node.js - 在Sequelize中选择列的子串

node.js - 我可以在 Windows 中使用命令行升级 Node.js 吗？

javascript - NodeJs 以丑陋的二进制格式接收 UDP 数字

node.js - "refused to connect"带 https 并让我们加密

mysql - MySQL 表中的阿拉伯文本？

javascript - Node.js POST 导致 [错误 : socket hang up] code: 'ECONNRESET'

node.js - Angular 9 SSR 404 未找到带有状态代码的页面

node.js - Webpack 无法解析 JS 模块(在 Typescript 项目中)

sequelize.js - 使用列值作为子字符串对 LIKE/iLIKE 进行序列化

javascript - 如何在 Sequelize 模型中使用导入？