我有一个 DynamoDB 表，例如 data。该表有 400k 项。每个项目有 4 个字段 -
现在所有项目都有一个status = "Y"。无论密钥或任何条件如何，如何更新所有项目并将所有 400k 项目的状态设置为“N”？
在 MySQL 中，等效语句是 -
UPDATE data SET status = 'N';
我希望通过命令行或在 python 中使用 boto3 来完成它
【问题讨论】：
标签： python amazon-web-services amazon-dynamodb boto3
没有简单或便宜的方法来做你想做的事。您基本上需要做的是读取和写入整个数据库：
写：
UpdateExpression 的"set status = :N" 进行UpdateItem 请求。这只会修改“状态”属性（其余部分保持不变），但您将产生的成本（或您将使用的预置吞吐量）将是编写整个项目的成本。所以所有这些操作的总和将是重写整个数据库的成本。UpdateItem 中添加一个ConditionExpression，它只会在项目实际仍然存在时更新项目（您可以在其关键属性上使用attribute_exists() 条件来验证项目是否存在）。这将允许您的工作负载在进行这些更改时删除项目。BatchWriteItems（boto3 中的batch_writer()）一起修改一组项目，因为此批量操作只能替换项目 - 不能修改现有项目的属性。在任何情况下，BatchWriteItems 都不会降低成本（批次成本与它们包含的请求相同）。阅读：
Scan 操作，将Projection 设置为KEYS_ONLY 以仅获取键（您不需要需要数据）。不幸的是，您的成本将与阅读整个项目相同，而不仅仅是阅读钥匙。因此，所有这些 Scan 操作的成本总和将是读取整个数据库。如果您为此表使用预置容量，则您可以使用客户端请求未使用的任何多余容量在后台缓慢地进行此更改，基本上是“免费”。
这在您的情况下是否有意义实际上取决于您配置了多少过剩容量（读取和写入！）。如果你这样做，你需要注意不要为这个后台操作使用太多容量并伤害你的真实用户 - 你需要有某种控制器来通知容量超出错误并减少容量由后台进程使用。
如果您实际上有很多已经支付的超额预置容量，您可以随心所欲地执行此后台操作！读取部分 Scan 可以尽可能快地并行完成（使用“并行扫描”功能），不同键的写入部分显然也可以并行完成。
【讨论】：
以下代码使用batch_write_item DynamoDB API 以 25 的大小批量更新项目，这是 batch_write_item 在单个 API 调用中可以接收的最大项目数。如果您的商品很大，您可能需要调整这个数字。
警告：这只是一个概念证明示例。您应自行承担使用风险。
import boto3
def update_status(item):
item['status'] = {
'S': 'N'
}
return item
client = boto3.client('dynamodb', region_name='<ddb-region>')
paginator = client.get_paginator('scan')
operation_parameters = {
'TableName': '<ddb-table-name>',
'PaginationConfig': {
'PageSize': 25
}
}
page_iterator = paginator.paginate(**operation_parameters)
for page in page_iterator:
response = client.batch_write_item(RequestItems={
'<ddb-table-name>': [
{
'PutRequest': {
'Item': update_status(item)
}
}
for item in page['Items']
]
})
print(response)
【讨论】：