Node Js Async 未按正确顺序运行并跳过承诺

Question

我目前在使用 async/await 语法时遇到问题。在过去的 2 天里，我试图找出原因，最后决定问一下。

我正在尝试运行一个 cron 函数（测试），该函数调用连接到数据库的异步函数，并尝试使用 3rd 方 API 查找有关每个条目的新信息。

每个函数都独立工作，但在组合它们时它们不会以正确的顺序运行，第一个函数会跳过第一行的 await 语句。（仍然执行它）

输出如下所示（未定义 -> DB 条目 -> api 结果）

正确的应该看起来像（数据库条目 -> api 结果 -> 最终结果）

async function test() {
    var db = await checkfornewdata() // executes 
    console.log(db) //skips line one and returns undefined as it didnt get its value
}

async function checkfornewdata()
{
    
    var state = `SELECT * FROM users`;
    var users= []
    var newusers

    console.log('Get connection ...');

     connection.query(state , async function (err,result) {
      if(err) throw err;
      users= result
     console.log('Query Result')
     console.log(result) //works without problems

     for (var i in result){ 

       var checknew= await 3rdpartyapi.getusers(i.id );
       if (i.joinDate> checknew.joinDate){
         newusers.push(i);
     }
     console.log('New entries:')
     console.log(newusers)
     connection.end()
     return newusers;
  }

async function getusers(id)
{
var joinDate;   

if (typeof(id) !== 'undefined'){

console.log("getting joinDate of " + id)
await 3rdpartyapi.getUser(id).then(User => {    
        
joindate= User.joinDate;
console.log(joinDate)   //last output i recieve

})
.catch((err) => {
    
console.log(err)    

return err;
})
return joinDate;
}}

Answer 1

在您的checkfornewdata 函数中，您混合了承诺和回调。在当前形式中，您的函数在对数据库的调用完成之前返回。 （这就是为什么console.log(db) 返回undefined）。

要解决此问题，您可以使用支持承诺的 mysql 驱动程序（如 mysql2）或像这样重写您的函数：

function checkfornewdata() {
    // ...    
    return new Promise((resolve, reject) => {
      connection.query(state , async (err, result) => {
        if (err) {
          return reject(err);
        }
        // ...
        resolve(newusers);
      }
    }
}