语句未按预期执行[重复]

Question

我正在编写代码以从 api 获取数据并将其保存在 mongodb 数据库中。我写的代码是：

     getSquadList: async (ctx) => {
var query = ctx.request.query;
var squadList = await getSquadsOfMatch(query.matchId);
if (squadList.length <= 1) {
  var response = await axios.get(
    `${strapi.config.currentEnvironment.getSquadListApi}?apikey=${strapi.config.currentEnvironment.cricApiKey}&unique_id=${query.matchId}`
  );

  squadList = response.data.squad;

  var match = await Match.findOne({
    unique_id: query.matchId
  });

  var team1Squad, team2Squad;

  await squadList.forEach(async squad => {
    if (squad.name === match['team-1']) {
      team1Squad = {
        name: match['team-1'],
        match_id: match['unique_id'],
        match: match['_id'],
      };

      await new Squad(team1Squad).save();
      console.log('1');
    } else if (squad.name === match['team-2']) {
      team2Squad = {
        name: match['team-2'],
        match_id: match['unique_id'],
        match: match['_id'],
      };

      await new Squad(team2Squad).save();
      console.log('2');
    }
  });

  squadList = await getSquadsOfMatch(query.matchId);
  console.log('3');
}
ctx.send(squadList);
      }

我使用了 console.log() 来查看执行顺序。我想要的顺序是 1 2 3 但实际输出是 3 1 2 我怎样才能让程序在最后执行这些行。 小队列表 = 等待 getSquadsOfMatch(query.matchId); console.log('3');

Answer 1

如果我们模仿forEach 的作用，您不能将async 函数与forEach 一起使用：

function forEach(arr, callback){
   for(let i=0;i<arr.length;i++){
        callback(arr[i], i, arr);
   }
}

如您所见，await 不是您的 async 回调。

您可以创建一个自定义的forEach，例如：

async function forEach(arr, callback){
   for(let i=0;i<arr.length;i++){
        await callback(arr[i], i, arr);
   }
}

或者使用简单的for循环。

另外，您可以将所有的 Promise 推送到一个数组并调用 Promise.all 来处理所有请求。

async (ctx) => {
    var query = ctx.request.query;
    var squadList = await getSquadsOfMatch(query.matchId);
    if (squadList.length <= 1) {
        var response = await axios.get(
            `${strapi.config.currentEnvironment.getSquadListApi}?apikey=${strapi.config.currentEnvironment.cricApiKey}&unique_id=${query.matchId}`
        );

        squadList = response.data.squad;

        var match = await Match.findOne({
            unique_id: query.matchId
        });

        var team1Squad, team2Squad;
        const promises = squadList.map(squad => {
            if (squad.name === match['team-1']) {
                team1Squad = {
                    name: match['team-1'],
                    match_id: match['unique_id'],
                    match: match['_id'],
                };
                console.log('1');
                return new Squad(team1Squad).save(); //returning the promise
            } else if (squad.name === match['team-2']) {
                team2Squad = {
                    name: match['team-2'],
                    match_id: match['unique_id'],
                    match: match['_id'],
                };
                console.log('2');
                return new Squad(team2Squad).save(); //returning the promise
            }
        });
        await Promise.all(promises); //making all the changes parallely

        squadList = await getSquadsOfMatch(query.matchId);
        console.log('3');
    }
    ctx.send(squadList);
}

注意：我已经写了一篇介绍循环和异步函数的文章，请随时查看，https://medium.com/trappedpanda/loops-asynchronous-functions-and-returning-collective-results-in-node-js-b7566285fb74

Answer 2

您可以创建一个必须首先执行的承诺数组，并在运行getSquadsOfMatch 之前使用Promise.all 等待它们解决：

getSquadList: async (ctx) => {
    var query = ctx.request.query;
    var squadList = await getSquadsOfMatch(query.matchId);
    if (squadList.length <= 1) {
      var response = await axios.get(
        `${strapi.config.currentEnvironment.getSquadListApi}?apikey=${strapi.config.currentEnvironment.cricApiKey}&unique_id=${query.matchId}`
      );

      squadList = response.data.squad;

      var match = await Match.findOne({
        unique_id: query.matchId
      });

      var team1Squad, team2Squad;

      const tasks = squadList.map(async squad => {
        if (squad.name === match['team-1']) {
          team1Squad = {
            name: match['team-1'],
            match_id: match['unique_id'],
            match: match['_id'],
          };

          await new Squad(team1Squad).save();
          console.log('1');
        } else if (squad.name === match['team-2']) {
          team2Squad = {
            name: match['team-2'],
            match_id: match['unique_id'],
            match: match['_id'],
          };

          await new Squad(team2Squad).save();
          console.log('2');
        }
      });

      await Promise.all(tasks)
      squadList = await getSquadsOfMatch(query.matchId);
      console.log('3');
    }
    ctx.send(squadList);
  }