AWSSQS支持自动重新发送死信队列中的消息吗?
创始人
2024-09-27 13:00:41
0

是的,AWS SQS支持自动重新发送死信队列中的消息。我们可以通过配置队列的属性来实现。具体可以通过以下步骤完成:

  1. 创建一个SQS队列并设置最大接受次数和死信队列属性
import boto3

# 创建SQS客户端
sqs = boto3.client('sqs')

# 创建主队列
response = sqs.create_queue(QueueName='myQueue')

# 创建死信队列
response = sqs.create_queue(QueueName='myQueue_dead_letter',
                            Attributes={
                                'MessageRetentionPeriod': '86400',
                                'VisibilityTimeout': '30'
                            })

# 将主队列关联到死信队列
queue_arn = sqs.get_queue_attributes(QueueUrl='myQueue')['Attributes']['QueueArn']
dead_letter_arn = sqs.get_queue_attributes(QueueUrl='myQueue_dead_letter')['Attributes']['QueueArn']

policy = {
    "deadLetterTargetArn": dead_letter_arn,
    "maxReceiveCount": "5"
}

sqs.set_queue_attributes(QueueUrl='myQueue', Attributes={'RedrivePolicy': json.dumps(policy)})
  1. 开启消息重发
sqs.set_queue_attributes(
    QueueUrl='myQueue',
    Attributes={
        'ReceiveMessageWaitTimeSeconds': '20',
        'VisibilityTimeout': '30',
        'RedrivePolicy': json.dumps({
            'deadLetterTargetArn': dead_letter_arn,
            'maxReceiveCount': '5'
        }),
        'Policy': json.dumps({
            'Version': '2012-10-17',
            'Statement': [
                {
                    'Effect': 'Allow',
                    'Principal': '*',
                    'Action': 'sqs:SendMessage',
                    'Resource': queue_arn,
                    'Condition': {
                        'ForAllValues:StringEquals': {
                            'aws:SourceArn': dead_letter_arn
                        }
                    }
                }
            ]
        }),
        'MessageRetentionPeriod': '86400'
    }
)

以上代码均为Python示例,可以根据需要进行更改和适配。

相关内容

热门资讯

pokemomo辅助工具!wp... pokemomo辅助工具!wpk模拟器是什么(透视)神器-都是解迷是真的挂;一、wpk模拟器是什么可...
wejoker辅助器要钱玩吗!... wejoker辅助器要钱玩吗!pokernow辅助工具(透视)教程-竟然揭幕是真的挂1、金币登录送、...
wpk私人局有透视吗!拱趴大菠... wpk私人局有透视吗!拱趴大菠萝挂哪里(透视)插件-确实解迷真的有挂1、用户打开应用后不用登录就可以...
哈糖大菠萝破解器!德普之星辅助... 哈糖大菠萝破解器!德普之星辅助器怎么用(透视)脚本-确实开挂真的有挂1、打开软件启动之后找到中间准星...
aapoker辅助工具安全吗!... aapoker辅助工具安全吗!pokemmo脚本辅助下载(透视)脚本-一贯专业是真的挂1、进入游戏-...
hhpoker为什么一直输!哈... hhpoker为什么一直输!哈糖大菠萝万能挂(透视)脚本-竟然解迷是真的挂1、玩家可以在hhpoke...
wepoker透视有没有!we... wepoker透视有没有!wepoker怎么设置透视(透视)脚本-竟然详情真的有挂1、游戏颠覆性的策...
wepoker有辅助插件吗!h... wepoker有辅助插件吗!hhpoker德州挂真的有吗(透视)插件-都是关于真的是有挂1、hhpo...
wpk可以透视吗!we pok... wpk可以透视吗!we poker辅助器下载(透视)方法-本来必备真的是有挂1、we poker辅助...
德州私人局脚本!wepoker... 德州私人局脚本!wepoker怎么买辅助(透视)器-一直揭幕真的是有挂1、wepoker怎么买辅助辅...