如何使用boto3删除DynamoDB中仅知前缀的排序键对应记录？

问题原因 #

DynamoDB的delete_item接口必须传入完整的分区键(PK)和排序键(SK)值才能定位到具体记录。你传入的SK: 'VR#'和实际存储的VR#+时间戳格式不匹配，系统找不到对应条目，因此删除操作没有生效。返回200状态码仅表示请求本身格式合法，不代表记录被成功删除。

解决方案 #

需要先通过query接口查询出该PK下所有SK以VR#开头的记录，再逐个删除：

• 第一步：用query方法筛选出目标范围内的所有记录
• 第二步：遍历查询结果，调用delete_item删除每条记录

完整代码示例 #

import boto3
from boto3.dynamodb.conditions import Key

def get_dynamodb_table():
    # 替换为你的表初始化逻辑
    dynamodb = boto3.resource('dynamodb')
    return dynamodb.Table('your-table-name')

def delete_records_by_prefix(pk_value, sk_prefix):
    try:
        table = get_dynamodb_table()
        # 查询符合条件的所有记录（含分页处理）
        response = table.query(
            KeyConditionExpression=Key('PK').eq(pk_value) & Key('SK').begins_with(sk_prefix)
        )
        items = response.get('Items', [])
        
        # 处理分页，避免漏删大量数据
        while 'LastEvaluatedKey' in response:
            response = table.query(
                KeyConditionExpression=Key('PK').eq(pk_value) & Key('SK').begins_with(sk_prefix),
                ExclusiveStartKey=response['LastEvaluatedKey']
            )
            items.extend(response.get('Items', []))
        
        # 逐个删除记录
        for item in items:
            table.delete_item(
                Key={
                    'PK': item['PK'],
                    'SK': item['SK']
                }
            )
        
        return f"成功删除{len(items)}条记录"
    except Exception as err:
        print(f"删除失败: {err}")
        return False

# 调用示例
delete_records_by_prefix('AC#12131', 'VR#')

额外说明 #

• 若需要优化批量删除效率，可使用batch_write_item接口，每次最多批量处理25条记录，注意处理批量操作的异常重试逻辑。
• 确保执行代码的IAM角色拥有DynamoDB的Query和DeleteItem权限。

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