async waterfall and promise

Question

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

这是的草图

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现在支持异步/等待。

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

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

由于它是一个Promise，您不需要(也不应该(将它包装在另一个Promise中，而且您可以简单地等待它，而不是使用.then()

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

使用await或.then()解析promise，您会得到一个值，而不是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);
}