如何用AWS CDK Python配置死信队列重定向允许策略并解决循环依赖

你的问题核心是创建队列时互相引用导致循环依赖，解决办法是分阶段创建资源：先不设置死信队列的重定向允许策略，等源队列创建完成后再追加这个策略，就能打破循环。

修正后的完整代码如下：

from aws_cdk import Stack, sqs
from constructs import Construct

class MyStack(Stack):
    def __init__(
        self,
        scope: Construct,
        construct_id: str,
        **kwargs,
    ) -> None:
        super().__init__(scope, construct_id, **kwargs)
        
        # 第一步：先创建死信队列，暂不配置重定向允许策略
        dead_letter_queue_name = "MyDeadLetterQueue"
        dead_letter_queue = sqs.Queue(
            self,
            dead_letter_queue_name,
            queue_name=dead_letter_queue_name,
        )
        
        # 第二步：创建源队列，关联已创建的死信队列
        queue_name = "MySourceQueue"
        queue = sqs.Queue(
            self,
            queue_name,
            queue_name=queue_name,
            dead_letter_queue=sqs.DeadLetterQueue(
                max_receive_count=3,
                queue=dead_letter_queue,
            ),
        )
        
        # 第三步：给死信队列追加Redrive Allow Policy，仅允许当前源队列重定向
        dead_letter_queue.add_redrive_allow_policy(
            redrive_permission=sqs.RedrivePermission.BY_QUEUE,
            source_queues=[queue],
        )

关键说明 #

• 先创建无重定向策略的死信队列，避免一开始就依赖未创建的源队列
• 源队列创建时直接引用已存在的死信队列，完成关联配置
• 使用队列的add_redrive_allow_policy方法追加策略，这是CDK提供的后置配置操作，此时源队列已存在，不会再产生循环依赖
• 最终效果完全符合需求：死信队列仅允许关联的源队列向其发送失败消息，源队列会将重试3次仍失败的消息转至死信队列

内容的提问来源于stack exchange，提问作者Supavit Triampitak