2016-11-07 70 views
1

我们有一个简单的查询,使用部署在nodejs上的无服务器应用程序从我们的数据库获取信息。不幸的是,我无法获得蓝鸟承诺的任何回应 - 回应总是超时,我不确定可能导致问题的原因。下面是我的文件:Lambda没有返回数据的蓝鸟

serverless.yml:

service: myAuth0 

provider: 
    name: aws 
    iamRoleARN: arn:aws:iam::XXXXXXXXX:role/test-role 
    runtime: nodejs4.3 
    stage: production 
    region: us-us-1 
    iamRoleStatements: 
    - Effect: "Allow" 
     Action: 
     - "ec2:CreateNetworkInterface" 
     - "ec2:DescribeNetworkInterfaces" 
     - "ec2:DeleteNetworkInterface" 
     Resource: "*" 
    vpc: 
    securityGroupIds: 
     - ${self:custom.${opt:stage, self:provider.stage}.${opt:region, self:provider.region}.vpc.securitygroup} 
    subnetIds: 
     - ${self:custom.${opt:stage, self:provider.stage}.${opt:region, self:provider.region}.vpc.subnet1} 
     - ${self:custom.${opt:stage, self:provider.stage}.${opt:region, self:provider.region}.vpc.subnet2} 

custom: 
    production: 
    us-east-1: 
     vpc: 
     subnet1: subnet-11111111 
     subnet2: subnet-22222222 
     securitygroup: sg-33333333 

functions: 
    getUserRoles: 
    handler: app/handler.handle 
    events: 
     - http: 
      method: get 
      path: userstest/roles 

handler.js:

'use strict'; 

require('dotenv').config(); 
var Promise = require('bluebird'); 
var getConn = require('./dbConn'); 

module.exports.handle = (event, context, callback) => { 
    Promise.using(getConn(), function(conn){ 
    return conn.query('select ert.name from emp_roles ert order by ert.name').then(function(rows){ 
     let roles = []; 
     rows.forEach(function(row){ 
     roles.push(row.name); 
     }); 
     return roles; 
    }).catch(function(err){ 
     console.log(error); 
    }); 
    }).then(function(roles){ 
    console.log("found roles: " + roles); 
    callback(null, {roles: roles}); 
    }); 
}; 

dbConn.js:

var mysql = require('promise-mysql'); 
var pool = mysql.createPool({ 
    connectionLimit: 10, 
    host  : process.env.MYSQL_HOST, 
    user  : process.env.MYSQL_USER, 
    password : process.env.MYSQL_PW, 
    database : process.env.MYSQL_DB 
}); 

function getConn() { 
    return pool.getConnection().disposer(function(connection) { 
    pool.releaseConnection(connection); 
    }); 
} 

module.exports = getConn; 

我添加了控制台日志条目,我可以看到它完成了它们...但是它不会返回任何内容,并最终导致连接错误。我看到数据被提取,而Lambda只是坐在那里,没有任何东西返回6秒。下面是从云观看最新的条目:

18时15分01秒开始的requestId:195a7218-a516-11e6-b52d-5f028bb2bdf6 版本:$最新18点15分01秒2016-11-07T18:15: 01.820Z 195a7218-a516-11e6-b52d-5f028bb2bdf6找到角色:9 18时15分07秒结束 的requestId:195a7218-a516-11e6-b52d-5f028bb2bdf6 18时15分07秒报告 的requestId:195a7218-a516-11e6-b52d -5f028bb2bdf6持续时间:6002.14 ms 计费时长:6000 ms内存大小:1024 MB使用的最大内存:18 MB 18:15:07 2016-11-07T18:15:07.468Z 195a7218-a516-11e6-b52d-5f028bb2bdf6 任务6.00秒后超时

使用蓝鸟与Lambda时是否有什么突破?

回答

0

蓝鸟绝对有效。

我想可能会有使用disposer结束连接的问题。我使用postgresql承诺库,所以不能真正尝试与MySQL,但我重写它使用disposer,我得到相同的超时。

尝试在finally块中结束连接。

db.getConnection() 
    .then(doMyQuery) 
    .catch(catchErrors) 
    .finally(db.disposeConnection) 

编辑:好吧,实际上释放连接在lambdas中是不好的,你应该结束它们。 mysqljs文档说:

当你与一个连接完成,只需调用connection.release() ,连接将返回到池中,随时可以通过 别人再使用。

你真的不想那么做。这就是你超时的原因。当你的承诺链结束时,连接返回到池并等待再次使用,因此lambda超时,因为它永远不会结束。

使用connection.end()或connection.destroy()

+0

谢谢......不幸的是,它仍然在回调(cb)超时: var Promise = require('bluebird'); var pool = require('./ dbConn'); (函数(行)){ module.exports.handle =(event,context,cb)=> pool.getConnection()。然后(函数(conn){conn.query(query).then(function(rows){ let roles = []; rows.forEach(function(row){ roles.push(row.name); }); cb(null,{roles:roles}); })。catch(function(err){ 的console.log(误差); })最后(函数(){ pool.releaseConnection(conn);在 });} )捕获(功能(E){ 回调(e)中; }) ; }; –

+0

你的新dbConn怎么样,看起来如何?编辑:我想它现在只是返回一个池。 – Erndob

+0

@DavidD我更新了我的答案。 – Erndob