Lambda并发写入DynamoDB时put_item静默失败问题咨询

是，这种情况确实属于Lambda并发向按需模式DynamoDB写入时，出现写入失败但未抛出预期异常的场景，结合你的代码配置细节分析如下：

核心问题拆解 #

• 代码校验逻辑的误判风险
  你在put_item后用get_item校验写入结果，但DynamoDB默认是最终一致性读，并发场景下刚写入的数据可能无法立即被读取到，这会触发ValueError并进入重试流程，但实际上写入已经成功了，属于“假失败”。
  另外，你的异常捕获只覆盖了ClientError，自定义的ValueError如果在重试次数内没解决，会直接终止逻辑，但外层没有处理，可能导致日志中看不到明确的失败提示，看起来像“无异常但写入失败”。

• 按需模式的节流未被完整处理
  按需模式DynamoDB会自动扩容，但扩容有延迟，当100个Lambda并发写入超过临时吞吐量上限时，会触发节流，但你只捕获了ProvisionedThroughputExceededException和ThrottlingException，而按需模式下节流还会返回RequestLimitExceeded错误码，这类异常没被捕获，会直接抛出而非进入重试，导致写入失败却没有你预期的异常处理日志。

优化建议 #

1. 修正读写一致性校验
   给get_item添加强一致性读参数，确保读取最新数据，避免误判：

   response = table.get_item(Key={'PrimaryKey': item['PrimaryKey']}, ConsistentRead=True)
   

2. 扩展节流异常捕获范围
   把RequestLimitExceeded加入异常处理列表，覆盖按需模式的节流场景：

   if e.response['Error']['Code'] in ['ProvisionedThroughputExceededException', 'ThrottlingException', 'RequestLimitExceeded']:
   

3. 使用boto3内置重试机制
   替代自定义重试逻辑，减少代码复杂度，内置重试会自动处理各类节流异常：

   from botocore.config import Config
   
   config = Config(
       retries={
           'max_attempts': 5,
           'mode': 'standard'
       }
   )
   dynamodb = boto3.resource('dynamodb', config=config)
   

4. 增加调试日志
   在put_item后打印请求ID，方便确认写入是否成功：

   resp = table.put_item(Item=item)
   print(f"Put item request ID: {resp['ResponseMetadata']['RequestId']}")
   

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