具有SuperAgent和回呼（同步回呼）的AWSLambda始終回傳null

我目前正在研究一個與 OAuth 具有類似程序的身份驗證管道。

如果在第三方認證系統中認證成功，該值將被傳輸到 Success Direct url，我想與我的服務器通信以進行配置以進行自我認證。

在這種情況下，我將成功重定向 url 的 api 組織到 lambda 中，并使用 Lambda 的回呼物件來處理鏈中的回應和請求。

但是下面的代碼總是回傳空值，我不知道為什么。

// index.js
const Auth = require('AuthRequest')

exports.handler = async function (event, context, callback) {
    if (event.routeKey == 'POST /authentication/success') {
        var body = Auth.parse_query_to_json(Auth.decode_base64(event.body));

        if (body.resultCode == '0000') {        // success
            await Auth.get_auth_info(body, callback);
        }
        else {                                  // failure
            callback(null, {
                statusCode: 200,
                body: 'failure1'
            });
        }
    }
    else if (event.routeKey == 'POST /authentication/failure') {
        callback(null, {
            statusCode: 200,
            body: 'failure2'
        });
    }
};

// authRequest.js
const superagent = require('superagent')

var get_auth_info = async function (body, callback) {
    await superagent
        .post(url)
        .send({
            ...
        })
        .set('Content-Type', 'application/json;charset=utf-8')
        .end(async function(err, res) {
            if(err) {
                callback({
                    statusCode: 200,
                    body: 'failure3'
                });
            }
            else {
                callback(null, res)
            }
        });
};

var create_user_auth = async function (req, callback) {
    await superagent
        .post('my-auth-api-uri')
        .send({
        })
        .set('Content-Type', 'application/json;charset=utf-8')
        .end(async function(err, res) {
            if(err) {
                callback({
                    statusCode: 200,
                    body: 'failure4'
                });
            }
            else {
                if(res.status == 200) {
                    callback(null, res)
                }
                else {
                    callback({
                        statusCode: 200,
                        body: 'failure5'
                    });
                }
            }
        });
};

......

而這個 lambda 函式是由 API 網關觸發的，并使用 Payload 2.0 版本的事件物件，使用 http api。

有沒有人知道這個問題的答案？

uj5u.com熱心網友回復：

如果你想要sync處理程式，那么你不應該使用async function. 檔案解釋說它應該是：

exports.handler =  function(event, context, callback) {

uj5u.com熱心網友回復：

感謝@Marcin，我的代碼運行完美！

// index.js
const Auth = require('AuthRequest')

exports.handler = function (event, context, callback) {
    if (event.routeKey == 'POST /authentication/success') {
        var body = Auth.parse_query_to_json(Auth.decode_base64(event.body));

        if (body.resultCode == '0000') {        // success
            Auth.get_auth_info(body, callback);
        }
        else {                                  // failure
            callback(null, {
                statusCode: 200,
                body: 'failure1'
            });
        }
    }
    else if (event.routeKey == 'POST /authentication/failure') {
        callback(null, {
            statusCode: 200,
            body: 'failure2'
        });
    }
};

// authRequest.js
const superagent = require('superagent')

var get_auth_info = function (body, callback) {
    superagent
        .post(url)
        .send({
            ...
        })
        .set('Content-Type', 'application/json;charset=utf-8')
        .end(function(err, res) {
            if(err) {
                callback({
                    statusCode: 200,
                    body: 'failure3'
                });
            }
            else {
                callback(null, res)
            }
        });
};

var create_user_auth = function (req, callback) {
    superagent
        .post('my-auth-api-uri')
        .send({
        })
        .set('Content-Type', 'application/json;charset=utf-8')
        .end(function(err, res) {
            if(err) {
                callback({
                    statusCode: 200,
                    body: 'failure4'
                });
            }
            else {
                if(res.status == 200) {
                    callback(null, res)
                }
                else {
                    callback({
                        statusCode: 200,
                        body: 'failure5'
                    });
                }
            }
        });
};

......

標籤：

上一篇：AWSS3同步如何排除*.js檔案但包含*.min.js？

下一篇：使用基本憑證發出IamClient請求