რა უპირატესობები და ნაკლოვანებები აქვს BullMQ-ს და როდის გამოვიყენოთ?

Question

IT Interview Practice · Accepted Answer

BullMQ არის Redis-ზე დაფუძნებული დავალებების რიგი Node.js-ისთვის. შესაბამისობის შესაფასებლად დაიწყეთ **სამუშაოთი, რომელიც HTTP პასუხის შემდეგ შეიძლება დასრულდეს და თვალყურის დევნება ან გამეორება სჭირდება**.

განვიხილოთ დიდი ანგარიში. მოთხოვნის შიგნით შექმნამ მომხმარებელი timeout-მდე შეიძლება ალოდინოს. რიგით აპლიკაცია სამუშაოს იღებს, მის ID-ს აბრუნებს და ცალკე ამუშავებს.

## 1. ნახეთ, რა იცვლება სამუშაოს რიგში გადატანით

```text
[User] -> [API: submit job] -> [Redis / BullMQ] -> [Worker]
                |                                   |
          [Return job ID]                       [Saved report]
```

გამგზავნი დავალებას ამატებს; მუშაკი ასრულებს. მომხმარებელი პროგრესს ამოწმებს და მზადყოფნის შემდეგ შენახულ ანგარიშს ჩამოტვირთავს.

ანგარიშის დამუშავებას დრო კვლავ სჭირდება. გაუმჯობესება ისაა, რომ სამუშაოს სიცოცხლე ერთი გახსნილი HTTP მოთხოვნის შენარჩუნებაზე აღარ არის დამოკიდებული და მუშაკები API სერვერებისგან ცალკე იმართება.

## 2. სარგებელი მოთხოვნებს დაუკავშირეთ

| საჭიროება | BullMQ-ის შესაძლებლობა | აპლიკაციის გადასაწყვეტი |
| --- | --- | --- |
| დროებითი მარცხის შემდეგ აღდგენა | განმეორება მზარდი დაყოვნებით | რომელი შეცდომა განმეორდეს და როდის შეწყდეს. |
| მოგვიანებით ან გრაფიკით გაშვება | გადადებული დავალებები და დაგეგმვა | დროის მოთხოვნა და გათიშვის შემდგომი ქცევა. |
| დამუშავების დატვირთვის კონტროლი | კონკურენტულობისა და სიხშირის ზღვარი | ბაზისა და გარე სერვისების უსაფრთხო ლიმიტები. |
| ფონური სიმძლავრის გაზრდა | დამატებითი მუშაკები | გაუძლებს თუ არა შემდეგი დამოკიდებულება დამატებით დატვირთვას. |

ანგარიშისთვის ეს ფუნქციები მდგომარეობებისა და განმეორების მექანიზმის თავიდან აგებას აგაცილებთ. ისინი პროგრესისა და მარცხის კვლევისთვის ინფორმაციასაც იძლევა. დამატებითი მუშაკები მხოლოდ მაშინ ეხმარება, როცა დასრულებას აჩქარებს დამოკიდებულებების გადატვირთვის გარეშე.

## 3. გაიგეთ სისწორის მთავარი პასუხისმგებლობა

მუშაკმა ანგარიში შეიძლება შეინახოს და დასრულების მონიშვნამდე გაითიშოს. განმეორებამ სამუშაო ხელახლა შეასრულოს. იგივე შემთხვევა თანხის ჩამოჭრის ან შეტყობინების გაგზავნისას უფრო სერიოზულია.

მოთხოვნილ სამუშაოს სტაბილური ბიზნესიდენტობა მიეცით. მისი განმეორება არსებულ შედეგს უნდა იყენებდეს ან უსაფრთხოდ ცვლიდეს, დამატებითი ბიზნესეფექტის ნაცვლად. ეს იდემპოტენტურობაა. გარე ეფექტებისთვის გამოიყენეთ პროვაიდერის მხარდაჭერა, თუ არსებობს, და გაურკვეველი შედეგები შეაჯერეთ. [იდემპოტენტური დავალებები](https://docs.bullmq.io/patterns/idempotent-jobs).

თუ ბაზაში ჩანაწერის შენახვამ დავალებაც უნდა შექმნას, გაითვალისწინეთ ჩაწერებს შორის შუალედი. Outbox ინსტრუქციას ბიზნესჩანაწერთან იმავე ტრანზაქციაში ინახავს; გამომქვეყნებელი შემდეგ რიგში აგზავნის. მიწოდება შეიძლება განმეორდეს, ამიტომ მუშაკს იდემპოტენტურობა მაინც სჭირდება.

## 4. ხარჯში Redis-ისა და მუშაკების ოპერირებაც ჩართეთ

Redis მოლოდინში მყოფ სამუშაოს ინახავს, ამიტომ მნიშვნელოვანია მუდმივი შენახვა, მეხსიერების პოლიტიკა და აღდგენა. რიგისთვის noeviction დააყენეთ: მეხსიერების გასათავისუფლებლად გასაღებების ჩუმად წაშლა აუცილებელი დავალებებისთვის შეუფერებელია. გამოცადეთ აღდგენა; აპლიკაციის გადატვირთვის უსაფრთხოება Redis-ის ყველა მარცხს არ ფარავს. [საწარმოო გარემოს მითითებები](https://docs.bullmq.io/guide/going-to-production).

დიდი ანგარიშის ფაილები შესაბამის საცავში მოათავსეთ, დავალებებში კი მითითებები გადასცეთ. განსაზღვრეთ დასრულებული და ჩავარდნილი დავალებების შენახვის ვადა, რათა Redis-ის გამოყენება კონტროლდებოდეს.

მძიმე CPU დამუშავებამ მუშაკის event loop შეიძლება დაბლოკოს და lock-ის განახლებას ხელი შეუშალოს. დავალება გაჩერებულად ჩაითვლება და ხელახლა დამუშავდება. გამოიყენეთ შესაბამისი worker thread ან იზოლირებული პროცესორი და გაჩერებული დავალებები აკონტროლეთ. [გაჩერებული დავალებები](https://docs.bullmq.io/guide/jobs/stalled).

## 5. რეკომენდაცია პირობებს მოარგეთ

- აირჩიეთ BullMQ, როცა Node.js აპლიკაციას დაკვირვებადი ფონური სამუშაო, განმეორება და ცალკე გასაზრდელი მუშაკები სჭირდება, ხოლო გუნდს Redis-ის საიმედოდ მართვა შეუძლია.
- მარტივი ლოკალური მოქმედება მარტივად დატოვეთ, თუ გამძლე აღრიცხვა და დამოუკიდებელი შესრულება არ სჭირდება.
- შეაფასეთ გამძლე მოვლენების ჟურნალი, თუ მთავარი მოთხოვნა რამდენიმე დამოუკიდებელი მომხმარებლის ხანგრძლივი განმეორებითი წაკითხვაა და არა რიგის დავალებების დასრულება.

ანგარიშის მაგალითში გამოცადეთ დამოკიდებულების მარცხი, მუშაკის ავარია შედეგის შენახვის შემდეგ და გათიშვის შემდგომი აღდგენა. დარწმუნდით, რომ მომხმარებელი სანდო სტატუსს ხედავს და განმეორება ურთიერთსაწინააღმდეგო შედეგებს არ ქმნის.

**დაიმახსოვრეთ:** BullMQ დავალებებს კოორდინაციას უწევს. ბიზნესსისწორეს აპლიკაცია უზრუნველყოფს, რიგის ოპერირება კი გუნდის პასუხისმგებლობად რჩება.

საჭიროება	BullMQ-ის შესაძლებლობა	აპლიკაციის გადასაწყვეტი
დროებითი მარცხის შემდეგ აღდგენა	განმეორება მზარდი დაყოვნებით	რომელი შეცდომა განმეორდეს და როდის შეწყდეს.
მოგვიანებით ან გრაფიკით გაშვება	გადადებული დავალებები და დაგეგმვა	დროის მოთხოვნა და გათიშვის შემდგომი ქცევა.
დამუშავების დატვირთვის კონტროლი	კონკურენტულობისა და სიხშირის ზღვარი	ბაზისა და გარე სერვისების უსაფრთხო ლიმიტები.
ფონური სიმძლავრის გაზრდა	დამატებითი მუშაკები	გაუძლებს თუ არა შემდეგი დამოკიდებულება დამატებით დატვირთვას.

1. ნახეთ, რა იცვლება სამუშაოს რიგში გადატანით

2. სარგებელი მოთხოვნებს დაუკავშირეთ

3. გაიგეთ სისწორის მთავარი პასუხისმგებლობა

4. ხარჯში Redis-ისა და მუშაკების ოპერირებაც ჩართეთ

5. რეკომენდაცია პირობებს მოარგეთ

დაკავშირებული კითხვები