问题:Boto 3 DynamoDB batchWriteItem 指定类型时属性值类型无效

在尝试对 DynamoDB 表执行批处理_write_item 时,我遇到了 Python Boto3 的一个奇怪问题。我正在关注文档并尝试编写单个项目。该表设置正确,我可以通过 AWS cli 运行 batch-write-item 没问题。

假设客户端和 DynamoDB 设置正确,我运行:

client.batch_write_item(RequestItems={
    "myTable": [
        {
            "PutRequest": {
                "Item": {
                    "name": {
                        "S": "hello"
                    },
                    "value": {
                        "S": "world"
                    }
                }
            }
        }
    ]
})

我收到以下错误:

botocore.exceptions.ClientError:调用 BatchWriteItem 操作时发生错误(ValidationException):属性值类型无效

如果我更改它,请删除类型并运行:

client.batch_write_item(RequestItems={
    "myTable": [
        {
            "PutRequest": {
                "Item": {
                    "name": "hello",
                    "value": "world"
                }
            }
        }
    ]
})

它按预期工作。

我需要使用遵循文档并与 AWS cli 兼容的先前格式。

是文档错误还是我错过了配置设置、版本问题或其他什么?

解答

这也让我明白了,看起来您使用的是 DynamoDB resource,而不是_client_。它们都提供相同的功能,但作用却略有不同。这是您要查找的内容:

http://boto3.readthedocs.io/en/latest/reference/services/dynamodb.html#DynamoDB.ServiceResource.batch_write_item

除此之外,文档仍然很不清楚。这是我发现的:

• 当使用一个资源(你当前正在做什么)时,你可以指定非关键属性的类型,你不能指定关键属性的类型

• 使用客户端(其他选项)时,您必须指定所有属性的类型。

使用 DynamoDB 资源:

resource = boto3.resource('dynamodb', endpoint_url='http://localhost:8000')

mytable = resource.create_table(
    TableName='mytable',
    KeySchema=[{ 'AttributeName': 'name', 'KeyType': 'HASH' }],
    AttributeDefinitions=[{ 'AttributeName': 'name', 'AttributeType': 'S' }],
    ProvisionedThroughput={ 'ReadCapacityUnits': 5, 'WriteCapacityUnits': 5 }
)

try:
    resource.batch_write_item(RequestItems={
        'mytable': [{ 'PutRequest': { 'Item': {
            'name': { 'S': 'myname' },
            'value': { 'S': 'myvalue' }
        }}}]
    })
    print(f'resource, specify all types : write succeeded.')
except Exception as e:
    print(f'resource, specify all types : write failed: {e}')

try:
    resource.batch_write_item(RequestItems={
        'mytable': [{ 'PutRequest': { 'Item': {
            'name': 'myname',
            'value': { 'S': 'myvalue' }
        }}}]
    })
    print(f'resource, specify value only: write succeeded.')
except Exception as e:
    print(f'resource, specify value only: write failed: {e}')

try:
    resource.batch_write_item(RequestItems={
        'mytable': [{ 'PutRequest': { 'Item': {
            'name': 'myname',
            'value': 'myvalue'
        }}}]
    })
    print(f'resource, specify none      : write succeeded.')
except Exception as e:
    print(f'resource, specify none      : write failed: {e}')

输出

resource, specify all types : write failed:
    An error occurred (ValidationException) when calling the BatchWriteItem operation: Invalid attribute value type
resource, specify value only: write succeeded.
resource, specify none      : write succeeded.

然后使用 DynamoDB 客户端(将上面的所有“资源”替换为客户端)

client = boto3.client('dynamodb', endpoint_url='http://localhost:8000')
try:
    client.batch_write_item(RequestItems={    
....

输出

client, specify all types : write succeeded.
client, specify value only: write failed: Parameter validation failed:
    Invalid type for parameter RequestItems.mytable[0].PutRequest.Item.name, value: myname, type: <class 'str'>, valid types: <class 'dict'>
client, specify none      : write failed: Parameter validation failed:
    Invalid type for parameter RequestItems.mytable[0].PutRequest.Item.name, value: myname, type: <class 'str'>, valid types: <class 'dict'>
    Invalid type for parameter RequestItems.mytable[0].PutRequest.Item.value, value: myvalue, type: <class 'str'>, valid types: <class 'dict'>