Я должен реализовать следующий сценарий: я отправляю сообщения чему-либо (очередь? Поток), и у меня есть два типа для потребителей: 1) существует в одном экземпляре и записывает сообщения в s3 2) много экземпляров для масштабирования сообщений процесса, и каждое сообщение должно будет обработан один раз
Как мне реализовать это, используя AWS управляемые сервисы? Разные потребители получают все сообщения каждое - это потоки и Kinesis. Каждое сообщение обрабатывается один раз - это очереди и SQS
Но мне нужно здесь сочетание обоих подходов