在 EventBridge 中使用死信队列处理未传送的事件 - Amazon EventBridge
使用 DLQ 的注意事项向 DLQ 授予权限从 DLQ 重新发送事件

在 EventBridge 中使用死信队列处理未传送的事件

为避免在事件未能传送到目标后丢失事件，您可以配置死信队列 (DLQ)，并将所有失败事件发送到该队列，以便日后处理。

EventBridge DLQ 是标准 Amazon SQS 队列，EventBridge 使用它来存储无法成功传送到目标的事件。创建规则并添加目标时，可以选择是否使用 DLQ。配置 DLQ 时，可以保留任何未成功传送的事件。然后，您可以解决导致事件传送失败的问题，并在之后处理事件。

当您为规则的目标配置 DLQ 后，EventBridge 会将调用失败的事件发送到所选的 Amazon SQS 队列。

事件错误的处理方式不同。有些事件会在不进行任何重试的情况下被丢弃或发送到 DLQ。例如，由于缺少对目标的权限或目标资源已不存在而导致的错误，在采取行动解决潜在问题之前，系统将不会进行任何重试。EventBridge 将这些事件直接发送到目标 DLQ（如已指定）。

当事件传送失败时，EventBridge 会向 Amazon CloudWatch 指标发布一个事件，表明目标 invocation 失败。如果您使用 DLQ，则会向 CloudWatch 发送额外指标，包括 InvocationsSentToDLQ 和 InvocationsFailedToBeSentToDLQ。

如果您使用 AWS KMS 客户自主管理型密钥对事件进行静态加密，也可以为事件总线指定 DLQ。有关更多信息，请参阅 在 EventBridge 中使用死信队列来捕获加密事件错误。

您的 DLQ 中的每条消息都将包含以下自定义属性：

  • RULE_ARN

  • TARGET_ARN

  • ERROR_CODE

    以下是 DLQ 可能返回的错误代码示例：

    • CONNECTION_FAILURE

    • CROSS_ACCOUNT_INGESTION_FAILED

    • CROSS_REGION_INGESTION_FAILED

    • ERROR_FROM_TARGET

    • EVENTS_IN_BATCH_REQUEST_REJECTED

    • EVENTS_IN_BATCH_REQUEST_REJECTED

    • FAILED_TO_ASSUME_ROLE

    • INTERNAL_ERROR

    • INVALID_JSON

    • INVALID_PARAMETER

    • NO_PERMISSIONS

    • NO_RESOURCE

    • RESOURCE_ALREADY_EXISTS

    • RESOURCE_LIMIT_EXCEEDED

    • RESOURCE_MODIFICATION_COLLISION

    • SDK_CLIENT_ERROR

    • THIRD_ACCOUNT_HOP_DETECTED

    • THIRD_REGION_HOP_DETECTED

    • THROTTLING

    • TIMEOUT

    • TRANSIENT_ASSUME_ROLE

    • UNKNOWN

  • ERROR_MESSAGE

  • EXHAUSTED_RETRY_CONDITION

    可能返回以下条件：

    • MaximumRetryAttempts

    • MaximumEventAgeInSeconds

  • RETRY_ATTEMPTS

以下视频介绍了 DLQ 的设置：

使用死信队列的注意事项

在为 EventBridge 配置 DLQ 时，请考虑以下事项。

  • 仅支持标准队列。在 EventBridge 中，DLQ 不能使用 FIFO 队列。

  • EventBridge 在消息中包含事件元数据和消息属性，包括：错误代码、错误消息、用尽重试条件、规则 ARN、重试尝试和目标 ARN。您可以使用这些值来识别事件和失败原因。

  • 同一账户中 DLQ 的权限：

    • 如果您使用控制台向规则添加目标，并在同一个账户中选择一个 Amazon SQS 队列，则会将一个基于资源的策略（授予 EventBridge 访问该队列的权限）附加到该队列。

    • 如果您使用 EventBridge API 的 PutTargets 操作为规则添加或更新目标，并且在同一账户中选择一个 Amazon SQS 队列，则必须手动向所选队列授予权限。要了解更多信息，请参阅为死信队列授予权限。

  • 使用另一 AWS 账户的 Amazon SQS 队列的权限。

    • 如果您通过控制台创建规则，则不会显示其他账户的队列供您选择。您必须提供其他账户中队列的 ARN，然后手动附加基于资源的策略，为该队列授予权限。要了解更多信息，请参阅为死信队列授予权限。

    • 如果您使用 API 创建规则，则必须手动将基于资源的策略附加到用作死信队列的另一账户中的 SQS 队列。要了解更多信息，请参阅为死信队列授予权限。

  • 您使用的 Amazon SQS 队列必须位于创建规则的区域。

为死信队列授予权限

要成功将事件传送到该队列，EventBridge 必须具有执行这一操作的权限。当您使用 EventBridge 控制台指定 DLQ 后，系统会自动添加权限。这包括：

如果您使用 API 指定 DLQ，或者使用其他 AWS 账户中的队列，则必须手动创建基于资源的策略，然后将其附加到队列，用于授予所需权限。

目标死信队列权限示例

以下基于资源的策略演示如何授予所需权限，使 EventBridge 能够向 Amazon SQS 队列发送事件消息。示例策略向 EventBridge 服务授予权限，使用 SendMessage 操作向名为“MyEventDLQ”的队列发送消息。队列必须位于 us-west-2 区域，AWS 账户为 123456789012。该 Condition 语句仅允许来自名为“myTestrule”的规则的请求，该规则是在 us-west-2 区域创建的，AWS 账户为 123456789012。

{
  "Sid": "Dead-letter queue permissions",
  "Effect": "Allow",
  "Principal": {
     "Service": "events.amazonaws.com"
  },
  "Action": "sqs:SendMessage",
  "Resource": "arn:aws:sqs:us-west-2:123456789012:MyEventDLQ",
  "Condition": {
    "ArnEquals": {
      "aws:SourceArn": "arn:aws:events:us-west-2:123456789012:rule/MyTestRule"
    }
  }
}

事件总线死信队列权限示例

以下基于资源的策略演示了如何在为事件总线指定 DLQ 时授予所需权限。在本例中，aws:SourceArn 指定用于将事件发送到 DLQ 的事件总线的 ARN。在本示例中，队列必须与事件总线位于同一区域。

{
  "Sid": "Dead-letter queue permissions",
  "Effect": "Allow",
  "Principal": {
     "Service": "events.amazonaws.com"
  },
  "Action": "sqs:SendMessage",
  "Resource": "arn:aws:sqs:region:account-id:queue-name",
  "Condition": {
    "ArnEquals": {
      "aws:SourceArn": "arn:aws:events:region:account-id:event-bus/event-bus-arn"
    }
  }
}

要将策略附加到队列，请使用 Amazon SQS 控制台，打开队列，然后选择访问策略并编辑该策略。您也可以使用 AWS CLI。要了解更多信息，请参阅Amazon SQS 权限。

如何从死信队列中重新发送事件

可以通过两种方式将消息移出 DLQ：

  • 避免编写 Amazon SQS 使用者逻辑 - 将 DLQ 设置为 Lambda 函数的事件源以耗尽 DLQ。

  • 编写 Amazon SQS 使用者逻辑 - 使用 Amazon SQS API、AWS 开发工具包或 AWS CLI 编写自定义使用者逻辑，用于轮询、处理和删除 DLQ 中的消息。