json - 尝试将自定义有效负载消息传递给 sqs - kinesis 完成后的死信队列在 lambda 中重试 3 次

Question

我一直在研究一个解决方案，当消息发送到运动流时会触发 3 个 lambda。在 lambda 内，kinesis 在失败时重试 3 次。在这种情况下，我会将在流中接收到的有效负载发送到 sqs dlq。但是，我还想向 dlq 发送一些自定义数据，如下所示进行重新处理：

{
"updatedtime": "2021-09-01",
"lambda_name": "lambda1",
"failure_code": "400"
}

我查看了 sqs 文档，我可以使用该send_message函数将消息发送到队列并最终发送到 dlq。我想在 kinesis 放弃后发送自定义有效负载（完成 3 次重试）。

我也考虑过 sns，但在这种情况下它对我没有帮助。是否有任何其他服务或更好的选择可以将自定义有效负载发送到 dlq 进行重新处理？任何帮助，将不胜感激。

谢谢！

标签： jsonamazon-web-servicesamazon-sqsamazon-snsamazon-kinesis