Lambda 不会将消息放入 dlq

Question

我只是想为 Lambda 测试我的 DLQ，但我不明白为什么没有消息放在上面。我的代码只做一件事throw new Exception("Test");。

第一个错误是可以理解的，我尝试使用按钮Test 同步执行此操作。之后我设置了Kinesis 并开始在上面发送消息，但没有任何改变。在CloudWatch metrics 的监控页面上，我看到Errors, Availability 有几个错误，但DeadLetterErrors 没有错误。

至于创建的 DLQ，这只是简单的标准队列，配置没有任何变化。

提前感谢您的帮助

Answer 1

使用 AWS SDK 异步调用 lambda，如下所示。

$ aws lambda invoke --function-name my-function --invocation-type Event --payload '{ "key": "value" }' response.json { "StatusCode": 202 }

文档 - https://docs.aws.amazon.com/lambda/latest/dg/invocation-async.html

Answer 2

• 使用 Kinesis 流触发 lambda 意味着您正在使用同步调用。但是，DLQ 仅适用于asynchronous invocations。
• 好消息是，AWS 在 2019 年 11 月发布了 new error handling mechanisms 用于 Kinesis 和 DynamoDB 事件源。

使用此功能，您可以在发生故障时配置目标。此目标可以是 SNS 主题、SQS 队列、另一个 lambda 函数或 EventBridge 事件总线。

要通过控制台 UI 添加它，

1. 转到 lambda 函数
2. 点击Add Destination按钮
3. 选择流调用
4. 选择失败条件
5. 选择 SQS 队列作为目标，并将其指向您要像 DLQ 一样使用的 SQS。

要通过 cloudformation 添加它，请关注documentation。
我将为您需要附加到 lambda 函数的触发器提供一个基本示例：

LambdaTrigger:
  Type: AWS::Lambda::EventSourceMapping
  Properties:
    FunctionName: !GetAtt Lambda.Arn
    EventSourceArn: !GetAtt Kinesis.Arn
    DestinationConfig:
      OnFailure:
        Destination: !GetAtt DLQ.Arn