AWS SQS订阅SNS主题高延迟
我有几个。Net 5.0微服务，RabbitMQ作为消息代理。现在我正在切换到AWS SQS。很少有服务在侦听相同的消息（这是通过RabbitMQ中的Exchange完成的）。在AWS中，这可以通过将SQS队列订阅到SNS主题来实现。我创建了SNS fifo topic和SQS fifo队列，将这些队列订阅到topic。当我将消息直接发布到队列时，一切都会立即工作，但当我将消息发布到SNS主题时，从订阅到主题的队列中获取消息需要7分钟以上。有人注意到这么大的延迟吗？可能是延迟？顺便说一句，所有服务都在同一地区的aws上运行。有什么想法吗？非常感谢您的建议！
共有1个答案
谢谢大家的评论和帮助！就我而言，缺乏sqs经验是主要问题。我在队列设置“传递延迟”中找到了参数，并设置了较小的值，现在我可以立即接收消息。
-
是否有一种方法可以使用AWS CLI列出特定SQS队列订阅的所有AWS SNS主题？ 我已经知道如何看到一个SNS主题上的订阅者列表，但这只有在我知道SNS主题的名称时才起作用。在这种情况下，我只知道SQS队列的名称。 我在网上搜索什么也找不到。
-
我有一个将消息发布到AWS SNS主题字符串的NodeJS应用程序和一个AWS SQS订阅。在SQS控制台上，我可以看到发布的消息。但是，我不清楚SQS队列的访问策略。 问题 当将消息传递到SQS队列时，作为订阅的结果，哪个用户是有效的？与发表该主题的人相同？ 只有在使用时，才能使消息流入队列。那么，我应该如何定义一个限制性策略，使消息只能作为订阅的结果写入队列？ 创建具有权限的队列的AWS SQ
-
我想在一个主题上放一个BrokeredMessage。有些订阅者必须立即处理。一个或多个订阅服务器必须在第二天才开始处理。 我曾经研究过使用BrokeredMessage.ScheduleDenQueueTimeUTC属性来延迟队列和主题上的消息处理，但这意味着所有订阅者都将延迟它们的处理。 我的想法是，我应该在不延迟入队时间的情况下将BrokeredMessage添加到主题中，并在一个订阅服务器
-
https://github.com/azure/azure-service-bus/tree/master/samples/dotnet/gettingstart/microsoft.azure.servicebus/topicsubscriptionwithruleoperationssample 现在我想添加一个筛选器/规则，这样只有通过筛选器中定义的特定条件的消息才应该给订阅。 例如,下面
-
我正在构建一个由亚马逊服务提供支持的警报系统。 我每天将一个文件放到S3上，它生成一个lambda函数（我们称之为生成器函数）来处理该文件。 Generator基于此文件构建警报并将多条消息发布到SNS主题（让我们称之为发件箱）-由Generator计算的每个收件人一条消息。 我在发件箱中订阅了第二个lambda函数（我们称之为Courier），它应该接收每条消息并对其进行处理。 发电机代码： 以
-
我正在试验消息驱动Beans，以便从外部ActiveMQ实例接收主题订阅消息。 我的测试首先从队列订阅开始，它工作得很好。 然后我想尝试主题订阅，但我无法让它工作。 这就是我所拥有的： 会议记录。xml 这是MDB： 我不知道为什么，但从日志中我可以看到，TomEE创建了一个队列，而不是一个主题： 另一个证明是，当我添加持续时间配置时，服务器不会启动： 然后服务器抱怨这不适合配置类型javax.j