Kako koordinirati cron posao na više NestJS čvorova?

Question

IT Interview Practice · Accepted Answer

Najprije definirajte što znači „samo jedan čvor izvršava cronjob”. **Sprječavanje istodobnog izvršavanja i sprječavanje ponovljenog poslovnog učinka različiti su zahtjevi.** Zajednički raspoređivač koordinira izvršavanje, a sama operacija mora biti sigurna nakon rušenja i ponavljanja.

Uzmimo dnevni posao izdavanja računa na tri NestJS čvora. Želimo izvršiti planirani rad bez stvaranja dodatnog računa nakon ponovnog pokretanja workera.

## 1. Shvatite zašto svi čvorovi pokreću zadatak

Svaka instanca aplikacije registrira vlastiti cron callback. U zakazano vrijeme svaka može početi neovisno:

```text
00:00 -> Node A -> invoice task
      -> Node B -> invoice task
      -> Node C -> invoice task
```

Lokalna zastavica isRunning postoji samo u jednom procesu. NestJS waitForCompletion može spriječiti preklapanje poziva na toj instanci, ali ne koordinira druge čvorove. Ista zastavica na tri čvora i dalje znači tri odvojene odluke. [NestJS raspoređivanje](https://docs.nestjs.com/techniques/task-scheduling).

Zato trebamo zajedničko mjesto koje odlučuje koji posao postoji i tko ga smije obraditi.

## 2. Odaberite model koordinacije

| Situacija | Mogućnost za procjenu | Preostala odgovornost |
| --- | --- | --- |
| Platforma već nudi zakazane poslove | Raspoređivanje izvan web instanci | Podesiti preklapanje, oporavak i propuštena izvršavanja. |
| Tim već održava BullMQ | Zajednički Job Scheduler i namjenski red | Podesiti zajedničku konkurentnost i sigurna ponavljanja. |
| Zadatak mora ostati na aplikacijskim čvorovima | Zajednička brava ili vremenski najam | Ispravno obraditi vlasništvo, istek i zastarjele workere. |

Za račune, ako Redis i BullMQ već postoje, zajednički raspoređivač sa stabilnim ID-jem praktičan je kandidat. Odvojite raspored od workera kako dodavanje web čvorova ne bi stvorilo neovisne rasporede.

Na podržanoj verziji BullMQ-a postavite globalnu konkurentnost namjenskog reda na jedan. Time ograničavate aktivne poslove među svim workerima; lokalna vrijednost jedan na svakom workeru i dalje dopušta više različitih poslova istodobno. [Globalna konkurentnost](https://docs.bullmq.io/guide/queues/global-concurrency).

Odredite što ako jučerašnji posao još traje: čekati, preskočiti ili spojiti pojavljivanja. Definirajte vremensku zonu i treba li nadoknaditi propuštene poslovne dane nakon prekida.

## 3. Zaštitite račun, a ne samo posao

Pretpostavimo da worker stvori račun i sruši se prije bilježenja dovršetka. Oporavak može ponoviti posao iako račun već postoji.

```text
[Create invoice] -> [Crash before completion]
                              |
                            [Retry]
                              |
                  [Same business key: reuse result]
```

Koristite stabilan poslovni ključ, primjerice korisnik i obračunsko razdoblje. U lokalnoj bazi jedinstveno ograničenje i transakcija mogu povezati stvaranje računa sa zapisom dovršenog rada. Ponovni pokušaj pronalazi postojeći rezultat umjesto novog računa.

Za vanjskog pružatelja koristite njegov ključ idempotentnosti ako postoji i uskladite neizvjesne ishode. ID posla ili sačuvani zapis reda sami po sebi nisu trajno jamstvo protiv ponavljanja poslovne radnje. [Idempotentni poslovi](https://docs.bullmq.io/patterns/idempotent-jobs).

## 4. Znajte što brava jamči, a što ne

Zajednička brava mora se dobiti atomski. Koristite token vlasništva, istek i obnovu; oslobađajte je samo ako token još odgovara. Inače stari worker može osloboditi bravu novijega.

Istek donosi drugi slučaj: zaustavljeni worker nastavlja nakon isteka najma dok novi već radi. Kritični upisi mogu trebati fencing tokene, rastuće brojeve vlasništva koje odredište provjerava kako bi odbilo zastarjele workere. Sam dugačak timeout ne uklanja rizik.

Ako koordinacija nije dostupna, odlučite treba li zadatak čekati umjesto rada bez vlasništva. Za rad s važnim posljedicama to je često sigurnije.

## 5. Provjerite kvarove

Testirajte više čvorova, rušenje nakon stvaranja računa, pauzu dulju od najma, gubitak veze s Redisom i postupno uvođenje verzije. Bilježite poslovni datum, worker, pokušaj i ishod kako biste razlikovali ponovljene pokušaje od ponovljenih učinaka.

**Zapamtite:** koordinirajte raspored → ograničite zajedničko izvršavanje → učinite poslovnu radnju sigurnom za ponavljanje → testirajte oporavak. „Jedan aktivan posao” nije dokaz točno jednog poslovnog učinka.

Situacija	Mogućnost za procjenu	Preostala odgovornost
Platforma već nudi zakazane poslove	Raspoređivanje izvan web instanci	Podesiti preklapanje, oporavak i propuštena izvršavanja.
Tim već održava BullMQ	Zajednički Job Scheduler i namjenski red	Podesiti zajedničku konkurentnost i sigurna ponavljanja.
Zadatak mora ostati na aplikacijskim čvorovima	Zajednička brava ili vremenski najam	Ispravno obraditi vlasništvo, istek i zastarjele workere.

1. Shvatite zašto svi čvorovi pokreću zadatak

2. Odaberite model koordinacije

3. Zaštitite račun, a ne samo posao

4. Znajte što brava jamči, a što ne

5. Provjerite kvarove

Povezana pitanja