重试次数超限后，Lambda未丢弃DynamoDB流表中的记录

核心逻辑说明 #

DynamoDB流传递的是数据变更事件（增/删/改操作的快照），Lambda处理的是这些事件，而非直接操控DynamoDB表中的原始数据。Lambda重试耗尽后将事件转至SQS，这一流程不会触发源表数据的删除——这是AWS服务的设计逻辑，流事件的处理结果与源表数据的留存状态完全独立。

为什么表中记录未被丢弃？ #

你的Lambda配置仅针对流事件的处理重试，没有关联源表数据的删除逻辑。如果需要在事件处理失败后删除表中对应记录，必须在代码中显式实现：

• 从流事件的Records[].dynamodb.Keys字段提取目标记录的主键
• 调用DynamoDB的DeleteItem API执行删除操作

实现目标的具体方案 #

如果希望在Lambda处理失败（含重试耗尽）后删除表记录，可以分两种场景处理：

1. 处理过程中直接删除：在Lambda业务逻辑执行完成（或确认无法恢复的失败）时，立即删除对应记录

   import boto3
   
   dynamodb = boto3.resource('dynamodb')
   target_table = dynamodb.Table('你的表名')
   
   def lambda_handler(event, context):
       for rec in event['Records']:
           # 执行你的业务处理逻辑
           # ...
           # 提取主键（根据表的主键类型调整数据格式，如N/S/B）
           primary_key = rec['dynamodb']['Keys']['主键字段名']['S']
           # 删除源表记录
           target_table.delete_item(Key={'主键字段名': primary_key})
   

2. 通过SQS事后删除：如果希望仅在重试完全失败后再删除，可在SQS的消费逻辑中处理失败事件，提取主键后执行删除，避免正常处理时误删数据。

补充说明 #

• 当前的5次重试和SQS失败目标，作用是留存未成功处理的流事件，用于后续排查或重新处理，和源表数据的删除无直接关联。
• 若误将“流事件的丢弃”等同于“表记录的删除”，这是概念混淆——流事件的生命周期和源表数据的生命周期是两个独立维度。

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