选择性地从SQS队列读取消息
有一个SQS队列，我在其中不断收到消息。我只需要阅读和处理过去24小时内收到的信息。目前收到的信息应在第二天处理<代码>时间戳存储在消息正文中。
是否可以从SQS队列中选择性地读取消息。例如，只读那些时间戳值大于前一天的时间戳但小于当前时间戳（当前时间戳是此作业运行的时间）的消息？
共有1个答案
Amazon SQSReceiveMessages命令从队列返回一条消息（或一批消息）。消息的顺序大致为FIFO（先进先出），但这并不保证。
没有办法选择性地检索消息。无法使用消息的内容、消息属性或消息元数据来限制返回的消息。基本上就是从堆栈中弹出一条消息。
-
我有一个java客户机，它在队列中发送jms消息（“队列请求”）。该消息包含一个int属性（“id”），其中包含唯一的客户端id号。消息正在处理中，然后进入另一个队列（“队列响应”）。如何让客户机等到具有其id的消息在队列中，然后读取它。我曾尝试使用侦听器并实现onMessage，但当收到消息时，我如何停止侦听？
-
我是AWS的新手。我在这里试图理解SQS。我也看了一些培训，但我仍然不能得到一些答案那里的讨论论坛。我在这里重复我的问题。注意，我知道下面的几个问题有明显的答案，因此更多的是一种修辞。我的困惑源于这样一个事实，即我目前对这个主题的理解导致我对在明显已知的问题之后出现在我脑海中的后续问题给出了相互矛盾的答案，并且夺走了我认为我理解得很好的任何东西的信心。 如果我有一个名为MyQueue的标准队列，并
-
我有一个触发Lambda函数的SQS队列。我正在尝试解析SQS消息并提取相关数据。我特别尝试提取s3对象键和s3 bucket arn。 我当前的Lambda函数： CloudWatch中显示的我的SQS消息： 最后一个错误是： 我还尝试了objectKey=record['Records][0]['s3']['object']['key']。谢谢
-
我已经建立了AWS架构体系，以便每次对发电机数据库条目的更新都以启用重复数据删除的SQS先进先出队列结束。我还有一个测试来覆盖这个场景，在那里我清除了队列（队列可以从套装中的其他测试中获得更新。为了避免在收到正确的消息之前必须轮询大量的消息，我在运行测试之前清除队列），更新Dynamo Db，并在轮询队列时检查这些条目是否收到。这个测试是不稳定的，有时会失败，因为我发送的所有更新都没有从队列中收到
-
我试图实现一个AWS SQS队列，以最大限度地减少来自后端服务器的数据库交互，但我遇到了问题。 我有一个消费者进程，它从一个SQS队列中查找消息 为了测试功能，我为一个客户端实现了逻辑。它运行得很好。然而，当我添加了3个客户端时，它不能正常工作。我能够看到SQS队列被500条消息卡住了，后端作业正在正常工作，从队列中读取。 我需要增加后端作业的数量还是增加客户端SQS队列的数量？现在，所有客户端都
-
我有一个应用程序，在这个应用程序中，我可以在进程的一部分中以JSON格式将消息写入Azure服务总线队列。我有一个下游进程，我想将该消息从队列中弹出，将json转换为一个对象，然后处理该对象。 我没有问题将消息推送到队列上，但我还没有找到任何将消息从队列中逐一或循环弹出的示例。我在微软或Github上看到的每一个例子都是一个控制台应用程序（在网络应用程序中毫无用处），它设置了某种侦听器，可以抓取队