Lambda 実装例: S3 へのアップロードを SNS で通知して Lambda から読み込む

$ npm install aws-sdk --save-dev
$ npm install @types/aws-lambda --save-dev

import { S3 } from 'aws-sdk';
const s3 = new S3();

/** S3 バケット内のオブジェクト（テキスト）を読み込んでその内容を返します。 */
export async function getS3Object(
    bucketName: string,
    objectKey: string
): Promise<string | undefined> {
    const output: S3.GetObjectOutput = await s3.getObject({
        Bucket: bucketName,
        Key: objectKey,
    }).promise();
    return output.Body?.toString();
}

// テスト用 main 関数
if (require.main === module) (async () => {
    try {
        const bucket = 'bucket-123456789012-sample';
        const key = 'sample.txt';
        const body = await getS3Object(bucket, key);
        console.log(body);
    } catch (e) {
        console.err(e);
    }
})();

import { SNSEvent, Context, Callback } from 'aws-lambda';
import * as s3util from './s3util';

/** SNS トピックの通知から抽出する S3 メタ情報 */
type BucketMeta = {
    /** S3 のイベント名 (例: `ObjectCreated:Put`) */
    eventName: string,
    /** S3 バケット名 */
    bucketName: string,
    /** S3 バケット内のオブジェクトキー */
    objectKey: string,
};

/** Lambda 関数に渡されるイベントデータから S3 のメタ情報を取得します。 */
function parseSnsEvent(snsEvent: SNSEvent): BucketMeta {
    const msg = JSON.parse(snsEvent.Records[0].Sns.Message) as any;
    return {
        eventName: msg.Records[0].eventName,
        bucketName: msg.Records[0].s3.bucket.name,
        objectKey: msg.Records[0].s3.object.key,
    } as BucketMeta;
}

/** Lambda 関数のエントリポイントです。 */
export async function handler(event: SNSEvent, ctx: Context, callback: Callback) {
    try {
        const meta: BucketMeta = parseSnsEvent(event);
        const body = await s3util.getS3Object(meta.bucketName, meta.objectKey)
        console.log(meta);
        console.log(body);
        callback(null, body);
    } catch (e) {
        console.error(e);
        callback(e);
    }
}

AWSTemplateFormatVersion: 2010-09-09
Transform: AWS::Serverless-2016-10-31

Parameters:
  TopicArn:
    Type: String
    Default: arn:aws:sns:ap-northeast-1:123456789012:mytopic
  BucketName:
    Type: String
    Default: bucket-123456789012-sample

Resources:
  MyFunction:
    Type: AWS::Serverless::Function
    Properties:
      Runtime: nodejs14.x
      Handler: build/index.handler
      CodeUri: function.zip

      # S3 にアクセスするための権限（ポリシー）をロールに追加
      Policies:
        - S3CrudPolicy:
            BucketName: !Ref BucketName

      # この Lambda 関数を SNS トピックにサブスクライブする
      Events:
        MySnsEvent:
          Type: SNS
          Properties:
            Topic: !Ref TopicArn

{
  "name": "function",
  "version": "0.0.1",
  "scripts": {
    "start": "node build/index.js",
    "build": "tsc",
    "build:watch": "tsc --watch",
    "zip": "npm-pack-zip",
    "cf:package": "aws cloudformation package --template-file template.yml --output-template-file template.packaged.yml --s3-bucket bucket-123456789012-functions",
    "cf:deploy": "aws cloudformation deploy --stack-name mystack --template-file template.packaged.yml --capabilities CAPABILITY_IAM"
  },
  "files": [
    "build"
  ],
  "bundledDependencies": [],
  "devDependencies": {
    "@types/aws-lambda": "^8.10.75",
    "@types/node": "^14.14.35",
    "npm-pack-zip": "^1.2.9",
    "typescript": "^4.2.3"
  },
  "dependencies": {
    "aws-sdk": "^2.884.0"
  }
}

$ npm run install     # 依存パッケージのインストール
$ npm run build       # ビルド（トランスパイル）
$ npm run zip         # ビルド結果を ZIP 化
$ npm run cf:package  # ZIP をアップロード
$ npm run cf:deploy   # デプロイ（CloudFormation スタックを生成）