Lambda中Kinesis批处理的重试次数存储于何处？

这个重试计数器确实是AWS Lambda的内部维护指标，不会暴露给Lambda函数的事件输入，也无法通过AWS SDK直接获取到，你没遗漏什么。

为什么找不到这个计数？ #

Lambda处理Kinesis流时，服务端会单独维护每个记录（或批次）的重试次数，用于判断是否触发MaximumRetryAttempts阈值，但这个状态不会被包含在传递给Lambda的Kinesis Event struct中——这也是你查遍AWS Lambda Go SDK事件定义都找不到相关字段的原因。

如果你需要跟踪重试情况，可以这么做： #

• 按单条记录自定义重试计数：因为BisectBatchOnFunctionError会拆分批次，按批次跟踪重试意义不大，建议针对每条Kinesis记录的序列号，在DynamoDB或其他存储中维护重试次数。每次处理记录前先查询计数，超过阈值就直接标记为处理失败或跳过，避免无意义重试。
• 借助CloudWatch分析重试趋势：CloudWatch Metrics提供了Lambda的Invocations、Errors、BatchItemFailures等指标，结合Lambda日志中的记录序列号，用CloudWatch Insights可以分析特定记录的重试次数；如果配置了死信队列（DLQ），当记录重试次数耗尽后会被发送到DLQ，你可以在DLQ中收集这些失败记录的信息。
• 用Lambda Destinations扩展重试跟踪：给Lambda配置失败目的地（比如SQS/SNS），每次批次处理失败时，将事件发送到目的地，同时在消息属性中附加自定义的重试计数（比如每次失败就递增计数），后续可以在目的地的消费者中处理这些带计数的失败事件。

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