はじめに

いろいろと連番を作る機会があると思います。

手元にDBサーバがあれば、あんまり苦労をしなくていいのですが、遠隔地だったり接続元のネットワークが別だったりするとちょっと手間になってしまいます。その手間をAWS API GatewayとLambdaとDynamoDBでどうにかしたいと思い、Node.jsの勉強をしつつ作ってみました。

ID単位で番号を発番できるので、「伝票番号を発番する」「その日の入場人数をカウントする」などにつかえて便利です。

準備

DynamoDBにテーブルを作る。

テーブル名：好きな名前をつけて下さい。ここでは、numbering-publicというテーブル名にしました。
プライマリーキー：keyidにしました。変更する場合は、コードの該当箇所も変更してください。

テーブル作成後、しばらくするとテーブルの概要が確認できます。"Amazon リソースネーム（ARN）"arn:aws:dynamodb:ap-northeast-1:999999999999999:table/numbering-publicをメモしておきましょう。後で使います。

Lambdaを作る

名前：好きな名前をつけて下さい。ここでは、numbering-qiitaという名前に。
ランタイム：node.js 6.10
ロール：テンプレートから新しいロールを作成
ロール名：好きな名前をつけて下さい。ここでは、lambda-numbering-qiitaという名前に。
ポリシーテンプレート：S3 オブジェクトの読み取り専用アクセス権限を仮に設定しました。

ロール＆ポリシーの編集

いまのままではDynamoDBに接続できないので、ロール＆ポリシーを調整します。
1. さきほど作成したロール：lambda-numbering-qiitaを開いて「インラインポリシーの追加」から追加していきます。
2. Policy Generatorを選択
3. Policy Generatorで必要事項を埋めて、「ステートメントを追加」

効果：許可
AWS サービス：Amazon DynamoDB
アクション：すべてのアクション(*) ※本当は最小限のアクションのみを付けたほうがよいです
Amazon リソースネーム（ARN）：arn:aws:dynamodb:ap-northeast-1:999999999999999:table/numbering-public ← DynamoDBを作ったときにメモしたARNです

すべての入力が終わったら「ステートメントを追加」してください。その後「次のステップ」へ。

ポリシーの確認画面が表示されるので、確認して、必要に応じて編集して「ポリシーの適用」

AWS API GatewayでAPIを作る

API名：好きな名前をつけて下さい。ここでは、numbering-qiitaという名前に。
説明：後で見て判別/判断できる説明を書きましょう。
エンドポイント：エッジ最適化。ごめんなさい、エッジ最適化と地域、どちらがいいかわかりません。

アクションから「リソースの作成」をする

プロキシリソースとして設定：チェックなし
リソース名：keyid
リソースパス：{keyid} ※中括弧{}でくくることでパラメータ変数として扱えます。
API Gateway CORS を有効にする：チェックなし

{keyid} - GET - セットアップ

統合タイプ：Lambda 関数
Lambda プロキシ統合の使用：チェックあり
Lambda リージョン：Lambdaを作ったリージョンを指定してください
Lambda 関数：numbering-qiita
デフォルトタイムアウトの使用：チェックあり

APIのデプロイ

デプロイされるステージ：[新しいステージ]
ステージ名：v1。好きな名前をつけて下さい。
ステージの説明：分かりやすい説明を
デプロイメントの説明：分かりやすい説明を

APIのステージ

ステージ変数から「ステージ変数の追加」をします。

名前：tablename。DynamoDBのテーブル名を設定するためLambda関数内で使用しています。
値：numbering-public。DynamoDBのテーブル名。

Lambda関数を仕上げる

連携の確認

左側に「API Gateway」、右に「Amazon DynamoDB」が追加されていればOKです。

ソースコード

index.js

"use strict";

var AWS = require('aws-sdk');
var documentClient = new AWS.DynamoDB.DocumentClient();

function asyncPutDb(tablename, hashKey) {

 return new Promise(function(resolve, reject) {
  var params = {
   TableName: tablename,
   Item: {
    keyid: hashKey,
    countindex: 1
   }
  };

  documentClient.put(params, function(err, data) {
   if (err) {
    reject("asyncPutDb");
   }
   else {
    resolve(1);
   }
  });
 });
}

function asyncUpdateDb(tablename, hashKey) {

 return new Promise(function(resolve, reject) {
  var params = {
   TableName: tablename,
   Key: {
    "keyid": hashKey
   },
   UpdateExpression: "set countindex = countindex + :addvalue",
   ExpressionAttributeValues: {
    ":addvalue": 1
   },
   ReturnValues: 'UPDATED_NEW'
  };

  documentClient.update(params, function(err, data) {
   if (err) {
    resolve(-2);
   }
   else {
    resolve(data.Attributes.countindex);
   }
  });
 });
}

function setResultJson(hashKey, countindex) {
 return {
  keyid: hashKey,
  countindex: countindex
 };
}

exports.handler = (event, context, callback) => {

 var response = {
  statusCode: 200,
  headers: { "Access-Control-Allow-Origin": "*" },
  body: {
   keyid: event.pathParameters.keyid,
   countindex: -1
  }
 };

 console.log("tablename:", event.stageVariables.tablename);
 console.log("keyid:", event.pathParameters.keyid);

 asyncUpdateDb(event.stageVariables.tablename, event.pathParameters.keyid)
  .then(function(resultUpdate) {
   if (resultUpdate > 0) {
    console.log("resultUpdate:", resultUpdate);
    response.body = JSON.stringify(setResultJson(event.pathParameters.keyid, resultUpdate));
    callback(null, response);
   }
   else {
    asyncPutDb(event.stageVariables.tablename, event.pathParameters.keyid, response)
     .then(function(resultPut) {
      console.log("resultPut:", resultPut);
      response.body = JSON.stringify(setResultJson(event.pathParameters.keyid, resultPut));
      callback(null, response);
     })
     .catch(function(err) {
      console.log("put error:", err);
      callback(null, JSON.stringify(err));
     });
   }
  });
};

保存を忘れずに。最新版のコードはgistに掲載しています。

テスト用Json

testcode

{
  "pathParameters": {
    "keyid": "abc1"
  },
  "stageVariables": {
    "tablename": "numbering-public"
  }
}

試してみる。

Lambdaでのテスト

テスト用Jsonを登録後、「テスト」実行。

1回目

2回目

ちゃんと採番されてます。

API Gatewayでのテスト

……テストしたいのですが、うまくステージ変数が反映されていないようでメソッドのテストができませんでした。

ブラウザでのテスト

API Gatewayの作成したステージを選択後、上部に「URL の呼び出し」が表示されています。このURLをそのまま開くと{"message":"Missing Authentication Token"}エラーが出ますが、URLの後ろに/qiita-testなどを追加すると動きます。

-https://XXXXXXXXXX.execute-api.ap-northeast-1.amazonaws.com/v1
+https://XXXXXXXXXX.execute-api.ap-northeast-1.amazonaws.com/v1/qiita-test

1回目

{"keyid":"qiita-test","countindex":1}

2回目

{"keyid":"qiita-test","countindex":2}