Kif tikkoordina cron job fuq diversi nodi NestJS?

Question

IT Interview Practice · Accepted Answer

L-ewwel iddefinixxi xi tfisser “node wieħed biss iħaddem il-cronjob”. **Li tipprevjeni eżekuzzjonijiet simultanji u li tipprevjeni effett tan-negozju ripetut huma ħtiġijiet differenti.** Scheduler kondiviż jikkoordina l-eżekuzzjoni; l-operazzjoni nnifisha trid tibqa’ sigura wara crash u tentattiv ieħor.

Ikkunsidra xogħol ta’ fatturi ta’ kuljum installat fuq tliet nodes NestJS. Irridu li x-xogħol skedat iseħħ, mingħajr ma tinħoloq fattura oħra meta worker jerġa’ jibda.

## 1. Ifhem għaliex in-nodes kollha jibdew ix-xogħol

Kull istanza tal-applikazzjoni tirreġistra l-cron callback tagħha. Fil-ħin skedat, kull waħda tista’ tibda indipendentement:

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

Flag lokali isRunning jeżisti biss fi proċess wieħed. NestJS waitForCompletion jista’ jwaqqaf callbacks li jikkoinċidu fuq dik l-istanza, iżda ma jikkoordinax in-nodes l-oħra. L-istess flag fit-tliet nodes xorta jħalli tliet deċiżjonijiet separati. [Skedar f’NestJS](https://docs.nestjs.com/techniques/task-scheduling).

Għalhekk neħtieġu post kondiviż biex niddeċiedu liema xogħol jeżisti u min jista’ jipproċessah.

## 2. Agħżel il-mudell ta’ koordinazzjoni

| Sitwazzjoni | Għażla li għandha tiġi evalwata | Responsabbiltà li tibqa’ |
| --- | --- | --- |
| Il-pjattaforma diġà tipprovdi xogħlijiet skedati | Agħmel l-iskedar barra l-istanzi web | Ikkonfigura sovrappożizzjoni, irkupru u x’jiġri meta jintilef ħin skedat. |
| It-tim diġà jħaddem BullMQ | Job Scheduler kondiviż u queue apposta | Ikkonfigura konkorrenza kondiviża u tentattivi mill-ġdid siguri. |
| Ix-xogħol eżistenti jrid jibqa’ fuq in-nodes tal-applikazzjoni | Lock jew lease kondiviż | Immaniġġja sew is-sjieda, l-iskadenza u workers b’sjieda skaduta. |

Għall-fatturi, jekk Redis u BullMQ diġà jeżistu, scheduler kondiviż b’ID stabbli huwa għażla prattika. Issepara l-iskeda mill-workers sabiex iż-żieda ta’ nodes web ma toħloqx skedi indipendenti.

F’verżjoni ta’ BullMQ li tappoġġaha, issettja l-konkorrenza globali tal-queue apposta għal wieħed. Dan jillimita x-xogħlijiet attivi fost il-workers kollha; konkorrenza lokali ta’ wieħed għal kull worker xorta tippermetti lil diversi workers jagħmlu xogħlijiet differenti. [Konkorrenza globali](https://docs.bullmq.io/guide/queues/global-concurrency).

Iddeċiedi x’għandu jiġri jekk ix-xogħol tal-bieraħ għadu għaddej: tistenna, taqbeż jew tgħaqqad l-okkorrenzi. Iddefinixxi ż-żona tal-ħin u jekk id-dati tan-negozju mitlufa għandhomx jiġu pproċessati wara waqfien.

## 3. Ipproteġi l-fattura, mhux biss ix-xogħol

Ejja ngħidu li worker joħloq fattura u jikkraxxja qabel jirreġistra li x-xogħol tlesta. L-irkupru jista’ jerġa’ jħaddem ix-xogħol għalkemm il-fattura diġà teżisti.

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

Uża ċavetta tan-negozju stabbli, bħall-klijent flimkien mal-perjodu tal-kont. Għal xogħol fid-database lokali, restrizzjoni ta’ uniċità u tranżazzjoni jistgħu jorbtu l-ħolqien tal-fattura mar-rekord tax-xogħol komplut. Tentattiv ieħor imbagħad isib ir-riżultat eżistenti minflok joħloq fattura oħra.

Għal fornitur estern, uża ċ-ċavetta tal-idempotenza tiegħu meta tkun appoġġata u rrikonċilja riżultati inċerti. ID ta’ job jew rekord miżmum fil-queue waħdu mhuwiex garanzija permanenti li azzjoni tan-negozju ma tistax tirrepeti ruħha. [Xogħlijiet idempotenti](https://docs.bullmq.io/patterns/idempotent-jobs).

## 4. Kun af x’jista’ u x’ma jistax jiggarantixxi lock

Lock kondiviż irid jinkiseb atomikament. Uża token tas-sjieda, skadenza u tiġdid; erħih biss meta t-token għadu jaqbel. Inkella worker antik jista’ jerħi l-lock ta’ worker ġdid.

L-iskadenza toħloq każ ieħor: worker wieqaf jerġa’ jkompli wara li tiskadi l-lease tiegħu waqt li worker ġdid diġà qed jaħdem. Kitbiet kritiċi jistgħu jeħtieġu fencing tokens, numri tas-sjieda li dejjem jiżdiedu u li d-destinazzjoni tiċċekkja biex tirrifjuta workers b’sjieda qadima. Timeout twil waħdu ma jeliminax dan ir-riskju.

Jekk il-koordinazzjoni mhix disponibbli, iddeċiedi jekk ix-xogħol għandux jistenna minflok jaħdem mingħajr sjieda. Għal xogħol b’konsegwenzi importanti, din spiss tkun l-għażla aktar sigura.

## 5. Ivverifika l-każijiet ta’ falliment

Ittestja diversi nodes, crash wara l-ħolqien tal-fattura, pawża itwal mil-lease, telf ta’ konnessjoni ma’ Redis u deployment gradwali. Irreġistra d-data tan-negozju, il-worker, it-tentattiv u r-riżultat sabiex tiddistingwi tentattivi ripetuti minn effetti ripetuti.

**Ftakar:** ikkoordina l-iskedar → illimita l-eżekuzzjoni kondiviża → agħmel l-azzjoni tan-negozju sigura għar-ripetizzjoni → ittestja l-irkupru. “Job attiv wieħed” waħdu ma jipprovax effett tan-negozju eżattament darba.

Sitwazzjoni	Għażla li għandha tiġi evalwata	Responsabbiltà li tibqa’
Il-pjattaforma diġà tipprovdi xogħlijiet skedati	Agħmel l-iskedar barra l-istanzi web	Ikkonfigura sovrappożizzjoni, irkupru u x’jiġri meta jintilef ħin skedat.
It-tim diġà jħaddem BullMQ	Job Scheduler kondiviż u queue apposta	Ikkonfigura konkorrenza kondiviża u tentattivi mill-ġdid siguri.
Ix-xogħol eżistenti jrid jibqa’ fuq in-nodes tal-applikazzjoni	Lock jew lease kondiviż	Immaniġġja sew is-sjieda, l-iskadenza u workers b’sjieda skaduta.

1. Ifhem għaliex in-nodes kollha jibdew ix-xogħol

2. Agħżel il-mudell ta’ koordinazzjoni

3. Ipproteġi l-fattura, mhux biss ix-xogħol

4. Kun af x’jista’ u x’ma jistax jiggarantixxi lock

5. Ivverifika l-każijiet ta’ falliment

Mistoqsijiet relatati