Consumer

Bull consumer/process ile iş işleme öğrenirsin.

Consumer

Consumer, kuyruktan mesaj alıp işleyen taraftır. Bull'da queue.process((job) => { ... }) ile consumer tanımlarsın. Her mesaj için callback çağrılır; callback Promise döndürürse Bull iş bitmesini bekler.

Örnek: kuyruk.process((job) => { console.log("İşleniyor: " + job.data.aksiyon); return Promise.resolve(); });. Mesaj kuyruktan alınınca job parametresi ile callback çağrılır. job.data mesajın verisidir. Callback bir Promise döndürürse; resolve iş başarılı, reject iş başarısız demektir. Başarısız işler retry yöntemine göre tekrar denenir. Birden çok consumer kuyruğu paralel işleyebilir.

job.data ve Promise

Consumer callback'i job parametresi alır. job.data mesajın verisidir. Callback bir Promise döndürmeli; resolve başarılı, reject başarısız demektir.

Örnek: kuyruk.process(async (job) => { const kullanici = job.data.kullanici; await sendMail(kullanici); });. async fonksiyon otomatik Promise döndürür; bu yüzden return'e gerek yok. sendMail başarılı olursa iş tamamlanır, hata atarsa Bull işi başarısız sayar ve retry yöntemini uygular. job.attemptsMade kaç kez denendiğini verir. Bull { concurrency: 5 } ile paralelliği sınırlar.

Uygulama Consumer tanımla

Aşağıdaki kuyruk nesnesini kullan. kuyruk.process(async (job) => { console.log("İş: " + job.data.aksiyon); }) ile consumer tanımla. console.log ile "Consumer hazır" yaz.

Örnek çözümü göster

const Bull = require("bull");
const kuyruk = new Bull("is-kuyrugu");
kuyruk.process(async (job) => {
  console.log("İş: " + job.data.aksiyon);
});
console.log("Consumer hazır");

Kendini test et

queue.process ne yapar?
```
kuyruk.process((job) => { ... })
```
- Mesajı kuyruğa ekler
- Mesajları alıp işler
- Redis'i kapatır
- Yeni kuyruk oluşturur
Cevabı göster

Mesajları alıp işler — queue.process mesajları alıp işler.

job.data erişimini tamamla

const kullanici = job.____.kullanici;

Cevabı göster

const kullanici = job.data.kullanici;

Parçayı rolüne eşle

queue.process

Consumer tanımlar
job.data

Mesajın verisi
Promise resolve

İş başarılı
Promise reject

İş başarısız

Sıradaki ders: Retry ve backoff

Deneyiminizi Geliştiriyoruz

Çerez Tercihleri

Kesinlikle Gerekli Çerezler

Analitik Çerezler