【发布时间】：2020-04-17 21:43:38
【问题描述】：
我遇到了问题Lambda函数由于某种原因它超时。
我尝试添加一些 console.log 来了解发生了什么，在外部 http 请求之前一切正常。
我使用 npm 模块请求
我可以在请求之前看到日志，但回调中的日志从不显示，就像端点没有响应一样。
我错过了什么吗？提前致谢！
var mysql = require('mysql');
var request = require('request');
var config = require('./config.json');
var pool = mysql.createPool({
host: config.dbhost,
user: config.dbuser,
password: config.dbpassword,
database: config.dbname
});
var openWeatherOptions = (device) => {
let domain = 'https://api.openweathermap.org/data/2.5/';
let apiEndpoint = 'weather?';
let params = `lat=${device.lat}&lon=${device.lng}&APPID=${process.env.WEATHER_APP_ID}&units=metric`;
let url = [domain, apiEndpoint, params].join('').toString();
return {
url: url,
method: 'GET',
headers: { 'Content-Type': 'application/json'},
};
};
exports.handler = (event, context, callback) => {
context.callbackWaitsForEmptyEventLoop = false;
// Connect to DB
console.log('fallback connecting to DB')
pool.getConnection( (errOnConnection, connection) => {
if(errOnConnection) {
callback({"err": errOnConnection });
}
console.log('fallback connected to DB')
// Retrieve device position
let queryOne = 'SELECT lat, lng FROM T03_DevicesPosition WHERE deviceCode = (?);';
console.log('fallback retrieving device position')
connection.query( queryOne, [event.device], (errOnQ1, results, fields) => {
if(errOnQ1) {
connection.release();
callback({"err": errOnQ1 });
}
console.log('fallback device position retrieved')
// Call openweather
let device = results[0];
let options = openWeatherOptions(device);
console.log('fallback calling openWeather with following data: ', device, options);
request( options, (errOpenWeather, response, body) => {
console.log('fallback openweather response received');
if(errOpenWeather || (response.statusCode !== 200 && response.statusCode !== 201) ) {
connection.release();
callback({"err": errOpenWeather });
}
let meteo = JSON.parse(body).main;
meteo.date = new Date(event.time*1000);
meteo.pressure = Math.floor( meteo.pressure );
console.log('fallback storing data', meteo);
let query = `INSERT INTO T02_DevicesTransmissions (deviceCode, transmissionDate, temperature, humidity, pressure, unixDate, rawData) VALUES ( ?, ?, ?, ?, ?, ?, ?);`;
let queryValues = [ event.device, meteo.date, meteo.temp, meteo.humidity, meteo.pressure, event.time, 'fallback'];
connection.query( query, queryValues, (errInsert, results, fields) => {
connection.release();
console.log('fallback completed with', errInsert ? '' : 'out');
if (errInsert) callback({"err": errInsert });
else callback();
});
});
});
});
}
【问题讨论】：
-
这里是 AWS 的说明：aws.amazon.com/premiumsupport/knowledge-center/…
标签： node.js aws-lambda npm-request