promise.then 在异步 lambda 处理程序中不起作用

Question

我在这里实现了一个简单的数据库调用 这有效，输出为success

const Database = require('../utils/Database')

module.exports.logActivityLog =  (event, context, callback) => {
    try {
        context.callbackWaitsForEmptyEventLoop = false
        const db = new Database('config1')
        var p1 = db.findOne('logs', { id: 1 })
        var p2 = db.findOne('logs', { id: 1 })

        Promise.all([p1, p2]).then((values) => {
            console.log(db.getConnection().threadId)
            console.log('values', values)
            callback(null, 'success')
        }).catch((e) => {
            console.log(e)
            callback(null, 0)
        })
    } catch (error) {
        console.log(error)
        callback(null, 'error')
    }
}

现在，如果我使用 async 作为处理程序，它总是以 null 输出，尽管我的 promiss.all.then 的 console.log 有效。

module.exports.logActivityLog = async (event, context, callback) => {
    //exactly same as above
}

我需要第二种方法来工作。我在这里做错了吗？

Answer 1

你可以这样做

const Database = require('../utils/Database')

module.exports.logActivityLog = async (event, context, callback) => {
    try {
        context.callbackWaitsForEmptyEventLoop = false
        const db = new Database('config1')
        var p1 = await db.findOne('logs', { id: 1 })
        var p2 = await db.findOne('logs', { id: 1 })
        console.log(db.getConnection().threadId)
        console.log('values', p1, p2)
        callback(null, 'success')
    } catch (error) {
        console.log(error)
        callback(null, 'error')
    }
}

或者如果你希望数据库操作并行运行，试试这个

var [p1, p2] = [
  await db.findOne('logs', { id: 1 }), 
  await db.findOne('logs', { id: 1 })
]

Answer 2

当使用async/await 时，你应该await 你的承诺：

const Database = require('../utils/Database')

module.exports.logActivityLog = async (event, context, callback) => {
    try {
        context.callbackWaitsForEmptyEventLoop = false
        const db = new Database('config1')
        var p1 = db.findOne('logs', { id: 1 })
        var p2 = db.findOne('logs', { id: 1 })

        try {
            const values = await Promise.all([p1, p2])
            console.log(db.getConnection().threadId)
            console.log('values', values)
            callback(null, 'success')
        } catch (e) {
            console.log(e)
            callback(null, 0)
        }
    } catch (error) {
        console.log(error)
        callback(null, 'error')
    }
}