1. まとめ

クライアントからAPI GatewayにPOSTされたバイナリデータをLambdaで何かしらの処理を実施する方法を記載する．ここでは，実例としてバイナリデータとして画像ファイルを受け取り，Lambdaにて画像をS3に保存する方法を記載する．

2. 目次

1 まとめ
2 目次
3 簡易処理フロー
4 実装
- 4.1 Lambda
- 4.2 API Gateway
5 テスト
6 参考リンク

3. 簡易処理フロー

API Gateway
- バイナリメディアタイプにてimage/*を設定しバイナリを扱えるよう設定
Lambda
- Base64にエンコードされたデータをデコードし画像ファイルのバイナリーデータを取得
- 画像をS3に保存
S3
- 画像を格納

4. 実装

　
下記のcURLで叩いて，S3に画像が保存されていればOK

$ curl -X POST -H 'Content-type: image/jpeg' --data-binary "@ramen.jpeg" https://xxxxxxxxxxxxx.execute-api.ap-northeast-1.amazonaws.com/v1/upload

4.1. Lambda

コード全体

'use strict';

const aws = require('aws-sdk');
const s3 = new aws.S3({ apiVersion: '2006-03-01'});

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

    // add logging level
    console.log = console.log.bind(null, '[LOG]');
    console.info = console.info.bind(null, '[INFO]');
    console.warn = console.warn.bind(null, '[WARN]');
    console.error = console.error.bind(null, '[ERROR]');

    // variables
    var response = {}

    // check event
    console.log(event)

    // if data is encoded with base64, then decode with base64 and save it in S3
    if (event.isBase64Encoded === true) {

        // decode
        var decode = new Buffer(event.body,'base64');

        // save data in s3
        var params = {
                        Bucket: 's3-xxxxxxxxxxxxxxx-20180702', 
                        Key: 'ramen.jpg', 
                        ContentType: 'image/jpeg', 
                        Body: decode
                    };
        s3.putObject(params, function(err, data) {
            if (err) {
                console.error(err);
                console.error('image upload failed');

                // create response
                response.statusCode = 400
                response.body = JSON.stringify({
                    message: 'fail.'
                })
                callback(null, response);

            } else {
                console.log('image upload success');

                // create response
                response.statusCode = 200
                response.body = JSON.stringify({
                    message: 'image has been uploaded to S3'
                })
                callback(null, response);
            }
        });

    } else {

        // create response
        response.statusCode = 400
        response.body = JSON.stringify({
            message: 'fail.'
        })
        callback(null, response);
    }
};

補足

eventの中身の確認

下記でCloudWatchにログとして書き出す

    // check event
    console.log(event)

下記が結果．重要な部分だけ抽出．
①event.bodyがbase64でencodeされた画像データ
②event.isBase64Encodedがtrueになっておりbase64でバイナリデータをエンコードされているのがわかる

body: '/9j/4AAQSkZJRgABAQAASABIAAD/99b06vJCFQ+N .. 省略 ... h/9k=',
isBase64Encoded: true

デコード

base64でエンコードされていることを確認し，デコードnew Buffer(event.body,'base64')を実施

    // if data is encoded with base64, then decode with base64 and save it in S3
    if (event.isBase64Encoded === true) {
        // decode
        var decode = new Buffer(event.body,'base64');

4.2. API Gateway

バイナリメディアタイプを設定しない場合のレスポンス

$ curl -X POST -H 'Content-type: image/jpeg' --data-binary "@ramen.jpg" https://xxxxxxxxxxxxx.execute-api.ap-northeast-1.amazonaws.com/v1/upload

{"message":"fail"}

バイナリメディアタイプにimage/*を追加し変更を保存．ステージに反映するには再度APIをデプロイする必要がある．

バイナリメディアタイプを設定した場合のレスポンス

image/*が登録されているため，image/jpegが通る．

$ curl -X POST -H 'Content-type: image/jpeg' --data-binary "@ramen.jpg" https://xxxxxxxxxxxxx.execute-api.ap-northeast-1.amazonaws.com/v1/upload

{"message":"image has been uploaded to S3"}

適当にimage/*以外にContent-typeを設定してみると，エラーになる．想定通りの挙動

$ curl -X POST -H 'Content-type: text/plain' --data-binary "@ramen.jpg" https://xxxxxxxxxxxxx.execute-api.ap-northeast-1.amazonaws.com/v1/upload

{"message":"fail"}

Content-typeを外してみてもエラーになる．想定通りの挙動

$ curl -X POST --data-binary "@ramen.jpg" https://xxxxxxxxxxxxx.execute-api.ap-northeast-1.amazonaws.com/v1/upload

{"message":"fail"}

5. テスト

cURLで叩いてみる

$ curl -X POST -H 'Content-type: image/jpeg' --data-binary "@ramen.jpg" https://xxxxxxxxxxxxx.execute-api.ap-northeast-1.amazonaws.com/v1/upload

{"message":"image has been uploaded to S3"}

S3に保存されていることを確認

6. 参考リンク

なし

API Gateway+Lambdaでバイナリデータを処理