DynamoDB：部分更新失败时不终止事务的批量更新方案

核心需求是实现类似BatchWriteItem的容错逻辑（单条操作失败不中断整体），但支持更新操作，以下是几种实用解决办法：

方案1：并行执行独立的UpdateItem请求 #

• 用多线程/异步任务并行发起单个UpdateItem请求，每个请求完全独立，某条失败不会牵连其他。
• 优势：完全隔离每个更新操作，可自定义重试逻辑（比如针对ProvisionedThroughputExceededException这类可重试错误）。
• 注意：
  • 控制并发数，避免超出表的读写容量配额，可根据表的RCU/WCU调整并发量。
  • 自行记录每个请求的结果，失败项单独存入重试队列后续处理。

方案2：使用PartiQL的BatchExecuteStatement #

• DynamoDB的PartiQL支持批量提交更新语句，单条语句失败不会导致整批回滚，只会返回对应失败项的错误详情。
• 示例伪代码：

import boto3

dynamodb_client = boto3.client('dynamodb')

batch_statements = [
    "UPDATE user_table SET login_count = login_count + 1 WHERE user_id = 'u001'",
    "UPDATE user_table SET login_count = login_count + 1 WHERE user_id = 'u002'",
    # 更多更新语句
]

response = dynamodb_client.batch_execute_statement(Statements=batch_statements)

# 遍历结果，筛选失败项
for res in response['Responses']:
    if 'Error' in res:
        print(f"更新失败: {res['Error']['Message']}, 对应语句: {res['Statement']}")

• 限制：
  • 每批次最多25条语句，总大小不超过16KB。
  • 同样要注意吞吐量限制，避免突发请求触发限流。

方案3：自定义批量处理封装 #

• 模仿BatchWriteItem的批次逻辑，把多个更新项分成每批25个的组，每组内并行执行UpdateItem请求。
• 自行封装类似BatchWrite的接口，内部拆分为单个更新请求执行，收集成功/失败结果，失败项留待后续重试。

通用注意事项 #

• 必须记录所有失败的更新项，避免数据丢失，后续通过重试机制补全。
• 针对限流类错误（ProvisionedThroughputExceededException、RequestLimitExceeded），实现指数退避重试，降低失败概率。
• 如果更新依赖项的原有状态，务必用ConditionExpression做校验，避免并发更新导致的数据不一致。

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