我有以下lambda函数代码,用于简单地打印出S3存储桶的已上传事件的作者和元数据:
from __future__ import print_function import json import urllib import boto3 print('Loading function') s3 = boto3.client('s3') def lambda_handler(event, context): #print("Received event: " + json.dumps(event, indent=2)) # bucket = event['Records'][0]['s3']['bucket']['name'] for record in event['Records']: bucket = record[0]['s3']['bucket']['name'] key = record[0]['s3']['object']['key'] response = s3.head_object(Bucket=bucket, Key=key) logger.info('Response: {}'.format(response)) print("Author : " + response['Metadata']['author']) print("Description : " + response['Metadata']['description'])
但是,测试时出现以下错误:
{ "stackTrace": [ [ "/var/task/lambda_function.py", 17, "lambda_handler", "for record in event['Records']:" ] ], "errorType": "KeyError", "errorMessage": "'Records'" }
访问S3对象的存储桶名称和键名时,我做错什么了吗?如果没有,那我在做什么错呢?
晚会有点晚。但是,这是我的第一篇文章!
说明:
在lambda面板中测试时-> def lambda_handler(event,context)<-事件将直接注入。
但是,在AWS API中, 添加映射模板 或其他必需的->事件<-为空,因此导致测验:
“ errorType”:“ KeyError”,“ errorMessage”:“’记录’”
这是空指针。记录不存在,因为->事件<-不存在。
解:
您需要在AWS API中配置 Integration Request 。单击“ 人体贴图模板” 。然后 将映射模板 集内容类型 添加 到 application / json, 然后编辑生成的映射模板:
{ "body" : $input.json('$'), "headers": { #foreach($header in $input.params().header.keySet()) "$header": "$util.escapeJavaScript($input.params().header.get($header))" #if($foreach.hasNext),#end #end }, "method": "$context.httpMethod", "params": { #foreach($param in $input.params().path.keySet()) "$param": "$util.escapeJavaScript($input.params().path.get($param))" #if($foreach.hasNext),#end #end }, "query": { #foreach($queryParam in $input.params().querystring.keySet()) "$queryParam": "$util.escapeJavaScript($input.params().querystring.get($queryParam))" #if($foreach.hasNext),#end #end } }
并 编辑Lambda函数 :
更换:
用于事件[‘Records’]中的记录:
与:
记录事件[‘query’] [‘Records’]
不知道堆栈是否会用这个答案对您执行ping操作-所以我称呼您@ Dawny33 @KevinOelen @franklinsijo
至于解释,我自己想了一下。但是,“映射模板”来自https://medium.com/simple-thoughts-amplified/passing- variables-from-aws-api-gateway-to- lambda-3c5d8602081b