AWS控制台如何接收具有相同消息组ID的多个FIFO队列消息?
创始人
2024-11-19 08:00:20
0

针对FIFO队列,消息组ID可确保先入先出的顺序。AWS控制台如何接收具有相同消息组ID的多个FIFO队列消息呢?AWS SNS提供一种解决方法,即设置SNS订阅FIFO队列。通过将SNS作为中介,消息可以在通过SNS传输时获取唯一的消息组ID。 AWS SNS还提供了一些有用的选项,例如将错误发送到SNS,而不是直接到达AWS Lambda。

以下是设置SNS订阅FIFO队列的Python代码示例:

import boto3

sqs = boto3.client('sqs')
sns = boto3.client('sns')

queue_url = 'https://sqs.us-east-2.amazonaws.com/123456789012/my-queue.fifo'
topic_arn = 'arn:aws:sns:us-east-2:123456789012:my-topic.fifo'

# Create SQS queue
response = sqs.create_queue(
    QueueName='my-queue.fifo',
    Attributes={
        'FifoQueue': 'true',
        'ContentBasedDeduplication': 'true'
    }
)

queue_url = response['QueueUrl']

# Create SNS Topic
response = sns.create_topic(
    Name='my-topic.fifo',
    Attributes={
        'FifoTopic': 'true'
    }
)

topic_arn = response['TopicArn']

# Subscribe SQS queue to SNS Topic
response = sns.subscribe(
    TopicArn=topic_arn,
    Protocol='sqs',
    Endpoint=queue_url,
    Attributes={
        'FilterPolicy': '{"department": ["finance", "engineering"]}',
        'RawMessageDelivery': 'true'
    }
)

创建SNS订阅后,如果队列具有相同的消息组ID,AWS SNS将自动将它们合并为一条消息发送到SNS主题中,从而避免了AWS控制台重复接收消息的问题。

相关内容

热门资讯

为切实保障!哈灵脚本修改器!真... 为切实保障!哈灵脚本修改器!真是有挂辅助软件(真实有挂)-哔哩哔哩1、哈灵脚本修改器脚本辅助下载、哈...
截至目前!天天填大坑辅助器免费... 截至目前!天天填大坑辅助器免费下载!原来真的有辅助脚本(真的有挂)-哔哩哔哩1、金币登录送、破产送、...
昨日!方片十三张透视!切实存在... 昨日!方片十三张透视!切实存在有辅助app(有挂辅助)-哔哩哔哩1、方片十三张透视免费脚本咨询教程、...
据悉!微信呢微乐游戏辅助脚本!... 据悉!微信呢微乐游戏辅助脚本!总是存在有辅助app(有挂实锤)-哔哩哔哩运微信呢微乐游戏辅助脚本辅助...
事发当天!友间十三道有什么窍门... 事发当天!友间十三道有什么窍门!竟然真的有辅助安装(有挂教学)-哔哩哔哩1、这是跨平台的友间十三道有...
今天上午!四川长牌辅助!都是真... 今天上午!四川长牌辅助!都是真的是有辅助神器(有挂透视)-哔哩哔哩1、超多福利:超高返利,海量正版游...
此事备受玩家关注!龙江博乐填大... 此事备受玩家关注!龙江博乐填大坑辅助!切实真的有辅助器(有挂规律)-哔哩哔哩1)龙江博乐填大坑辅助有...
反观!湖南牵手胡子跑辅助!竟然... 反观!湖南牵手胡子跑辅助!竟然有挂辅助工具(存在有挂)-哔哩哔哩1)湖南牵手胡子跑辅助有没有挂:进一...
值得注意的是!闲逸软件可以控制... 值得注意的是!闲逸软件可以控制的吗!竟然存在有辅助app(有挂教程)-哔哩哔哩1、游戏颠覆性的策略玩...
记者获悉!518互游破解!都是... 记者获悉!518互游破解!都是是有辅助神器(有挂秘籍)-哔哩哔哩小薇(辅助器软件下载)致您一封信;亲...