在创建 SQS 队列时,需要指定找不到消费者和消息的情况下所需的死信队列 ARN。以下是示例代码:
import aws_cdk.aws_sqs as sqs
# 创建死信队列
dead_letter_queue = sqs.Queue(self, "my-dead-letter-queue")
# 创建主队列时指定死信队列 ARN
queue = sqs.Queue(
self,
"my-queue",
dead_letter_queue={
'queue': dead_letter_queue,
'max_receive_count': 3
}
)
在创建主队列时,将 dead_letter_queue
参数设置为包含死信队列的字典。在字典中,queue
键指定死信队列,max_receive_count
键指定当未能处理的消息达到最大重试次数时将其发送到死信队列的次数。