AWS LambdaでMySQLの情報を取得したい

Question

現在AWSでWebAPIの開発を行っています。
やろうとしていることは

RDSで立てたMySQLのサーバーの情報をjson形式でAPIから取得できるようにすることです。

LambdaとAPIGatewayを利用してやってみようとしたのですが、
Lambdaにzipをアップして、テストを実行しても思ったように処理が終わりません。
色々試しましたが問題点、解決策がわかりませんでした。
長文になるとは思いますがお付き合いお願いします。

まず、データベースについて記載します。

RDS：MySQL
データベース名：testDB
テーブル情報：testTable (id int, value varchar(10))
testTableの中身：
( 1, testValue1 )
( 2, testValue2 )
( 3, testValue3 )

testTableにある情報を全て取得して
それをjsonにして返すことを目的としてやっています。

DBからの情報の取得と、取得した情報のjsonへの変換はjavascriptとnodeで行いました。

「Runtime」には「Node.js4.3」を選択。
「Code entry type」は「Upload a .ZIP file」を選択。
VPCはDBを立てているVPCを選択。
セキュリティグループもDBと同じものを選択しています。

.zipは以下のようにしてあります。

uploadzip.zip
    ┗index.js
    ┗node_modules
        ┗mysql

index.js

var mysql = require('mysql');

'use strict';
exports.handler = (event, context) => {
    var connection = mysql.createConnection({
      host     : 'RDSからエンドポイントを指定',
      user     : 'MySQLのユーザ名',
      password : 'MySQLのパスワード',
      database : 'testDB'
    });
    connection.connect(function(err) {
      if (err) {
        console.error('error connecting: ' + err.stack);
        return;
      }
      console.log('connected as id ' + connection.threadId);
    });
    connection.query('show tables', function(err) {
      if (err) {
        console.error('error connecting: ' + err.stack);
        return;
      }
      console.log('connected as id ' + connection.threadId);
    });
    connection.query('select * from testTable', function(err, rows, fields) {
      if (err)
      {
        console.log("--err");
        console.log(err);
        throw err;
      }
      console.log(rows);
      console.log(fields);
    });
    connection.end(function(err) {
        context.done();
    });
};

Lambdaでの設定を載せます。

• Code

Code entry type : Upload a .ZIP file

• Configuration

Runtime : Node.js 4.3
Handler : index.handler
Role : Chose an existing role
Existing role : lambda_basic_vpc_execution
VPC : VPCを設定（VPCは全体で1つしか作っていません）
Subnets : ap-northeast-1a,-northeast-1c
Security Groups : DBのセキュリティグループと同じものを設定

これで、Lambdaのテストを実行すると

{
  "errorMessage": "2016-07-19T00:07:13.619Z oooooooo-oooo-oooo-oooo-oooooooooooo Task timed out after 3.00 seconds"
}

と赤文字で返って来ます。
jsoneは普通に実行する分には取得したいものが取得できていました。

分かりにくいかもしれませんが困っています。
解決策、問題点を教えて下さい。
よろしくお願いします。
長文になりましたが読んでくださりありがとうございました。

Comments

[TaichiYanagiya]

「Security Groups : DBのセキュリティグループと同じものを設定」とのことですが、インバウンドの送信元で自セキュリティグループを許可していますか？

[TaichiYanagiya]

RDS は VPC 内のみ公開でしょうか、public に公開でしょうか？
もし後者の場合、「RDSのエンドポイント名」を VPC 内の DNS で名前解決すると、グローバルIPアドレスが返ったりしませんでしょうか？

Answer 1

Task timed out after 3.00 seconds

文字通り捉えれば、Lambda Functionに設置しているタイムアウト値が3秒になっており、
実際の処理が3秒以上かかるためにタイムアウトとなっているのでしょう。

テスト実行などで処理時間を計測したのちに、適切なタイムアウト値に設定してあげてください。

Comments

[suvera]

回答有り難うございます！
タイムアウト値を増やしてテストすると以下のように出てきます。
"errorMessage": "Process exited before completing request"
また、index.jsをコマンドラインなどで実行した際は3秒もかからずに取得できています。

[attakei]

"Process exited before completing request" ですと、context.doneより前にコードが終わってしまうと発生するメッセージみたいです。
でも、正常に接続終了させられればcontext.done()が呼ばれるように見えますね。。。

だとすると、
- 実はconnection.endより前でエラーで止まってしまう
- connection.endが実は正しい使い方ではない
あたりが、考えられそうです。

[suvera]

返信遅くなって申し訳ありません。
その見方では考えれていなかったのでその方面から調査してみます。