当記事はアカウンティング・サース・ジャパン Advent Calendarの11日目です。
開発グループでマネージャーをしています。
普段コードはほとんど書いていないですが、AWS好きなのでAWSネタで行きます。
先日、Amazon Auroraのストアード・プロシージャーからLambda Functionの呼び出しができるようになったことが発表されました。
https://aws.amazon.com/jp/blogs/news/amazon-aurora-update-call-lambda-functions-from-stored-procedures-load-data-from-s3/
早速試してみましょう！
要件
- 会員テーブルにデータが登録されたら、営業責任者にお褒めの電話
- 会員テーブルからデータが削除されたら、営業責任者にお叱りの電話
構成概要
- Amazon AuroraにUsersテーブルを作成し、INSERTとDELETEのTriggerからストアード・プロシージャーをcallする
- ストアード・プロシージャーからLambdaをキック
- LamdaからTwilio APIをキック
まずはLambdaの設定
「Create a Lambda Function」を押して、「Blank Function」選択
設定は、「VPC」のところは「No VPC」を選択
※ VPCを選択すると、インターネットアクセスする為に一手間かかりますので、今回はこっち。
他の項目は適当に（「Lambda function code」は次項）。
Lambda function code
exports.handler = function(event, context) {
console.log(JSON.stringify(event, null, 2));
var message = new Buffer(event.message, 'base64').toString()
var queryString = require('querystring');
twiml = {
Twiml: '<Response>\n' +
'<Say voice="alice" language="ja-JP">' + message + '</Say>\n' +
'</Response>'
};
url = "http://twimlets.com/echo?" + queryString.stringify(twiml);
var exec = require('child_process').exec;
var cmd = 'curl -XPOST https://api.twilio.com/2010-04-01/Accounts/#####Twilio ACCOUNT SID#####/Calls ' +
'--data-urlencode "Url=' + url + '" ' +
'--data-urlencode "To=+81xxxxxxxxxx" ' +
'--data-urlencode "From=+81xxxxxxxxxx" ' +
'-u "#####Twilio ACCOUNT SID#####:#####Twilio AuthToken#####"';
exec(cmd, function(error, stdout, stderr) {
if (! error) {
console.log('standard out: ' + stdout);
console.log('standard error: ' + stderr);
context.done();
} else {
console.log('error code: ' + error.code);
console.log(error);
context.fail();
}
});
};
以下の値をセットする。
| 設定項目 | 値 |
|---|---|
| To | かける相手（≒上司）の電話番号の、頭一桁を除いた番号を設定する |
| From | Twilioで取得した番号を設定 |
| ACCOUNT SID | TwilioのACCOUNT SID |
| AUTH TOKEN | TwilioのAUTH TOKEN |
Amazon Aurora用のRoleの作成
次にまずは、Auroraに設定するRoleを作成します。
- 名前：forAuroraToLambda
- アクセス許可タブのところで、「AWSLamdbaRole」をアタッチ
- 信頼関係タブの編集のところで、"rds.amazonaws.com"をServiceの所に追加
DBインスタンスの作成
| 設定項目 | 値 |
|---|---|
| エンジン | Amazon Aurora（当然ｗ） |
| パブリックアクセス可能 | はい |
| Subnet | Publicで・・・ |
後は適当に。
クラスターにIAMロールを紐付け
- クラスターの画面の上部にある「IAMロールの管理」をクリックする
- そこで先程作成した「forAuroraToLambda」を選択し、完了
DB Cluster Parameter Groupの作成
つぎに「DB Cluster Parameter Group」を作成します。
- 新規で「DB Cluster Parameter Group」を「forLambda」で作成
- パラメータの編集で、「aws_default_lambda_role」の値に、先程作成したRoleのARN（↓のようなやつ）を設定
「arn:aws:iam::xxxxxxxxxx:role/forAuroraToLambda」 - インスタンスの編集画面で、「DB クラスターのパラメータグループ」の値を、「forLambda」に変更
- 再起動
Database、Tableの作成
//Database
create database test;
//Table
create table users (id int auto_increment primary key, name char(100));
ストアード・プロシージャーの作成
DROP PROCEDURE IF EXISTS lambda_test;
DELIMITER ;;
CREATE PROCEDURE lambda_test(IN message VARCHAR(255)) LANGUAGE SQL
BEGIN CALL mysql.lambda_async(
// ↓ここに先程作成したLambdaのARNを設定する
'arn:aws:lambda:ap-northeast-1:xxxxxxxxxx:function:helloTwilio',
CONCAT('{"message":"', to_base64(message), '"}')
);
END
;;
DELIMITER ;
トリガーの作成
// Insert用
DROP TRIGGER IF EXISTS insert_trigger;
DELIMITER ;;
CREATE TRIGGER insert_trigger
AFTER INSERT ON users
FOR EACH ROW
BEGIN
CALL lambda_test('いけてるやん');
END
;;
DELIMITER ;
// Delete用
DROP TRIGGER IF EXISTS delete_trigger;
DELIMITER ;;
CREATE TRIGGER delete_trigger
AFTER DELETE ON users
FOR EACH ROW
BEGIN
CALL lambda_test('あかんがな');
END
;;
DELIMITER ;
では、実際にやってみよう
直接UsersテーブルにレコードをInsertします。
// 会員追加
insert into users(name) values ('hoge');
お褒めの電話がかかりましたか？
// 会員退会処理
delete from users where id = nnn;
お叱りの電話がかかりましたか？
まとめ
Databaseのストアード・プロシージャーからLambdaを呼び出せることにより、様々な連携の実装コストが格段に下がるかもしれません。
ただ、2000年代前半のストアド地獄の二の舞いにならないよう、節度を持って使っていきましょう！
参考
http://dev.classmethod.jp/cloud/aws/invoke-lambda-from-aurora/
http://docs.aws.amazon.com/ja_jp/AmazonRDS/latest/UserGuide/Aurora.Lambda.html
http://aws.typepad.com/aws_japan/2016/02/access-resources-in-a-vpc-from-your-lambda-functions.html