![[PukiWiki]](image/pukiwiki.png "[PukiWiki]")
|
AWSメモ > AWS LambdaからDynamoDBに接続する AWS LambdaからDynamoDBに接続する †
テーブルの作成 †マネージメントコンソールのDynamoDB から以下の通りテーブルを作成する
Lambda関数を作成する †マネージメントコンソールのLambda から、以下の通りLambda関数を作成する。
DynamoDBへのアクセスを AWS.DynamoDB で行うのか AWS.DynamoDB.DocumentClient で行うのかが悩ましいが、 http://docs.aws.amazon.com/AWSJavaScriptSDK/latest/AWS/DynamoDB.html 関数コード 'use strict';
var AWS = require('aws-sdk');
//var dynamodb = new AWS.DynamoDB();
var documentClient = new AWS.DynamoDB.DocumentClient();
const createResponse = (callback, statusCode, body) => {
var res = {
"statusCode": statusCode,
"headers": { "Test-Headr1": "1234" },
"body": JSON.stringify(body)
}
callback(null, res);
}
exports.handler = (event, context, callback) => {
let id = false;
if (event.pathParameters){
id = event.pathParameters.id || false;
}
let req = event.body;
if (typeof(event.body) === "string") {
// TODO: 暫定（JSON文字列を受け取った場合のパース）
let jsonBody = event.body.replace(/=/g,":").replace(/&/g, ",").replace(/([^:,]+):([^:,]*)/g, "\"$1\":\"$2\"");
req = JSON.parse("{"+jsonBody+"}");
}
switch(event.httpMethod){
case "GET":
if(id && id > 0) {
var params = {
TableName : 'Books',
FilterExpression : 'id = :id',
ExpressionAttributeValues : {':id' : parseInt(id,10) }
};
documentClient.scan(params, function(err, data) {
if (err) {
console.log(err);
createResponse(callback, 500, { "msg": "Get Error!", "err": err});
} else {
createResponse(callback, 200, data);
console.log(data);
}
});
return;
} else {
var params = {
TableName : 'Books'
};
documentClient.scan(params, function(err, data) {
if (err) {
console.log(err);
createResponse(callback, 500, { "msg": "List Error!", "err": err});
} else {
createResponse(callback, 200, data);
console.log(data);
}
});
}
break;
case "POST":
var params = {
TableName : 'Books',
Item: {
"id" : parseInt(req.id, 10),
"isbn" : req.isbn,
"title" : req.title,
"price" : parseInt(req.price,10)
}
};
documentClient.put(params, function(err, data) {
if (err) {
console.log(err);
createResponse(callback, 500, { "msg": "Create Error!", "err": err, "req": req});
} else {
createResponse(callback, 200, { "msg": "Create OK!"});
}
});
break;
case "PUT":
var params = {
TableName : 'Books',
Key: { "id" : parseInt(id, 10) },
ExpressionAttributeNames: {
"#isbn" : "isbn",
"#title" : "title",
"#price" : "price"
},
ExpressionAttributeValues: {
":isbn" : req.isbn,
":title" : req.title,
":price" : parseInt(req.price, 10)
},
UpdateExpression: "SET #isbn = :isbn, #title = :title, #price = :price"
};
documentClient.update(params, function(err, data) {
if (err) {
console.log(err);
console.log(data);
createResponse(callback, 500, { "msg": "Update Error!", "err": err});
} else {
createResponse(callback, 200, { "msg": "Update OK!"});
}
});
break;
case "DELETE":
var params = {
TableName : 'Books',
Key: { "id" : parseInt(id, 10) }
};
documentClient.delete(params, function(err, data) {
if (err) {
console.log(err);
console.log(data);
createResponse(callback, 500, { "msg": "Delete Error!", "err": err});
} else {
createResponse(callback, 200, { "msg": "Delete OK!"});
}
});
break;
default:
// Send HTTP 501: Not Implemented
console.log("Error: unsupported HTTP method (" + event.httpMethod + ")");
createResponse(callback, 501, { "msg": "Error: unsupported HTTP method (" + event.httpMethod + ")" } );
}
}
API Gateway の作成 †マネージメントコンソールのAPI GateWay から、以下の通りAPIを作成する。 API 名: lambda-example-api
URI一覧
全メソッドとも以下の設定で作成
作成後は「APIをデプロイ」からデプロイ。 動作確認 †# 一覧検索 curl -v https://エンドポイント/book # 一意検索 curl -v https://エンドポイント/book # 登録 curl -v -XPOST --data "id=1&isbn=A0001&title=test00A&price=1111" https://エンドポイント/book # 更新 curl -v -XPUT --data "isbn=B0001&title=test00B&price=2222" https://エンドポイント/book/1 # 削除 curl -v -XDELETE https://エンドポイント/book/1 |
api-gateway.png