"KeyError: 'Records'" in AWS S3 - Lambda trigger
"KeyError: 'Records'" in AWS S3 - Lambda trigger
我有以下 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 对象的存储桶名称和密钥名称时做错了什么吗?如果不是,那我做错了什么?
晚会有点晚了。但这是我的第一个 post!
解释:
当您在 lambda 面板中测试时 -> def lambda_handler(event, context) <- 直接注入事件。
但是在 AWS API 中需要 添加映射模板 否则 -> 事件 <- 为空,从而导致测验:
"errorType": "KeyError", "errorMessage": "'Records'"
这是空指针。记录不存在,因为 -> 事件 <- 不存在。
解决方案:
您需要在 AWS API 中配置 集成请求 。
单击 Body 映射模板。
然后添加映射模板
将内容类型设置为 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函数:
替换:
for record in event['Records']:
与:
for record in event['query']['Records']
不知道堆栈是否会用这个答案通知你 - 所以我叫你@Dawny33 @KevinOelen @franklinsijo
解释是我自己想的。但是 "mapping template" 来自 https://medium.com/simple-thoughts-amplified/passing-variables-from-aws-api-gateway-to-lambda-3c5d8602081b
我昨天遇到了这个问题,问题是当你 运行 测试时实际上没有任何事件 (def lambda_handler(event, context)) 供 lambda 处理。事件文档通常是在实际事件发生时生成的,它是一个 json 文档,您的 python 代码解析该文档然后检索密钥。所以解决方案是让你通过在 s3 中删除一个文件来创建一个实际的事件,只要你已经创建了事件通知然后它就会被拾取
我也遇到了同样的问题,我们在这里需要做的很简单。 lambda 的区域和创建存储桶/触发器时的区域应该相同。 如果相同,只需将文件上传到 S3 存储桶,就会直接反映到 DynamoDB。
我也遇到了同样的问题,对我有用的是...停止 运行 对 lambda 函数的测试,然后转到您的 s3 存储桶并上传您的 json 文件,一切都会好好地 。相信我,我现在也和你一样头疼..
我有以下 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 对象的存储桶名称和密钥名称时做错了什么吗?如果不是,那我做错了什么?
晚会有点晚了。但这是我的第一个 post!
解释:
当您在 lambda 面板中测试时 -> def lambda_handler(event, context) <- 直接注入事件。
但是在 AWS API 中需要 添加映射模板 否则 -> 事件 <- 为空,从而导致测验:
"errorType": "KeyError", "errorMessage": "'Records'"
这是空指针。记录不存在,因为 -> 事件 <- 不存在。
解决方案:
您需要在 AWS API 中配置 集成请求 。 单击 Body 映射模板。 然后添加映射模板 将内容类型设置为 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函数:
替换:
for record in event['Records']:
与:
for record in event['query']['Records']
不知道堆栈是否会用这个答案通知你 - 所以我叫你@Dawny33 @KevinOelen @franklinsijo
解释是我自己想的。但是 "mapping template" 来自 https://medium.com/simple-thoughts-amplified/passing-variables-from-aws-api-gateway-to-lambda-3c5d8602081b
我昨天遇到了这个问题,问题是当你 运行 测试时实际上没有任何事件 (def lambda_handler(event, context)) 供 lambda 处理。事件文档通常是在实际事件发生时生成的,它是一个 json 文档,您的 python 代码解析该文档然后检索密钥。所以解决方案是让你通过在 s3 中删除一个文件来创建一个实际的事件,只要你已经创建了事件通知然后它就会被拾取
我也遇到了同样的问题,我们在这里需要做的很简单。 lambda 的区域和创建存储桶/触发器时的区域应该相同。 如果相同,只需将文件上传到 S3 存储桶,就会直接反映到 DynamoDB。
我也遇到了同样的问题,对我有用的是...停止 运行 对 lambda 函数的测试,然后转到您的 s3 存储桶并上传您的 json 文件,一切都会好好地 。相信我,我现在也和你一样头疼..