ਕਈ NestJS nodes ਉੱਤੇ cron job ਦਾ ਸਮਨਵਯ ਕਿਵੇਂ ਕਰਨਾ ਹੈ?

Question

IT Interview Practice · Accepted Answer

ਪਹਿਲਾਂ ਤੈਅ ਕਰੋ ਕਿ “ਸਿਰਫ਼ ਇੱਕ ਨੋਡ cronjob ਚਲਾਏ” ਦਾ ਕੀ ਮਤਲਬ ਹੈ। **ਇਕੱਠੇ ਚੱਲਣ ਤੋਂ ਰੋਕਣਾ ਅਤੇ ਕਾਰੋਬਾਰੀ ਅਸਰ ਦੁਹਰਾਉਣ ਤੋਂ ਰੋਕਣਾ ਵੱਖਰੀਆਂ ਲੋੜਾਂ ਹਨ।** ਸਾਂਝਾ scheduler ਚਲਾਉਣ ਦਾ ਤਾਲਮੇਲ ਕਰਦਾ ਹੈ; ਅਸਲ ਕਾਰਵਾਈ ਕ੍ਰੈਸ਼ ਅਤੇ ਮੁੜ ਕੋਸ਼ਿਸ਼ ਤੋਂ ਬਾਅਦ ਵੀ ਸੁਰੱਖਿਅਤ ਹੋਣੀ ਚਾਹੀਦੀ ਹੈ।

ਤਿੰਨ NestJS ਨੋਡਾਂ ਉੱਤੇ ਰੋਜ਼ਾਨਾ ਬਿੱਲ ਬਣਾਉਣ ਵਾਲੀ ਜੌਬ ਸੋਚੋ। ਯੋਜਨਾਬੱਧ ਕੰਮ ਹੋਣਾ ਚਾਹੀਦਾ ਹੈ, ਪਰ worker ਮੁੜ ਚੱਲੇ ਤਾਂ ਦੂਜਾ ਬਿੱਲ ਨਹੀਂ ਬਣਨਾ ਚਾਹੀਦਾ।

## 1. ਸਮਝੋ ਕਿ ਸਾਰੇ ਨੋਡ ਕੰਮ ਕਿਉਂ ਸ਼ੁਰੂ ਕਰਦੇ ਹਨ

ਹਰ ਐਪਲੀਕੇਸ਼ਨ ਇੰਸਟੈਂਸ ਆਪਣਾ cron callback ਦਰਜ ਕਰਦਾ ਹੈ। ਤੈਅ ਸਮੇਂ ਉੱਤੇ ਹਰ ਇੱਕ ਸੁਤੰਤਰ ਸ਼ੁਰੂ ਹੋ ਸਕਦਾ ਹੈ:

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

ਸਥਾਨਕ isRunning ਫਲੈਗ ਸਿਰਫ਼ ਇੱਕ ਪ੍ਰਕਿਰਿਆ ਵਿੱਚ ਹੁੰਦਾ ਹੈ। NestJS ਦਾ waitForCompletion ਉਸ ਇੰਸਟੈਂਸ ਵਿੱਚ ਇਕੱਠੇ callback ਰੋਕ ਸਕਦਾ ਹੈ, ਪਰ ਹੋਰ ਨੋਡਾਂ ਦਾ ਤਾਲਮੇਲ ਨਹੀਂ ਕਰਦਾ। ਤਿੰਨਾਂ ਉੱਤੇ ਇੱਕੋ ਫਲੈਗ ਰੱਖਣ ਨਾਲ ਵੀ ਤਿੰਨ ਵੱਖਰੇ ਫ਼ੈਸਲੇ ਰਹਿੰਦੇ ਹਨ। [NestJS scheduling](https://docs.nestjs.com/techniques/task-scheduling)।

ਇਸ ਲਈ ਸਾਂਝੀ ਥਾਂ ਚਾਹੀਦੀ ਹੈ ਜੋ ਤੈਅ ਕਰੇ ਕਿ ਕਿਹੜਾ ਕੰਮ ਹੈ ਅਤੇ ਕੌਣ ਉਸ ਨੂੰ ਕਰ ਸਕਦਾ ਹੈ।

## 2. ਤਾਲਮੇਲ ਦਾ ਮਾਡਲ ਚੁਣੋ

| ਹਾਲਤ | ਪਰਖਣ ਵਾਲਾ ਵਿਕਲਪ | ਬਾਕੀ ਜ਼ਿੰਮੇਵਾਰੀ |
| --- | --- | --- |
| ਪਲੇਟਫਾਰਮ ਪਹਿਲਾਂ ਹੀ scheduled jobs ਦਿੰਦਾ ਹੈ | scheduling ਵੈੱਬ ਇੰਸਟੈਂਸਾਂ ਤੋਂ ਬਾਹਰ ਚਲਾਓ | ਇਕੱਠੇ ਚੱਲਣਾ, ਬਹਾਲੀ ਅਤੇ ਛੁੱਟੇ ਰਨ ਦਾ ਵਿਹਾਰ ਤੈਅ ਕਰੋ। |
| ਟੀਮ ਪਹਿਲਾਂ ਹੀ BullMQ ਚਲਾਉਂਦੀ ਹੈ | ਸਾਂਝਾ Job Scheduler ਅਤੇ ਖਾਸ ਕਿਊ | ਸਾਂਝੀ concurrency ਅਤੇ ਸੁਰੱਖਿਅਤ retry ਤੈਅ ਕਰੋ। |
| ਕੰਮ ਐਪਲੀਕੇਸ਼ਨ ਨੋਡਾਂ ਉੱਤੇ ਹੀ ਰਹਿਣਾ ਹੈ | ਸਾਂਝਾ lock ਜਾਂ lease | ਮਾਲਕੀ, ਮਿਆਦ ਅਤੇ ਪੁਰਾਣੇ worker ਸਹੀ ਸੰਭਾਲੋ। |

ਬਿੱਲ ਦੀ ਉਦਾਹਰਨ ਵਿੱਚ Redis ਅਤੇ BullMQ ਪਹਿਲਾਂ ਹਨ ਤਾਂ ਸਥਿਰ scheduler ID ਵਾਲਾ ਸਾਂਝਾ scheduler ਅਮਲੀ ਵਿਕਲਪ ਹੈ। schedule ਨੂੰ workers ਤੋਂ ਵੱਖ ਰੱਖੋ, ਤਾਂ ਜੋ ਵੈੱਬ ਨੋਡ ਵਧਾਉਣ ਨਾਲ ਸੁਤੰਤਰ schedule ਨਾ ਬਣਨ।

ਸਮਰਥਿਤ BullMQ ਵਰਜ਼ਨ ਵਿੱਚ ਖਾਸ ਕਿਊ ਦੀ global concurrency ਇੱਕ ਰੱਖੋ। ਇਹ ਸਾਰੇ workers ਵਿੱਚ ਸਰਗਰਮ jobs ਸੀਮਿਤ ਕਰਦਾ ਹੈ; ਹਰ worker ਦੀ local concurrency ਇੱਕ ਹੋਣ ਨਾਲ ਵੀ ਕਈ workers ਵੱਖ jobs ਇਕੱਠੇ ਚਲਾ ਸਕਦੇ ਹਨ। [Global concurrency](https://docs.bullmq.io/guide/queues/global-concurrency)।

ਜੇ ਕੱਲ੍ਹ ਦਾ ਕੰਮ ਅਜੇ ਚੱਲ ਰਿਹਾ ਹੈ ਤਾਂ ਉਡੀਕਣਾ, ਛੱਡਣਾ ਜਾਂ ਮੌਕਿਆਂ ਨੂੰ ਜੋੜਨਾ ਤੈਅ ਕਰੋ। ਸਮਾਂ ਖੇਤਰ ਅਤੇ downtime ਤੋਂ ਬਾਅਦ ਛੁੱਟੀਆਂ ਕਾਰੋਬਾਰੀ ਤਾਰੀਖਾਂ ਪੂਰੀਆਂ ਕਰਨ ਦਾ ਨਿਯਮ ਬਣਾਓ।

## 3. ਸਿਰਫ਼ ਜੌਬ ਨਹੀਂ, ਬਿੱਲ ਸੁਰੱਖਿਅਤ ਕਰੋ

ਮੰਨੋ worker ਬਿੱਲ ਬਣਾਉਂਦਾ ਹੈ ਅਤੇ ਜੌਬ ਪੂਰੀ ਹੋਈ ਦਰਜ ਕਰਨ ਤੋਂ ਪਹਿਲਾਂ ਕ੍ਰੈਸ਼ ਕਰਦਾ ਹੈ। ਬਿੱਲ ਮੌਜੂਦ ਹੋਣ ਦੇ ਬਾਵਜੂਦ ਬਹਾਲੀ ਜੌਬ ਮੁੜ ਚਲਾ ਸਕਦੀ ਹੈ।

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

ਗਾਹਕ ਅਤੇ ਬਿਲਿੰਗ ਮਿਆਦ ਵਰਗੀ ਸਥਿਰ business key ਵਰਤੋ। ਸਥਾਨਕ ਡਾਟਾਬੇਸ ਵਿੱਚ unique constraint ਅਤੇ transaction ਬਿੱਲ ਬਣਾਉਣ ਨੂੰ ਪੂਰੇ ਰਨ ਦੇ ਰਿਕਾਰਡ ਨਾਲ ਜੋੜ ਸਕਦੇ ਹਨ। Retry ਫਿਰ ਦੂਜਾ ਬਿੱਲ ਬਣਾਉਣ ਦੀ ਥਾਂ ਮੌਜੂਦਾ ਨਤੀਜਾ ਲੱਭਦਾ ਹੈ।

ਬਾਹਰੀ ਪ੍ਰਦਾਤਾ ਸਮਰਥਨ ਕਰਦਾ ਹੋਵੇ ਤਾਂ ਉਸ ਦੀ idempotency key ਵਰਤੋ ਅਤੇ ਅਨਿਸ਼ਚਿਤ ਨਤੀਜੇ ਮਿਲਾਓ। ਕਿਊ ਦੀ job ID ਜਾਂ ਸੰਭਾਲਿਆ job ਰਿਕਾਰਡ ਇਕੱਲਾ ਸਥਾਈ ਗਾਰੰਟੀ ਨਹੀਂ ਕਿ ਕਾਰੋਬਾਰੀ ਕਾਰਵਾਈ ਦੁਹਰਾਈ ਨਹੀਂ ਜਾਵੇਗੀ। [Idempotent jobs](https://docs.bullmq.io/patterns/idempotent-jobs)।

## 4. ਜਾਣੋ ਕਿ lock ਕੀ ਗਾਰੰਟੀ ਦੇ ਸਕਦਾ ਹੈ

ਸਾਂਝਾ lock ਐਟਾਮਿਕ ਢੰਗ ਨਾਲ ਲੈਣਾ ਚਾਹੀਦਾ ਹੈ। ਮਾਲਕੀ token, ਮਿਆਦ ਅਤੇ renewal ਵਰਤੋ; token ਅਜੇ ਮਿਲਦਾ ਹੋਵੇ ਤਾਂ ਹੀ ਛੱਡੋ। ਨਹੀਂ ਤਾਂ ਪੁਰਾਣਾ worker ਨਵੇਂ worker ਦਾ lock ਛੱਡ ਸਕਦਾ ਹੈ।

ਮਿਆਦ ਮੁੱਕਣ ਨਾਲ ਹੋਰ ਹਾਲਤ ਬਣਦੀ ਹੈ: ਰੁਕਿਆ worker lease ਮੁੱਕਣ ਤੋਂ ਬਾਅਦ ਮੁੜ ਚੱਲਦਾ ਹੈ, ਜਦੋਂ ਨਵਾਂ worker ਪਹਿਲਾਂ ਹੀ ਕੰਮ ਕਰ ਰਿਹਾ ਹੁੰਦਾ ਹੈ। ਮਹੱਤਵਪੂਰਨ ਲਿਖਤਾਂ ਲਈ fencing token ਲੋੜੀਂਦੇ ਹੋ ਸਕਦੇ ਹਨ—ਵਧਦੇ ਮਾਲਕੀ ਨੰਬਰ ਜਿਨ੍ਹਾਂ ਨੂੰ ਮੰਜ਼ਿਲ ਜਾਂਚ ਕੇ ਪੁਰਾਣੇ workers ਰੱਦ ਕਰਦੀ ਹੈ। ਸਿਰਫ਼ ਲੰਮਾ timeout ਇਹ ਜੋਖਮ ਨਹੀਂ ਹਟਾਉਂਦਾ।

ਤਾਲਮੇਲ ਉਪਲਬਧ ਨਾ ਹੋਵੇ ਤਾਂ ਤੈਅ ਕਰੋ ਕਿ ਕੰਮ ਮਾਲਕੀ ਬਿਨਾਂ ਚੱਲਣ ਦੀ ਥਾਂ ਉਡੀਕੇ। ਗੰਭੀਰ ਅਸਰ ਵਾਲੇ ਕੰਮ ਲਈ ਇਹ ਅਕਸਰ ਸੁਰੱਖਿਅਤ ਚੋਣ ਹੈ।

## 5. ਫੇਲ੍ਹ ਹਾਲਤਾਂ ਜਾਂਚੋ

ਕਈ ਨੋਡ, ਬਿੱਲ ਬਣਨ ਮਗਰੋਂ ਕ੍ਰੈਸ਼, lease ਤੋਂ ਲੰਮੀ ਰੋਕ, Redis ਸੰਪਰਕ ਟੁੱਟਣਾ ਅਤੇ rolling deployment ਟੈਸਟ ਕਰੋ। ਕਾਰੋਬਾਰੀ ਤਾਰੀਖ, worker, ਕੋਸ਼ਿਸ਼ ਅਤੇ ਨਤੀਜਾ ਦਰਜ ਕਰੋ, ਤਾਂ ਜੋ ਦੁਹਰਾਈ ਕੋਸ਼ਿਸ਼ ਅਤੇ ਦੁਹਰਾਇਆ ਅਸਰ ਵੱਖ ਪਤਾ ਲੱਗਣ।

**ਯਾਦ ਰੱਖੋ:** scheduling ਦਾ ਤਾਲਮੇਲ → ਸਾਂਝੀ ਕਾਰਵਾਈ ਸੀਮਿਤ → ਕਾਰੋਬਾਰੀ ਕੰਮ retry ਲਈ ਸੁਰੱਖਿਅਤ → ਬਹਾਲੀ ਟੈਸਟ। “ਇੱਕ ਸਰਗਰਮ job” ਇਕੱਲਾ ਠੀਕ ਇੱਕ ਕਾਰੋਬਾਰੀ ਅਸਰ ਦਾ ਸਬੂਤ ਨਹੀਂ।

ਹਾਲਤ	ਪਰਖਣ ਵਾਲਾ ਵਿਕਲਪ	ਬਾਕੀ ਜ਼ਿੰਮੇਵਾਰੀ
ਪਲੇਟਫਾਰਮ ਪਹਿਲਾਂ ਹੀ scheduled jobs ਦਿੰਦਾ ਹੈ	scheduling ਵੈੱਬ ਇੰਸਟੈਂਸਾਂ ਤੋਂ ਬਾਹਰ ਚਲਾਓ	ਇਕੱਠੇ ਚੱਲਣਾ, ਬਹਾਲੀ ਅਤੇ ਛੁੱਟੇ ਰਨ ਦਾ ਵਿਹਾਰ ਤੈਅ ਕਰੋ।
ਟੀਮ ਪਹਿਲਾਂ ਹੀ BullMQ ਚਲਾਉਂਦੀ ਹੈ	ਸਾਂਝਾ Job Scheduler ਅਤੇ ਖਾਸ ਕਿਊ	ਸਾਂਝੀ concurrency ਅਤੇ ਸੁਰੱਖਿਅਤ retry ਤੈਅ ਕਰੋ।
ਕੰਮ ਐਪਲੀਕੇਸ਼ਨ ਨੋਡਾਂ ਉੱਤੇ ਹੀ ਰਹਿਣਾ ਹੈ	ਸਾਂਝਾ lock ਜਾਂ lease	ਮਾਲਕੀ, ਮਿਆਦ ਅਤੇ ਪੁਰਾਣੇ worker ਸਹੀ ਸੰਭਾਲੋ।

1. ਸਮਝੋ ਕਿ ਸਾਰੇ ਨੋਡ ਕੰਮ ਕਿਉਂ ਸ਼ੁਰੂ ਕਰਦੇ ਹਨ

2. ਤਾਲਮੇਲ ਦਾ ਮਾਡਲ ਚੁਣੋ

3. ਸਿਰਫ਼ ਜੌਬ ਨਹੀਂ, ਬਿੱਲ ਸੁਰੱਖਿਅਤ ਕਰੋ

4. ਜਾਣੋ ਕਿ lock ਕੀ ਗਾਰੰਟੀ ਦੇ ਸਕਦਾ ਹੈ

5. ਫੇਲ੍ਹ ਹਾਲਤਾਂ ਜਾਂਚੋ

ਸੰਬੰਧਿਤ ਸਵਾਲ