SQS 上的审核消息
Moderated messages on SQS
我有一个消息用例问题。
我们在 AWS SQS 中有一个队列,比如说,origQueue 和 out-of -the-box-lambda-based-message-consumption 在该队列上。
现在为了迎合基于审核的消息消费的一个特定功能(基于消息中的 'isModerated' 标志),我想有另一个并行队列(这只是一个审核版本上述队列)。在这个 'moderated' 队列上,我们不希望自动消费,而是寻找基于节制步骤触发器的消费。这意味着任何 lambda 都不会一直监听这个队列。
我的一个想法是在运行时触发一个 lambda(在审核完成后),它基本上会从审核队列中退出队列,从消息中删除 'isModerated' 标志并将它们重新排队实际队列,即 origQueue。
但在这样做之前,我只是想收集其他可能的想法。是否有任何开箱即用的 AWS 功能或任何模式来解决这个基于触发器的消息消费问题?
如果消息从 SNS 进入队列,您可以在消息进入队列之前使用消息过滤:
https://docs.aws.amazon.com/sns/latest/dg/sns-message-filtering.html
我有一个消息用例问题。
我们在 AWS SQS 中有一个队列,比如说,origQueue 和 out-of -the-box-lambda-based-message-consumption 在该队列上。
现在为了迎合基于审核的消息消费的一个特定功能(基于消息中的 'isModerated' 标志),我想有另一个并行队列(这只是一个审核版本上述队列)。在这个 'moderated' 队列上,我们不希望自动消费,而是寻找基于节制步骤触发器的消费。这意味着任何 lambda 都不会一直监听这个队列。
我的一个想法是在运行时触发一个 lambda(在审核完成后),它基本上会从审核队列中退出队列,从消息中删除 'isModerated' 标志并将它们重新排队实际队列,即 origQueue。
但在这样做之前,我只是想收集其他可能的想法。是否有任何开箱即用的 AWS 功能或任何模式来解决这个基于触发器的消息消费问题?
如果消息从 SNS 进入队列,您可以在消息进入队列之前使用消息过滤:
https://docs.aws.amazon.com/sns/latest/dg/sns-message-filtering.html