首页 > 解决方案 > SQS 上的审核消息

问题描述

我有一个消息传递用例问题。

我们在 AWS SQS 中有一个队列,例如origQueue和该队列上的开箱即用的基于 lambda 的消息消费

现在为了迎合基于审核的消息消费的一个特定功能(基于消息中的“isModerated”标志),我正在考虑使用另一个并行队列(这将只是上述队列的审核版本)。在这个“调节”队列上,我们不想要自动消费,而是寻找基于调节步骤触发的消费。这意味着任何 lambda 都不会一直在监听这个队列。

我的一个想法是在运行时触发一个 lambda(在完成审核后),这将基本上从审核队列中出列,从消息中删除 'isModerated' 标志并将它们重新排列在实际队列中,即origQueue

但在这样做之前,我只是想收集其他潜在的想法。是否有任何开箱即用的 AWS 功能或任何模式来解决这个基于触发器的消息消费问题?

标签: amazon-web-servicesaws-lambdamessage-queuemessagingamazon-sqs

解决方案


如果消息从 SNS 进入队列,您可以在它们进入队列之前使用消息过滤:

https://docs.aws.amazon.com/sns/latest/dg/sns-message-filtering.html


推荐阅读