如果 Java 代码抛出 runtimeException，Lambda 函数不会重试 sqs 消息处理

Question

我有一个用 java 编写的 lambda 函数，它监听 sqs 事件并尝试对这些 sqs 消息进行某种处理。

根据 lambda 文档，如果 lambda 代码引发 runtimeException，则 lambda 将重试同一消息两次，然后再将其发送回队列。但是，我看不到这种行为。 我只看到它只处理一次消息。

在这种情况下，这是来自相关 lambda 代码的 sn-p。

@Override
    public Boolean handleRequest(SQSEvent sqsEvent, Context context) {

          try{
               ........some queue message processing.....
          }
          catch(Exception ex){
               throw new RuntimeException("exception occurred");
          }

}

这是否不足以让 lambda 再重试消息 2 次？我确实检查了 cloudwatch 以查看 lambda 日志，它仅包含来自第一次处理的日志，而不是重试的日志。

谁能告诉我我在这里错过了什么，因为它没有按预期工作。

Answer 1

您缺少 handleRequest 中的 throws 子句。如果你没有那个，lambda 只会吞下异常

public Boolean handleRequest(SQSEvent sqsEvent, Context context) throws RuntimeException

除此之外，Thales Munussi 告诉你的关于同步轮询的内容是绝对正确的。当您将 sqs 与 lambda 挂钩时，lambda 会轮询 sqs，从而保持两者之间的开放连接，从而使其成为同步连接 根据 aws 文档，lambda 在这种同步情况下不会重试。在 sqs 本身设置一个 dlq 并退休是你最好的办法

请记住，在您的 java 代码中引发运行时异常后，lambda 会将消息发送回队列 根据您的 sqs 中的 redrive 设置，sqs 将根据 redrive 编号生成相同的事件。

一旦 lambda 无法成功处理 redrive 次数，消息就会从主队列发送到 DLQ

Answer 2

documentation 表示如果调用是异步，它会再重试两次。 SQS 是一个基于投票的系统。 Lambda 将轮询队列，它的所有调用都将是同步。

对于基于轮询的 AWS 服务（Amazon Kinesis、Amazon DynamoDB、Amazon Simple Queue Service），AWS Lambda 轮询流或消息队列 并同步调用您的 Lambda 函数。

您可以在源 SQS 队列上配置一个 DLQ，以防您的消息失败，以便您可以进一步分析它或根据您配置的逻辑再次处理该消息。

编辑

OP 无法以某种方式查看 DLQ 中的消息。我附上了图片来证明它是有效的。

Lambda sqs-test 由 SQS 队列 sqs-test 中的新消息触发

这些是队列（sqs-test-dlq 被配置为 sqs-test 的 DLQ）。

这是 Lambda 函数的代码：

这是sqs-test的配置

这是重新驱动政策

消息在 Lambda 函数中失败后，成功发送到配置的 DLQ：

您一定缺少一些基本配置，因为它可以无缝运行，如上图所示。