Amazon DynamoDB Streamsから取得したデータをS3に保存する

package main

import (
        "bytes"
        "context"
        "encoding/json"

        "github.com/aws/aws-lambda-go/events"
        "github.com/aws/aws-lambda-go/lambda"
        "github.com/aws/aws-sdk-go/aws"
        "github.com/aws/aws-sdk-go/aws/endpoints"
        "github.com/aws/aws-sdk-go/aws/session"
        "github.com/aws/aws-sdk-go/service/s3"
)

// Handler lambda
func Handler(ctx context.Context, e events.DynamoDBEvent) error {
        for _, record := range e.Records {
                bucket := "seike460"
                s, _ := json.Marshal(record.Change.NewImage)
                key := record.EventID + ".json"
                sess := session.Must(session.NewSession(&aws.Config{
                        Region: aws.String(endpoints.ApNortheast1RegionID),
                }))
                svc := s3.New(sess)
                svc.PutObject(&s3.PutObjectInput{
                        Body:                 bytes.NewReader(s),
                        Bucket:               aws.String(bucket),
                        Key:                  aws.String(key),
                        ACL:                  aws.String("private"),
                        ServerSideEncryption: aws.String("AES256"),
                })
                return nil
        }
        return nil
}

func main() {
        lambda.Start(Handler)
}