S3にcreateObjectをトリガーにLambdaを起動するCloudformationテンプレート

にゃー

2019.02.12

この記事は公開されてから1年以上経過しています。情報が古い可能性がありますので、ご注意ください。

はじめに

こんにちは、中村です。

S3にオブジェクトをPutしたタイミングで、Lambdaをキックしたいケースがあるかと思います。手で作成する場合は、Lambda上でトリガーを設定することで問題ないですが、ありがちな構成なのでCloudformationで作成しました。

テンプレート

作成するリソースはこちらです。

Lambdaロール
Lambda
Lambdaパーミッション
S3バケット

今回のLambdaは、S3にオブジェクトをPutした後、txtファイルの場合発火しLambdaを起動します。 Lambdaは、S3のファイルの中身を確認します。そのため、ロールには、S3の読み込み権限・CloudWatchLogsのフル権限を与えます。

Lambdaのコードは、S3バケットにzipを元に作成します。このソースをzipしてバケットにPutしておきます。

const Aws = require('aws-sdk');
const S3 = new Aws.S3();

exports.handler = async(event) => {
    console.log(JSON.stringify(event));
    let param = {
        "Bucket": event.Records[0].s3.bucket.name,
        "Key": event.Records[0].s3.object.key
    };

    let data = S3.getObject(param).promise();
    console.log(data.Body.toString());

    return { statusCode: 200 };
}

パーミッションは、S3イベント通知を登録する前に、適切なアクセス権限が必要です。S3バケット名はRefを利用して参照したいところですが、循環依存になってしまいます。そのため静的にバケット名を記載します。

---
AWSTemplateFormatVersion: "2010-09-09"
Description: "Test resources."
Resources:
  TriggerLambdaRole:
    Type: "AWS::IAM::Role"
    Properties:
      AssumeRolePolicyDocument:
        Version: "2012-10-17"
        Statement:
          - Effect: Allow
            Principal:
              Service:
                - lambda.amazonaws.com
            Action:
              - "sts:AssumeRole"
      ManagedPolicyArns: 
        - "arn:aws:iam::aws:policy/AmazonS3ReadOnlyAccess"
        - "arn:aws:iam::aws:policy/CloudWatchLogsFullAccess"
      RoleName: "trigger_lambda_role"
  TriggerLambda:
    Type: "AWS::Lambda::Function"
    Properties:
      Code:
        S3Bucket: "CODE-BUCKET-HERE"
        S3Key: "lambda.zip"
      FunctionName: "trigger_lambda"
      Handler: "index.handler"
      MemorySize: 128
      Role: !GetAtt "TriggerLambdaRole.Arn"
      Runtime: "nodejs8.10"
      Timeout: 5
  TriggerLambdaPermission:
    Type: "AWS::Lambda::Permission"
    Properties:
      Action: "lambda:InvokeFunction"
      FunctionName: !GetAtt 
        - TriggerLambda
        - Arn
      Principal: "s3.amazonaws.com"
      SourceArn: !Join 
                  - ""
                  - - "arn:aws:s3:::"
                    - "TRIGGER-BUCKET-NAME-HERE"
  SrcS3Bucket:
    Type: "AWS::S3::Bucket"
    DependsOn: "TriggerLambdaPermission"
    Properties:
      BucketName: "TRIGGER-BUCKET-NAME-HERE"
      NotificationConfiguration:
        LambdaConfigurations:
          - Event: "s3:ObjectCreated:*"
            Filter:
              S3Key:
                Rules:
                  - Name: suffix
                    Value: txt
            Function: !GetAtt
              - TriggerLambda
              - Arn

"Hello, World."と記載したテキストファイルを作成し、アップロードしましょう。結果をCloudWatchLogsで確認します。