エクスプレスリクエストでNodeJS async/await + recursion

Question

GetPurchaseDataを呼び出すGetAllData（）という関数があります。この関数は、すべてのデータがロードされるまで再帰的に自身を呼び出します。

async function GetAllData(){ 
    console.log("starting loading purchase data"); 
     await GetPurchaseData(); 
     console.log("purchase data loaded")   
} 

async function GetPurchaseData(){ 
     return new Promise(async function (resolve,reject){ 
      var Headers = { 
       .... 
      } 
      await request({url: xxx, headers: Headers },async function(error, response, body) { 
        var tmp = JSON.parse(body)  
        _.forEach(tmp.Purchases, p => purchaseData.push(p));       

        if (response.headers.pagination){ 
         return await GetPurchasePaginatedData() 
        } 
        else{ 
         console.log("done loading....") 
         return resolve("done") 
        } 
      }); 
     }) 
} 

内のノードJSは、次のような出力出力します

starting loading purchase data 
done loading.... 

をそれは

購入データは、それがほとんどらしい

をロード印刷するGetAllDataまで戻ってくることはありませんその機能にこだわっているように、私の意見は何とか "復帰のラインsolve（ "done"） "は最初の呼び出しまで戻ってこないので、実際にPromiseを完了としてマークします。

Answer 1

私はasync/awaitでの経験はあまりありませんが、私が読んだところでは、このようなコードではいけません。

async function GetAllData(){ 
    console.log("starting loading purchase data"); 
     await GetPurchaseData(); 
     console.log("purchase data loaded")   
} 

async function GetPurchaseData(){ 
     let body = await request({url: xxx, headers: Headers }) 

     var tmp = JSON.parse(body)  
     _.forEach(tmp.Purchases, p => purchaseData.push(p));       

     if (response.headers.pagination){ 
      return await GetPurchasePaginatedData() 
     } 
     else{ 
      console.log("done loading....") 
      return "done" 
     } 
} 

Answer 2

（もhere参照）async/awaitPromise constructor antipatternを避け、通常のコールバックとしてasync機能を渡す避ける - あなたはuse the Promise constructor to promisify an existing callback APIする必要があります！注意すべき

async function GetPurchaseData() { 
    var headers = {…}; 
    var promise = new Promise((resolve,reject) => { // not async! 
     request({url: xxx, headers}, (error, response, body) => { // not async! 
      if (error) reject(error); 
      else resolve({response, body}); 
     }); 
    }); // that's it! 

    var {response, body} = await promise; 
    for (var p of JSON.parse(body).Purchases) 
     purchaseData.push(p));       

    if (response.headers.pagination) { 
     return GetPurchasePaginatedData() 
    } else { 
     console.log("done loading....") 
     return "done"; 
    } 
}