Krok 05 / 20 · Zbieranie · SQS · retry · DLQ

Kolejka zdarzeń

Buforowanie i retry, nic nie ginie.

Dla biznesu

Co to jest

Bufor między krokami, dzięki któremu praca czeka w kolejce, zamiast przepadać, gdy coś jest zajęte albo nie działa.

Dlaczego to ważne

Skoki ruchu są amortyzowane, błędy automatycznie ponawiane i nic nie znika, nawet podczas awarii dostawcy albo deployu.

Ryzyko bez tego

Wolny dostawca AI albo release zamienia się w utraconą pracę i ręczne ponowne przesyłanie plików.

Dla inżynierów

Jak to działa

Każdy etap konsumuje z kolejki i emituje zdarzenie dla następnego. Retry używa wykładniczego backoffu; wiadomości, które wciąż się nie udają, lądują w dead-letter queue, która podnosi alert. Konsumenci są idempotentni, więc retry nigdy nie podwaja pracy.

Typowy stack

  • SQS + dead-letter queue
  • EventBridge
  • Step Functions

Pułapki i kompromisy

  • Visibility timeout musi być dłuższy niż najdłuższy czas przetwarzania.
  • Niemonitorowana DLQ to tylko wolniejszy sposób na utratę danych.
  • Kolejność nie jest gwarantowana, chyba że wybierzesz FIFO.

W tym przykładzie

Wejście
event: meeting.ready
Wyjście
w kolejce · próba 1
dead-letter: pusta

Fikcyjny przykład · nie system klienta

Kontakt

Masz pytania?

Umów rozmowę Napisz na hello@paxcode.it