У меня вопрос об использовании сообщений.
У нас есть очередь в AWS SQS, скажем, origQueue и out-of-the-box-lambda-based-message-потребление в этой очереди.
Теперь, чтобы удовлетворить одну особенность потребления сообщений на основе модерации (на основе флага 'isModerated' в сообщении), я думаю иметь другую параллельную очередь (которая будет просто модерируемой версиейвышеуказанная очередь).В этой «модерируемой» очереди нам не нужно автоматическое потребление, скорее мы ищем умеренное пошаговое потребление.Это означает, что любая лямбда не будет слушать эту очередь все время.
Одна мысль, которая у меня возникла, - запускать лямбду во время выполнения (после проведения модерации), которая в основном удаляет очередь из модерируемой очереди, убирает флаг «isModerated» из сообщений и помещает их в очередь втекущая очередь, т.е. origQueue .
Но прежде чем идти по этому пути, я просто хотел собрать другие потенциальные идеи.Существует ли какая-либо готовая функция AWS или шаблон для решения этой проблемы потребления сообщений на основе триггера?