Um aplicativo ingere mensagens de entrada que dezenas de outros aplicativos e microsserviços consomem rapidamente. O volume de mensagens varia drasticamente e pode atingir picos de 100.000 mensagens por segundo. A empresa deseja desacoplar componentes e aumentar a escalabilidade. Qual solução atende a esses requisitos?

A solução correta utiliza o Amazon SNS para publicar mensagens em um tópico, que então distribui essas mensagens para múltiplas filas do Amazon SQS. Este padrão desacopla o produtor dos consumidores, permitindo que o SNS lide com o alto volume de mensagens de entrada (até 100.000 mensagens por segundo) e o SQS forneça um buffer escalável para os consumidores. Cada aplicativo consumidor pode ler de sua própria fila SQS de forma independente e em seu próprio ritmo, garantindo escalabilidade e resiliência. As outras opções são menos adequadas: O Amazon Kinesis Data Analytics é para análise em tempo real, não para ingestão e distribuição de mensagens para múltiplos consumidores. Implantar o aplicativo de ingestão em instâncias EC2 com Auto Scaling resolve a escalabilidade do produtor, mas não desacopla os consumidores nem gerencia a distribuição eficiente das mensagens para múltiplos aplicativos. Gravar no Kinesis Data Streams com um único shard limita a escalabilidade de ingestão (um único shard tem um limite de 1MB/s ou 1000 registros/s). Usar o DynamoDB para os consumidores lerem pode ser ineficiente para múltiplos consumidores buscando as mesmas mensagens e não é o padrão ideal para desacoplamento de mensagens.