AWS Lambda не выполняет node.js MySQL запросы

Question

Компания, в которой я работаю, в настоящее время пытается перенести часть нашей существующей кодовой базы на AWS Lambda. Мы запускаем node.js 4.3 (самая высокая версия, предлагаемая для лямбда), и мы выполняем внутри VPC для подключения к базе данных RDS. Функция Lambda очень просто подключается к базе данных, однако простой запрос select в нашу таблицу MySQL не выполняет или не возвращает никаких ошибок. Вот код, который мы пытаемся:

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

    /** 
    * Require Config file 
    **/ 
    var config = require('./config.js'); 

    /** 
    * AWS/MWS Configuration 
    **/ 
    var AWS = require('aws-sdk'); 
    var MWS = require('mws'); 

    var mws   = require('./lib/mws-reports/lib/mws.js'); 
    var XML   = require('./lib/mws-reports/pixl-xml'); 
    var mwsReportsAPI = require('./lib/mws-reports/lib/reports.js'); 
    var mwsFeedsAPI = require('./lib/mws-reports/lib/feeds.js'); 

    AWS.config.region  = config.AWS.region; 
    AWS.config.credentials = config.AWS.credentials; 

    var client = new mws.Client(
    config.MWS.credentials.accessKeyId, 
    config.MWS.credentials.secretAccessKey, 
    config.MWS.credentials.sellerID, 
    {} 
); 

    /** 
    * Configure DB 
    * @var Promise - A library to maintain Promises (used for chained MySQL queries) 
    * @var Utils - A wrapper for utility functions. 
    * @var connection - The MySQL DB Connection 
    **/ 
    var Promise = require('bluebird'); 
    var utils = require('./lib/Utils'); 
    var mysql = require('mysql'); 

    var MySQLConnection = mysql.createConnection(config.mysql); 

    MySQLConnection.connect(function (err) { 
    if(err) { 
     console.log("Error connection: " + err.stack); 
     return; 
    } 

    console.log("Connected as id " + connection.threadId); 
    }); 

    var connection  = Promise.promisifyAll(MySQLConnection); 
    var InventoryHealth = require('./app/models/InventoryHealth'); 
    var Items   = require('./app/models/Items'); 

    connection.query("SELECT * FROM items", function(err, rows) { 
    rows.forEach(function(item) { 
     console.log(JSON.stringify(item)); 
    }); 
    }); 

    connection.end(); 
    context.done(null, "Finished :)"); 
} 

Как я уже говорил, самое странное из всего этого является отсутствие ответа я получаю от Lambda. Это все, что он мне говорит:

START RequestId: f726f0ba-ecec-11e6-b0b3-9d51c554a5ac Version: $LATEST 
2017-02-07T04:22:01.123Z f726f0ba-ecec-11e6-b0b3-9d51c554a5ac (node) crypto.createCredentials is deprecated. Use tls.createSecureContext instead. 
END RequestId: f726f0ba-ecec-11e6-b0b3-9d51c554a5ac 
REPORT RequestId: f726f0ba-ecec-11e6-b0b3-9d51c554a5ac Duration: 4232.01 ms Billed Duration: 4300 ms Memory Size: 128 MB Max Memory Used: 22 MB 

Любые советы были бы замечательными. Спасибо.

Answer 1

Вы не используете обратные вызовы правильно. Читайте об этом. И не забудьте инициализировать модули вне обработчика для ускорения выполнения функции.

Не смотря на то, что делает код, и я не проверял этот код, вам нужно что-то больше в линиях:

/** 
    * Require Config file 
    **/ 
    var config = require('./config.js'); 

    /** 
    * AWS/MWS Configuration 
    **/ 
    var AWS = require('aws-sdk'); 
    var MWS = require('mws'); 

    var mws   = require('./lib/mws-reports/lib/mws.js'); 
    var XML   = require('./lib/mws-reports/pixl-xml'); 
    var mwsReportsAPI = require('./lib/mws-reports/lib/reports.js'); 
    var mwsFeedsAPI = require('./lib/mws-reports/lib/feeds.js'); 

    AWS.config.region  = config.AWS.region; 
    AWS.config.credentials = config.AWS.credentials; 

    var client = new mws.Client(
    config.MWS.credentials.accessKeyId, 
    config.MWS.credentials.secretAccessKey, 
    config.MWS.credentials.sellerID, 
    {} 
); 

    /** 
    * Configure DB 
    * @var Promise - A library to maintain Promises (used for chained MySQL queries) 
    * @var Utils - A wrapper for utility functions. 
    * @var connection - The MySQL DB Connection 
    **/ 
    var Promise = require('bluebird'); 
    var utils = require('./lib/Utils'); 
    var mysql = require('mysql'); 

    var InventoryHealth = require('./app/models/InventoryHealth'); 
    var Items   = require('./app/models/Items'); 

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

    var MySQLConnection = mysql.createConnection(config.mysql); 

    MySQLConnection.connect(function (err) { 
     if(err) { 
     console.log("Error connection: " + err.stack); 
     callback(err, err); 
     } else { 

     console.log("Connected as id " + connection.threadId); 

     var connection  = Promise.promisifyAll(MySQLConnection); 


     connection.query("SELECT * FROM items", function(err, rows) { 
      if (err) { 
      console.log(err); 
      callback(err, err); 
      } else { 
      rows.forEach(function(item) { 
       console.log(JSON.stringify(item)); 
      }); 
      connection.end(); 
      callback(null, rows); 
      } 
     }); 


     } 
}); 


}