JMi*_*d23 3 amazon-s3 amazon-web-services python-2.7 amazon-dynamodb
我正在尝试使用 AWS Lambda 函数将 csv 数据从 S3 写入 DynamoDB。我目前收到以下错误“BatchWriteItem 操作:提供的关键元素与架构不匹配”。
有没有快速解决这个问题的方法?
import boto3
s3 = boto3.client('s3')
dynamodb = boto3.resource('dynamodb')
def csv_reader(event, context):
bucket = event['Records'][0]['s3']['bucket']['name']
key = event['Records'][0]['s3']['object']['key']
obj = s3.get_object(Bucket=bucket, Key=key)
rows = obj['Body'].read().split('\n')
table = dynamodb.Table('customer_id')
with table.batch_writer() as batch:
for row in rows:
batch.put_item(Item={
'Customer-ID':row.split(',')[0],
'Name':row.split(',')[1]
})
Run Code Online (Sandbox Code Playgroud)
错误看起来像这样:
调用 BatchWriteItem 操作时发生错误 (ValidationException):提供的关键元素与架构不匹配:ClientError Traceback(最近一次调用最后一次):
文件“/var/task/lambda_function.py”,第 22 行,在 csv_reader 'Name':row.split(',')[1]
文件“/var/runtime/boto3/dynamodb/table.py”,第 156 行,退出 self._flush()
文件“/var/runtime/boto3/dynamodb/table.py”,第 137 行,在 _flush RequestItems={self._table_name: items_to_send})
文件“/var/runtime/botocore/client.py”,第 314 行,在 _api_call 中返回 self._make_api_call(operation_name, kwargs)
文件“/var/runtime/botocore/client.py”,第 612 行,在 _make_api_call 中引发 error_class(parsed_response, operation_name)
ClientError:调用 BatchWriteItem 操作时发生错误 (ValidationException):提供的关键元素与架构不匹配
我希望数据从 CSV 文件写入 DynamoDB。对 AWS 和 Python 完全陌生,因此将不胜感激。
放置项目时,您必须提供所有必填字段,否则会因上述异常而失败。
仔细检查您的表架构并检查强制值:至少一个哈希键是必需的。如果您使用 Range 键配置了 Hash Key,则必须提供这两个值。如果没有您表中的更多信息,我们很难猜测,但我将尝试在接下来的几行中总结问题。如果仍然不够,请使用表架构更新您的问题。
因此,假设您的 HashKey 已命名id,您的代码应如下所示:
batch.put_item(Item={
'id': 'some-id'
'Customer-ID':row.split(',')[0],
'Name':row.split(',')[1]
})
Run Code Online (Sandbox Code Playgroud)
如果还设置了范围键并命名为test,那么您的代码应如下所示:
batch.put_item(Item={
'id': 'some-id',
'test': 'some-value',
'Customer-ID':row.split(',')[0],
'Name':row.split(',')[1]
})
Run Code Online (Sandbox Code Playgroud)
如果您不确定 Hash 和 Range 键如何协同工作,我建议您阅读文档
| 归档时间: |
|
| 查看次数: |
7082 次 |
| 最近记录: |