AWS Lambdaのレスポンス上限6MBへの対策と413エラーの解消

LAMBDA_RUNTIME Failed to post handler success response. Http response code: 413.

LAMBDA_RUNTIME Failed to post handler success response. Http response code: 413.

serverless create --template aws-nodejs --path s3-tasks-bucket
cd s3-tasks-bucket

service: s3-tasks-bucket
frameworkVersion: "3"

provider:
  name: aws
  runtime: nodejs18.x
  region: ap-northeast-1
  versionFunction: false
  logRetentionInDays: 1
  iamRoleStatements:
    - Effect: Allow
      Action:
        - s3:PutObject
        - s3:GetObject
        - s3:DeleteObject
      Resource: arn:aws:s3:::${self:service}/*
    - Effect: Allow
      Action:
        - s3:ListBucket
      Resource: arn:aws:s3:::${self:service}

custom:
  defaultStage: dev

resources:
  Resources:
    MyS3Bucket:
      Type: AWS::S3::Bucket
      Properties:
        BucketName: ${self:service}
        # ライフサイクル設定(有効期限1日)
        LifecycleConfiguration: 
          Rules:
            - Status: Enabled
              ExpirationInDays: 1
              AbortIncompleteMultipartUpload:
                DaysAfterInitiation: 1
        # CORSの設定
        CorsConfiguration:
          CorsRules:
            - AllowedOrigins:
                - "*"
              AllowedMethods:
                - GET
              AllowedHeaders:
                - "*"
              MaxAge: 3000

import json
import boto3
import base64
import os
import ulid

s3 = boto3.client('s3')
BUCKET_NAME = os.environ.get('BUCKET_NAME', 's3-tasks-bucket')

def handler(event, context):
  try:
    file_id = str(ulid.new())
    file_name = f"tasks-{file_id}.json"
    # eventに直接、json.dumps(response)を受け取る
    file_content = json.dumps(event, indent=4)
    # ファイルをアップロード
    s3.put_object(Bucket=BUCKET_NAME, Key=file_name, Body=file_content,)
    # 署名付きURLの発行
    presigned_url = s3.generate_presigned_url(
      'get_object',
      Params={'Bucket': BUCKET_NAME, 'Key': file_name},
      ExpiresIn=300  # 5min
    )
    return {
      'statusCode': 200,
      'body': json.dumps({'message': 'file uploaded successfully!', 'fileName': file_name, 'presignedUrl': presigned_url})
    }
  except Exception as e:
    return {
      'statusCode': 500,
      'body': json.dumps({'message': 'Failed to save result to S3', 'error': str(e)})
    }

def json_serial(obj):
	if isinstance(obj, (datetime, date)):
		return obj.isoformat()
	raise TypeError ("Type %s not serializable" % type(obj))

@logger.inject_lambda_context()
def handler(event, context=LambdaContext):
	## ----略----
    ## RDSからTodoタスクを取得しています。
    tasks = {
		"before":[],
		"working":[],
		"done":[]
	}
	print(json.dumps(tasks, default=json_serial))
 	return {
     'statusCode': 200,
     'headers': {
       "Access-Control-Allow-Origin": "*"
     },
     'body': json.dumps(presigned_url_response, default=json_serial)
   }

def json_serial(obj):
	if isinstance(obj, (datetime, date)):
		return obj.isoformat()
	raise TypeError ("Type %s not serializable" % type(obj))
	
def invoke_response_export_lambda(response): # 今回追加した関数
    lambda_arn = os.environ['RESPONSE_EXPORT_AND_UPLOAD_S3_PRESIGNED_URL_ARN']
    # responseをJSONに変換
    payload = json.dumps(response, default=json_serial)  
    # Lambda関数をinvoke
    response = boto3.client('lambda').invoke(
        FunctionName=lambda_arn,
        InvocationType='RequestResponse',
        Payload=payload
    )
    # 結果を取得
    response_payload = json.loads(response['Payload'].read())
    # 結果を返す
    if response_payload.get('statusCode') == 200:
        presigned_url = json.loads(response_payload['body']).get('presignedUrl')
        return {
            'statusCode': 200,
            'presignedUrl': presigned_url
        }
    else:
        return {
            'statusCode': response_payload.get('statusCode', 500),
            'message': 'Failed to get presigned URL'
        }

@logger.inject_lambda_context()
def handler(event, context=LambdaContext):
		tasks = {
		    "before":[],
		    "working":[],
		    "done":[]
		}
	print(json.dumps(tasks, default=json_serial))
	
	## tasksを引数に入れ、presignedURLを返す関数を実行
	presigned_url_response = invoke_response_export_lambda(tasks)
	print('Presigned URL: ', presigned_url_response)
	if presigned_url_response.get('statusCode') == 200:
		presigned_url = presigned_url_response.get('presignedUrl')
		return {
            'statusCode': 200,
			'headers': {
				"Access-Control-Allow-Origin": "*"
			},
            'body': json.dumps({'presignedUrl': presigned_url}, default=json_serial)
        }
	else:
		return {
            'statusCode': 500,
			'headers': {
				"Access-Control-Allow-Origin": "*"
			},
            'body': json.dumps({'message': 'Failed to get presigned URL'}, default=json_serial)
        }

const getTasksFromS3PresignedUrl = async (url, signal) => {
  try {
    console.log('URL', url);
    const response = await fetch(url, { signal });
    if (!response.ok) {
      throw new Error('Network response was not ok');
    }
    const jsonData = await response.json();
    return jsonData;
  } catch (error) {
    console.error('Failed to fetch tasks from S3 presigned URL:', error);
  }
};

response = await API.GetAllTasks(params, signal).then((res) => {
  return getTasksFromS3PresignedUrl(res.presignedUrl, signal);
});