sql >> Base de Datos >  >> RDS >> Mysql

Consultar una base de datos MySQL desde una función NodeJS AWS Lambda

El problema era que necesitaba poner mi context.succeed dentro de mis devoluciones de llamada. Muchas gracias a sqlbot, ya que su charla sobre devoluciones de llamada me llevó a estudiar dónde las cosas realmente estaban terminando su ejecución.

Entonces, aparentemente, cuando usa AWS Lambda, si el "contexto" finaliza antes de que se llamen sus devoluciones de llamada, no recibe sus devoluciones de llamada. Entonces, a pesar de que había colocado todas mis devoluciones de llamada de esta manera:conectar -> consulta -> finalizar, la primera devolución de llamada de la cadena desde conectar nunca se llama porque "context.succeed" se llamaba justo después, lo que finalizó la ejecución.

Aquí está mi código a partir de ahora (obteniendo una consulta adecuada ahora):

var mysql = require('mysql');
var connection = mysql.createConnection({
    ...
});

exports.handler = (event, context) => {
    try {

        if (event.session.new) {
            // New Session
            console.log("NEW SESSION");
        }


        switch (event.request.type) {

            case "LaunchRequest":
                // Launch Request
                console.log(`LAUNCH REQUEST`);
                context.succeed(
                    generateResponse({},
                        buildSpeechletResponse("Welcome to an Alexa Skill, this is running on a deployed lamda function", true)
                    )
                );
                break;

            case "IntentRequest":
                // Intent Request
                console.log(`Intent Request`);
                console.log('Then run MySQL code:');
                connection.connect(function(err) {
                    console.log('Inside connection.connect() callback');
                    if (!err) {
                        console.log("Database is connected ... ");
                        connection.query("INSERT INTO Users (user_id) VALUES ('TESTNAME')",
                            function(err, result) {
                                console.log("Inside connection.query() callback")
                                if (!err) {
                                    console.log("Query Successful! Ending Connection.");
                                    connection.end();
                                } else {
                                    console.log("Query error!");
                                }
                            });
                    } else {
                        console.log("Error connecting database ..." + err.message);
                    }
                    context.succeed(
                        generateResponse({},
                            buildSpeechletResponse("Welcome to the incredible intelligent MySQLable Alexa!", true)
                        )
                    );
                });

                break;

            case "SessionEndedRequest":
                // Session Ended Request
                console.log(`SESSION ENDED REQUEST`);
                break;

            default:
                context.fail(`INVALID REQUEST TYPE: ${event.request.type}`);

        }

    } catch (error) {
        context.fail(`Exceptiodn: ${error}`)
    }

};

//Helpers
buildSpeechletResponse = (outputText, shouldEndSession) => {

    return {
        outputSpeech: {
            type: "PlainText",
            text: outputText
        },
        shouldEndSession: shouldEndSession
    };
};

generateResponse = (sessionAttributes, speechletResponse) => {
    return {
        version: "1.0",
        sessionAttributes: sessionAttributes,
        response: speechletResponse
    };
};