等待多个（异步）API 调用完成

Question

非常像一个 nodejs 菜鸟，试图理解 Promise、await、async。我向你保证我做了尽职调查研究（花了一整天的时间来研究下面的代码。我仍然不能完全确定一切都应该是这样，并且找不到具有完全相同的东西（或足够接近）的参考我在这里尝试做的事情。

感谢您的帮助。

一般结构：

function msg() 正在等待 4 个函数完成，这 4 个 api 调用（代码只显示了一个）：function redditPromise()。

redditPromise() 调用异步函数 redditGet() -> 这是调用 reddit API 并同时将 API 数据保存到数据库的函数。 (函数saveToDb())

var nodeSocialApi = require('node-social-api');
var Socstat = require('../proxy').Socstat;

exports.index = function (req, res, next) {

/* SAVES DATA TO MONGODB */
function saveToDb(website,total) {
     //** Start : NewAndSave
     Socstat.newAndSave(website, total, "random", function (err, socstat) { // newAndSave -> proxy/socstat.js
          if (err) {
               return next(err);
          }
     });
     //** End : NewAndSave
}
/* END SAVES DATA TO MONGODB */

/* GET DATA FROM REDDIT API */
const reddit = new nodeSocialApi.Reddit(); // no auth needed

async function redditGet() {
   let result;

   await reddit.get('r/about/about.json')
   .then((data) => {

   // callback value for promise
   result = data.data.subscribers;
   saveToDb("reddit",result);

   }) // end then
   .catch(err => console.log(err));

   return result;
}
/* END : GET DATA FROM REDDIT API */

/* REDDIT PROMISE (all the others look the same) */
function redditPromise() {
     return new Promise(resolve => {
         resolve(redditGet());
     });
}
/* END : REDDIT PROMISE (all the others look the same) */

/* ONE FUNCTION THAT WAITS FOR ALL PROMISED FUNCTIONS */
async function msg() {
  const [a, b, c,d] = await Promise.all([githubPromise(), twitterPromise(), redditPromise(), facebookPromise()]);

  console.log(a + " " + b + " " + c  + d);
}
/* END: ONE FUNCTION THAT WAITS FOR ALL PROMISED FUNCTIONS */

msg();

}; // END exports

Answer 1

您发布的代码中唯一可用的功能是 twitterPromise，我建议作为 Bergi 来返回承诺：

const saveToDb = (website,total) =>
  //** Start : NewAndSave
  new Promise(
    (resolve,reject) =>
      Socstat.newAndSave(
        website, 
        total, 
        "random", 
        (err, socstat) => // newAndSave -> proxy/socstat.js
          (err)
            ? reject(err)
            : resolve(socstat)
      )
  );

//redditGet does not deal with errors, 
//  the caller has to deal with the errors (rejected promise)
const redditGet = async () => {
  const data = await reddit.get('r/about/about.json');
  await saveToDb("reddit",data.data.subscribers);
  //just return a promise:
  return data.data.subscribers;
};

//facebookGet does not deal with errors, 
//  the caller has to deal with the errors (rejected promise)
const facebookGet = async () => {  
  const response = await facebook.get('1118720888180564/fields=fan_count');
  console.log(response.fan_count);
  const dbResult = await saveToDb("facebook",response.fan_count)
  console.log("db entry succesfull -> " + dbResult);
  return response.fan_count;
};
//msg does not deal with errors, the caller of msg does
const msg = () =>
  Promise.all([githubPromise(), twitterPromise(), redditPromise(), facebookPromise()])

//calling msg and dealing with the error and result
msg()
.then(
  results =>
    console.log("got resullts",results)
  ,reject =>
    console.error("rejected",reject)
);

如果你理解 promise，你可以 investigate async await，它对于习惯于同步脚本的人来说具有更简单的语法（try catch），但最终它会返回一个 promise。

Answer 2

希望我把这个写成一个新的“答案”是正确的。基本上只是想表明我没有把这里的帮助视为理所当然。一直在努力支付我的会费。

基于 cmets (@HMR)，我尝试将我的一些函数转换为 async/await。 我想我不确定两件事： 1) 我的最终返回 response.fan_count 是在等待 saveToDb 完成吗？我尝试将 return response.fan_count 放在 saveToDb.then 承诺中，但这不起作用。 2) 我应该将我的 saveToDb.then() 结构也转换为 async/await 吗？

const facebookGet = async () => {  

facebookGet ()  {
    //just return a promise:
    let response; // outside to be able to return in the end
    try {
         response = await facebook.get('1118720888180564/fields=fan_count');
         console.log(response.fan_count);
         saveToDb("facebook",response.fan_count)
         .then(dbResult => {
              console.log("db entry succesfull -> " + dbResult); // returns the database object
         })
         .catch(err => console.error(err));
    }
    catch (err) {
         console.log("fetch failed ", err);
    }
return response.fan_count;
}

回答我自己的问题 1)

在“saveToDb”之前放置一个“return”...允许我在“.then”中写入“return response.fan_count”