BatchWriteItem 操作:提供的关键元素与架构不匹配

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 完全陌生,因此将不胜感激。

Tha*_*ssi 5

放置项目时,您必须提供所有必填字段,否则会因上述异常而失败。

仔细检查您的表架构并检查强制值:至少一个哈希键是必需的。如果您使用 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 键如何协同工作,我建议您阅读文档