Filtragem de SNS mensagens da Amazon para tópicos FIFO - Amazon Simple Notification Service

As traduções são geradas por tradução automática. Em caso de conflito entre o conteúdo da tradução e da versão original em inglês, a versão em inglês prevalecerá.

Filtragem de SNS mensagens da Amazon para tópicos FIFO

SNSFIFOOs tópicos da Amazon oferecem suporte à filtragem de mensagens. O uso da filtragem de mensagens simplifica sua arquitetura descarregando a lógica de roteamento de mensagens dos sistemas do editor e a lógica de filtragem de mensagens de seus sistemas assinantes.

Ao inscrever uma fila Amazon SQS FIFO ou uma fila padrão em um SNS FIFO tópico, você pode usar a filtragem de mensagens para especificar que o assinante receba um subconjunto de mensagens, em vez de todas elas. Cada assinante pode definir sua própria política de filtro como atributos de assinatura. Com base no escopo da política de filtro, a política de filtro é comparada aos atributos ou ao corpo da mensagem recebida. Se a política de filtro estabelecer correspondência, o tópico entregará uma cópia da mensagem ao assinante. Se não houver correspondência, o tópico não entregará uma cópia da mensagem.

No exemplo de caso de uso do gerenciamento de preços de autopeças, suponha que as seguintes políticas de SNS filtro da Amazon estejam definidas e que o escopo da política de filtro sejaMessageBody:

  • Para a fila de atacado, a política de filtro {"business":["wholesale"]} estabelece correspondência com cada mensagem que contém uma chave chamada business e com wholesale no conjunto de valores. No diagrama a seguir, uma das chaves na mensagem m1 é business com um valor de wholesale. Uma das chaves na mensagem m3 é business com um valor de ["wholesale,retail"]. Assim, tanto m1 quanto m3 correspondem aos critérios da política de filtro e ambas as mensagens são entregues à fila de atacado.

  • Para a fila de varejo, a política de filtro {"business":["retail"]} estabelece correspondência com cada mensagem que contém uma chave chamada business e com retail no conjunto de valores. No diagrama, uma das chaves na mensagem m2 é business com um valor de retail. Uma das chaves na mensagem m3 é business com o valor de ["wholesale,retail"]. Assim, tanto m2 quanto m3 correspondem aos critérios da política de filtro e ambas as mensagens são entregues à fila de varejo.

  • Com relação à fila de análise, queremos que o Amazon Athena receba todos os registros, para que nenhuma política de filtro seja aplicada.

Exemplo de como SNS FIFO os tópicos da Amazon utilizam políticas de filtro para encaminhar mensagens para diferentes SQS filas da Amazon com base no conteúdo da mensagem. As mensagens m1 e m3 com a chave “comercial” definida como “atacado” são entregues na fila de atacado, enquanto a mensagem m2 com a chave “varejo” especifica rotas para a fila de varejo. Isso demonstra a entrega direcionada de mensagens, garantindo que somente mensagens relevantes sejam recebidas por cada função do assinante, otimizando a eficiência do processamento e a relevância dos dados.

SNSFIFOos tópicos oferecem suporte a uma variedade de operadores correspondentes, incluindo valores de cadeia de caracteres de atributos, valores numéricos de atributos e chaves de atributos. Para obter mais informações, consulte SNSFiltragem de mensagens da Amazon.

SNSFIFOos tópicos não entregam mensagens duplicadas aos endpoints inscritos. Para obter mais informações, consulte Desduplicação de SNS mensagens da Amazon para tópicos FIFO.