异步瀑布和承诺

Question

我正在使用异步瀑布处理请求中的嵌套条件，并使用快速框架。但是我很困惑如何在数据为 <promise> 时将数据处理到瀑布中的下一个函数。此承诺数据是来自 sequalize 的查询。

这是草图

exports.getanythinghere = async function() {

  var query = "SELECT anything, here "
            + "FROM anywhere WHERE ignore this query";

  return new Promise((resolve, reject) => {
    db.sequelize.query(query , {
      type: QueryTypes.SELECT    
    }).then(wth => {
      resolve(wth);
    })
  });

}


async.waterfall([
  function(callback) {
    const trying = getanythinghere (); 
    callback(null, trying); 
  },
  function(dataone, callbackt) {
    console.log("dataone is ", dataone); 
  }
], function(err, res) {
  if (err) return callback(err);
  callback(null, res);    
});//waterfall

dataone总是dataone is Promise { <pending> }

我在这里缺少什么。在jquery，我会做getanythinghere().done(function(){});

但是我想在瀑布的这个回调中有它。

几年前我曾经这样做过，但我忘记了，因为 java 和 php

太多了

请帮忙..

Answer 1

您不再需要像 Async 这样的库，主要是因为 Javascript 现在原生支持 async/await。

首先，这是一个 Promise，因为你可以添加它 .then() :

db.sequelize.query(query , {type: QueryTypes.SELECT});

因为它是一个 Promise，你不需要（也不应该）将它包装在另一个 Promise 中，你也可以简单地 await 它，而不是使用 .then()

const trying = await db.sequelize.query(query , {type: QueryTypes.SELECT});

使用 await 或 .then() 解析承诺，你得到一个值，而不是 Promise { <pending> }。

那么，就可以直接使用trying，不需要像瀑布一样传给别的函数

console.log("trying is ", trying);

最后，您的所有代码都包含在四行中：

try{
  const query = `SELECT anything, here FROM anywhere WHERE ignore this query`;
  const trying = await db.sequelize.query(query , {type: QueryTypes.SELECT});
  console.log("trying is ", trying);
} catch(err) {
  console.log(err);
}

异步瀑布和承诺

async waterfall and promise

javascript

node.js

async-await

waterfall