SQS FIFO Bank Transfer

FIFO + Idempotency (exactly-once) com AWS SQS FIFO: transferências de uma mesma conta são processadas na ordem correta e um reenvio por falha de rede nunca causa duplo débito.

passos: 6
arquivos: 6
teste: 1
tecnologias: 4

Lógica puraTypeScriptBunAWS SQSMoto

Cenário Relações Comparar

Baixar cartão

Cenário

Um banco processa transferências PIX e TED. Duas garantias são críticas: as transferências de uma mesma conta de origem são liquidadas na ordem em que foram pedidas, e uma transferência reenviada após falha de rede não debita duas vezes. A fila SQS FIFO entrega as duas com MessageGroupId e MessageDeduplicationId.

Como funciona

6 passos

Ordem e deduplicação por conta.

Esconde cada passo: lembre antes de tocar para revelar.

Vocabulário compartilhado

ChangeMessageVisibility+2

maxReceiveCount+2

RedrivePolicy+2

01
O producer envia cada transferência com MessageGroupId = conta de origem e MessageDeduplicationId = id da transferência
02
A fila entrega em ordem dentro de cada grupo; pagadores diferentes correm em paralelo
03
O reenvio com o mesmo id dentro de 5 minutos é descartado pela própria fila
04
Enquanto uma transferência de um pagador está em voo — inclusive esperando retry —, as seguintes do mesmo pagador não são entregues: nenhum débito ultrapassa o anterior
05
Retry por ChangeMessageVisibility; esgotado o maxReceiveCount, a RedrivePolicy move para a DLQ FIFO; mensagem ilegível vai direto, com o grupo original
06
A deduplicação da fila vale só 5 minutos: a liquidação envia o id da transferência como chave de idempotência ao razão

apps/messaging-streaming/sqs-fifo-bank-transfer

6 arquivos

src/

transfer_fifo.tsTransferência, envio com grupo por pagador e deduplicação pelo id, validação do corpo
worker_sqs.tsLoop de consumo: slots, heartbeat de visibilidade, delete em lote, retry por visibilidade e DLQ FIFO
consumer_transfer.tsLiquidação com chave de idempotência
producer_transfer.tsTransferências de dois pagadores e um reenvio
config_transfer.tsVariáveis de ambiente validadas no boot
worker_sqs.test.tstesteIntegração com moto: ordem por pagador, reenvio descartado, retry que bloqueia o grupo e envio sem grupo recusado

Executar · só Bun

$ cp .env.example .env# variáveis de ambiente
$ bun install# dependências
$ bun run consumer# terminal 1
$ bun run demo# terminal 2
$ bun run test# testes unitários
$

Roda contra a AWS: exige credenciais pela cadeia padrão do SDK e a fila FIFO com DLQ criadas pela IaC. Os testes rodam contra o moto.

Requisitos: Bun
Sobe junto: Moto

Relações

Onde ele se encaixa

Mapa

SQS FIFO Bank Transfer

Combina com4

Por que se relacionam

Combina com

Teste rápido

Qual destes combina com SQS FIFO Bank Transfer?

Próximo projeto · Comunicação & MensageriaSQS Order Processor

Contatos

SQS FIFO Bank Transfer