Tópicos do SNS e arquitetura de distribuição

O Amazon Simple Notification Service (SNS) é um serviço de mensagens de publicação e assinatura totalmente gerenciado. Os publicadores enviam mensagens para um tópico do SNS, e o SNS entrega imediatamente essas mensagens a todos os assinantes. Diferentemente do SQS (baseado em busca), o SNS é baseado em envio: ele entrega as mensagens aos assinantes assim que elas são publicadas. Isso torna o SNS ideal para transmitir eventos a vários sistemas downstream simultaneamente.

Assim como o SQS, o SNS tem dois tipos de tópicos: os tópicos Standard oferecem ordenação de mensagens com melhor esforço, entrega pelo menos uma vez e capacidade de processamento praticamente ilimitada; eles podem entregar mensagens ao SQS, ao Lambda, a endpoints HTTP, por e-mail, SMS e notificações push móveis. Os tópicos FIFO garantem ordenação rigorosa e entrega exatamente uma vez apenas para assinantes do SQS FIFO. Os tópicos FIFO suportam até 3.000 mensagens por segundo com agrupamento e são usados quando a ordem dos eventos precisa ser preservada entre vários assinantes.

O SNS oferece suporte a vários tipos de assinantes baseados em protocolos:

• SQS: enfileiramento durável (o mais comum para processamento assíncrono)
• Lambda: invocação direta (síncrona do ponto de vista do SNS)
• HTTP/HTTPS: entrega por webhook a endpoints externos
• E-mail / E-mail-JSON: notificação para pessoas
• SMS: entrega de mensagens de texto
• Push móvel: FCM, APNs por meio de aplicações de plataforma
• Firehose: transmissão para o S3 ou o Redshift por meio do Kinesis Data Firehose

Distribuição é o padrão central do SNS: publique uma mensagem em um tópico, e o SNS a entregará simultaneamente a todos os assinantes. Por exemplo, um novo evento de pedido é distribuído para: uma fila do SQS para atendimento no armazém, outra fila do SQS para atualização do inventário, uma função do Lambda para detecção de fraude e uma assinatura de e-mail para a equipe de operações. Cada assinante processa o evento de forma independente, sem acoplamento entre eles. Isso é muito mais escalável do que um único consumidor encaminhando mensagens para vários sistemas.

O padrão recomendado combina SNS e SQS: publique no SNS, que distribui as mensagens para várias filas do SQS. Isso oferece:

• Durabilidade: se um consumidor estiver indisponível, as mensagens ficam enfileiradas no SQS
• Escalonamento independente: cada consumidor processa as mensagens no próprio ritmo
• Desacoplamento: novos consumidores apenas assinam o SNS, sem alterar o publicador
• Resiliência a novas tentativas: o SQS oferece tempo limite de visibilidade e DLQ

Assinantes diretos do Lambda não têm o armazenamento intermediário oferecido pelo SQS, o que torna SNS→SQS→Lambda o padrão de três camadas mais resiliente.

Quando o SNS não consegue entregar uma mensagem a um assinante (o endpoint HTTP retorna 5xx, o Lambda gera uma exceção ou o SQS está indisponível), ele tenta novamente usando uma estratégia de retardo exponencial. As políticas de novas tentativas variam conforme o protocolo: endpoints HTTP recebem até 4 novas tentativas imediatas, seguidas de retardo exponencial ao longo de 23 dias; Lambda e SQS usam mecanismos próprios para gerenciar novas tentativas. Configure uma DLQ de tópico do SNS para capturar mensagens que esgotarem todas as tentativas de entrega, garantindo que nenhum evento seja perdido silenciosamente.

Publique no SNS usando o AWS SDK ou a CLI. Cada mensagem pode incluir um assunto (para e-mail), um corpo da mensagem (de até 256 KB) e atributos da mensagem para roteamento. Para diferentes tipos de assinantes (SQS, e-mail ou dispositivos móveis), você pode usar a estrutura da mensagem para enviar conteúdo diferente a cada protocolo; o JSON com chaves específicas do protocolo permite adaptar a carga útil para cada tipo de assinante.

As políticas de filtragem de assinaturas permitem que cada assinante receba apenas as mensagens relevantes para ele, com base nos atributos da mensagem. Sem filtragem, todos os assinantes recebem todas as mensagens publicadas. Com uma política de filtragem, um assinante especifica quais valores de atributos são importantes para ele. Por exemplo, uma fila de pedidos 'PREMIUM' assina com o filtro {"orderType": ["PREMIUM"]}; uma fila 'STANDARD' filtra por ["STANDARD"]. Cada assinante processa apenas o subconjunto relevante, reduzindo o processamento desnecessário.

O SNS oferece suporte a notificações push móveis diretas para dispositivos iOS (APNs) e Android (FCM/GCM). Você registra os tokens dos dispositivos como ARNs de endpoints de plataforma e publica diretamente em um endpoint ou em um tópico com assinantes de aplicações de plataforma. Para notificações diretas em grande escala para dispositivos (milhões de dispositivos), combine o SNS com a distribuição pelo SQS: o SNS encaminha o evento de notificação para o SQS, e um serviço de trabalho gerencia a resolução em massa dos tokens e a entrega em escala.

Proteja as mensagens do SNS com criptografia no lado do servidor usando o AWS KMS. Isso criptografa as mensagens armazenadas na infraestrutura do SNS. O controle de acesso usa tanto políticas baseadas em recursos (quem pode publicar no tópico ou assinar o tópico) quanto políticas do IAM. Para permitir que um bucket do S3 publique notificações em um tópico do SNS, conceda sns:Publish à entidade principal de serviço do S3 na política baseada em recursos do tópico. Restrinja sempre a publicação a fontes autorizadas para evitar a injeção de eventos não autorizados.

SNS e SQS são complementares, não alternativas. O SNS (envio) serve para transmitir mensagens imediatamente a vários consumidores; use-o quando vários sistemas precisarem reagir a um evento. O SQS (busca) serve para o processamento confiável e durável por um único consumidor, com novas tentativas e DLQ; use-o quando um consumidor precisar processar cada mensagem exatamente uma vez, no próprio ritmo. O padrão de distribuição SNS→SQS oferece os dois recursos: entrega em transmissão pelo SNS e processamento durável, com novas tentativas, pelo SQS. Essa combinação aparece com frequência nos cenários do exame SAA-C03.

Teste sua compreensão dos conceitos do AWS Solutions Architect (SAA-C03) apresentados nesta lição.

Nesta lição, você aprendeu: os tópicos do SNS oferecem transmissão de publicação e assinatura baseada em envio para assinantes, incluindo SQS, Lambda, HTTP, SMS e e-mail simultaneamente; a arquitetura de distribuição usa um tópico do SNS conectado a várias filas do SQS para obter processamento de eventos por vários consumidores, com durabilidade e escalonamento independente; e as políticas de filtragem de assinaturas reduzem o processamento desnecessário encaminhando apenas os eventos relevantes a cada assinante com base nos atributos da mensagem. A seguir, exploraremos em profundidade a filtragem de mensagens do SQS e a integração entre SNS e SQS.