[AWS×Node.js] AWS Lambda(Node.js)で他のサービスと連携する(2018年版)

はじめに

この記事は AWS Advent Calendar 2018 の7日目の記事です。
去年のアドベントカレンダーで「AWSLambdaとその他のサービスを組み合わせていろんなことをしてみる」という記事を書いたのですが、今年も1年間でLambdaのアップデートがあったので、2018年版という形で記事を書いていきます。

AWSLambdaアップデートまとめ

今年あったLambdaのアップデートの中で個人的に印象が強かったものを上げてみます。

1. Node.js v8.10 に対応
2. Golang に対応
3. 実行時間が 最大15分 に延長

といった感じです。
この他にもre:Inventで様々なアップデートがありましたね！
ランタイムにRubyを選択できるようになったり、CustomRuntimeで様々な言語をサポートしたり、ALB経由でinvokeできるようになったりと、まだまだLambdaは進化していくんだなと実感しました。

1. Node.js v8.10に対応

Node.jsユーザーの私からすると、Node.js8系への対応はかなり嬉しいものがありました。
なんと言っても async/await をLambdaでつ使えることで、非同期処理周りの書き方がとても楽になりましたね。
これについては「AWS LambdaがNode.js8.10をサポートしたのでasync/awaitを試してみた」でまとめてますので、よかったら見てあげてください。

今回の記事はNode.js v8.10で他のサービスと連携する内容を深掘りしていこうと思います。

2. Golangに対応

ちょっとGolangに興味があった時期にこのアップデートがあったので、試しに触ってみました。
「AWSLambdaがGo言語に対応したのでDynamoDBと絡ませながらデモってみた」でまとめてますので、よかったら見てあげてください。
DynamoDBに対して、GetItem / PutItem / Queryを実行しています。

3. 実行時間が最大15分に延長

今まで5分が最長だった実行時間が15分に延長されました。
これによって、より長くLambdaの中で処理を実行することができるようになったので、ちょっとしたバッチ処理などを実行させるのに有効かと思います。
ですが、個人的にはLambdaの中であまり長い処理を実行することはおすすめできません。

他のサービスと連携する

AWSLambdaを単体で利用される方はほとんどいないと思います。
LambdaからS3にテキストを保存したり、DynamoDBのデータを操作したり、SESやSNSのトリガーになったり……といろんなサービスと連携すると思います。
今回はS3 / DynamoDB / SES と連携する際のNode.jsの書き方をまとめていきます。

S3

S3とはゴミ箱…ではなく、安価で高可用性なファイルストレージです。
主にテキストや画像データを保存するのに適しています。S3に保存しておくと、自動的に3箇所に複製されます。また、保存されているファイルに対してURLが付与されるので、取り出すのにもハードルが低いのが特徴です。

ファイルを取得する(getObject)

"use strict";
const AWS = require("aws-sdk");
const S3 = new AWS.S3();

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

    // パラメータ生成
    const getParams = {
      Bucket: "BucketName",
      Key: "objectKey.json"
    }

    // S3にGETするSDK(API)実行
    const obj = await S3.getObject(getParams).promise();

    return obj;
  } catch (err) {
    throw err;
  }
};

ファイルを保存する(putObject)

"use strict";
const AWS = require("aws-sdk");
const S3 = new AWS.S3();

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

    // JSON文字列作成
    const jsonFile = [{
      id: "12345",
      value: "1111"
    },{
      id: "67890",
      value: "2222"
    }];

    // パラメータ生成
    const purParams = {
      Bucket: "BucketName",
      Key: "sample.json",
      Body: JSON.stringify(jsonFile)
    }

    // S3にPUTするSDK(API)実行
    await S3.putObject(purParams).promise();

    return null;
  } catch (err) {
    throw err;
  }
};

DynamoDB

DynamoDBはNoSQLのデータベースです。SQL文を生成してデータを操作するのではなく、API経由でデータの操作を行います。
今年はデータのバックアップ機能(PITR)やグローバルテーブルなどの大型アップデートがあったりと、最近Hotなサービスの一つです。

想定テーブル

テーブル名: sensorDataTable

sensor_id	record_time	value
a001	2018-12-07T00:00:00+09:00	10
a001	2018-12-07T00:10:00+09:00	17
a001	2018-12-07T00:20:00+09:00	20
a001	2018-12-07T00:30:00+09:00	14
a001	2018-12-07T00:40:00+09:00	10
…	…	…

データを取得する(query)

"use strict";
const AWS = require("aws-sdk");
const dynamoDB = new AWS.DynamoDB.DocumentClient(config);

exports.handler = async (event, context, callback) => {
  try {
    // パラメータ生成
    // テーブル sensorDataTable に対して sensor_id が a001 のデータを
    // record_time が 2018-12-07T00:00:00+09:00から昇順で100件取得する
    const params = {
      TableName: "sensorDataTable",
      KeyConditionExpression: "#hash_key = :hash_key AND #range_key >= :range_key",
      ExpressionAttributeNames: {
        "#hash_key": "sensor_id",
        "#range_key": "record_time" 
      },
      ExpressionAttributeValues: {
        ":hash_key": "a001",
        ":range_key": "2018-12-07T00:00:00+09:00"
      }, // 
      ScanIndexForward: true, // データの参照を昇順でするか、降順するか。 true: 昇順 /　false: 降順
      Limit: 100 // 取得するレコード数の上限
    };

    // DynamoDBからデータを取得するSDK(API)実行
    return await dynamoDB.query(params).promise();
  } catch (err) {
    throw err;
  }
}

データを保存する(put)

"use strict";
const AWS = require("aws-sdk");
const dynamoDB = new AWS.DynamoDB.DocumentClient(config);

exports.handler = async (event, context, callback) => {
  try {
    // パラメータ生成
    // テーブル sensorDataTable に対して sensor_id が a001 のデータを保存する
    const params = {
      TableName: "sensorDataTable"
      Item: {
        sensor_id: "a001",
        record_time: "2018-12-07T12:00:00+09:00",
        value: 25
      }
    };

    // DynamoDBからデータを保存するSDK(API)実行
    return await dynamoDB.put(params).promise();
  } catch (err) {
    throw err;
  }
}

SES

SESはメールを送信してくれるサービスです。
S3やDynamoDBに比べると使用する場面は少ないと思いますが、私はよく利用しています。

"use strict";
const AWS = require("aws-sdk");
const ses = new AWS.SES;

exports.handler = async (event, context, callback) => {
  try {
    // パラメータ生成
    // テーブル sensorDataTable に対して sensor_id が a001 のデータを保存する
    const params = {
      Source: "[e-mail]",
      Destination: {
        ToAddresses: ["[e-mail]"]
      },
      Message: {
        Subject: {
          Data: "メールのタイトル"
        },
        Body: {
          Text: {
            Data: "メールの本文"
          }
        }
      }
    };

    // メールを送信するSDK(API)実行
    return await ses.sendEmail(params).promise();
  } catch (err) {
    throw err;
  }
}

まとめ

今回はLambdaからその他のサービスと連携するサンプルをまとめました。LambdaはAWSの他のサービスとの親和性がかなり高いサービスです。S3やDynamoDBなどのデータレイクに格納する前にちょっと加工したり、SESなどのトリガーになったりします。
AWSLambdaは直接invokeしようとするとクレデンシャルを持たせないといけないのですが、Lambdaの前段にAPIGatewayを挟むこととで、Lambdaをinvokeするためのクレデンシャルを持たずにinvokeすることができます。
ではまた！