在 DynamoDB 中插入多行 json

Question

我有以下 json 文件{"columnwithoutname":"structureet","nofinesset":810001792,"nofinessej":810001784}{"columnwithoutname":"structureet","nofinesset":670797117,"nofinessej":670010339}我想使用 Lambda 将其插入 DynamoDB 中。这就是我所做的：def lambda_handler(event, context):    bucket=event['b']    file_key=event['c']    table=event['t']    recList=[]    s3 = boto3.client('s3')    dynamodb = boto3.client('dynamodb')    obj= s3.get_object(Bucket=bucket, Key=file_key)    recList=obj['Body'].read().split('\n')    for row in recList:        response = dynamodb.put_item(TableName='test-abe', Item=row)但是我有这个错误： "errorMessage": "Parameter validation failed:\nInvalid type for parameter Item显然，我还需要精确地确定每列的类型，以便可以接受它。无论如何，自动完成？我希望所有列都是字符串。谢谢

Answer 1

DynamoDB 客户端希望参数为 （每 https://boto3.amazonaws.com/v1/documentation/api/latest/reference/services/dynamodb.html#DynamoDB.Client.put_itemItemdict)

当你做你得到的是一个列表，所以传递给一个参数期望显然会失败。recList = obj['Body'].read().split('\n')strstrdict

需要考虑的另一件事是，DynamoDB 客户端需要具有非常特定格式的项目，并具有显式指定的属性数据类型。如果您想读取 JSON 并简单地编写它，我建议使用 DynamoDB 资源，如下所示：

dynamodb = boto3.resource('dynamodb')

table = dynamodb.Table(table_name)

table.put_item(item)

Table.put_item()接受简单，无需为每个属性指定数据类型，因此您只需从文件中读取，将其转换为dict并将其发送出去（https://boto3.amazonaws.com/v1/documentation/api/latest/reference/services/dynamodb.html#DynamoDB.Table.put_item）。dict

Answer 2

您需要操作每行才能具有“S”格式：

import json
for row in recList:
    row_dict = json.loads(row)
    ddb_row_dict = {k:{"S": v} for (k,v) in row_dict.items()}
    response = dynamodb.put_item(TableName='test-abe', Item=ddb_row_dict)