使用boto3 batch_write_item删DynamoDB数据报错：键元素与Schema不匹配

错误原因 #

• 批量删除DynamoDB条目必须使用表本身的主键，你在DeleteRequest里误用了GSI的solutionId作为键，而你的表分区键是emp_id，这就导致了键与表结构不匹配的报错。
• 你混用了boto3资源（resource）和低级客户端（client）的数据格式：资源模式下，Key不需要指定类型标识（比如{"S": "..."}），直接用原生Python值即可。
• 原代码的scan()只返回最多1MB的数据，会漏掉大量条目，必须处理分页才能获取全表数据。

修正后的代码 #

import boto3

table_name = "solutions"
dynamodb_resource = boto3.resource('dynamodb')
table = dynamodb_resource.Table(table_name)

# 获取全表所有数据（处理分页，避免遗漏）
all_items = []
response = table.scan()
all_items.extend(response['Items'])
while 'LastEvaluatedKey' in response:
    response = table.scan(ExclusiveStartKey=response['LastEvaluatedKey'])
    all_items.extend(response['Items'])

# 构造批量删除请求（使用表的分区键emp_id）
delete_list = []
for item in all_items:
    delete_list.append({
        'DeleteRequest': {
            'Key': {
                'emp_id': item['emp_id']
            }
        }
    })

# 拆分批量请求（DynamoDB限制单次批量操作最多25条）
def split_list(lst, size):
    for pos in range(0, len(lst), size):
        yield lst[pos:pos + size]

# 执行批量删除
for batch in split_list(delete_list, 25):
    dynamodb_resource.batch_write_item(
        RequestItems={table_name: batch}
    )

补充说明 #

• 如果你的表包含排序键，需要把排序键也加到Key字典中，比如'Key': {'emp_id': item['emp_id'], 'sort_key': item['sort_key']}。
• 若表数据量极大，这种逐条删除的方式性能会受限，但符合你“不删除表”的需求；如果允许短暂停服，也可以考虑先导出数据备份，再删除原表重建空表。

内容的提问来源于stack exchange，提问作者Codistan