Czy można zaktualizować już utworzone zadanie w węźle kue js

Question

Witam Tworzę zadania przy użyciu Kue.

jobs.create('myQueue', { 'title':'test', 'job_id': id ,'params': params }) 
      .delay(milliseconds) 
      .removeOnComplete(true) 
      .save(function(err) { 
       if (err) { 
        console.log('jobs.create.err', err); 
       } 

     }); 

każde zadanie ma opóźnienie, zwykle wynosi 3 godziny.

Teraz sprawdzę każde przychodzące żądanie, które chce utworzyć nowe zlecenie i uzyskać identyfikator.

Jak widać z powyższego kodu, podczas tworzenia zadania dodaję identyfikator zadania do pracy.

więc teraz chcę sprawdzić id przychodzący z istniejącymi zadaniami job_id w kolejce i zaktualizować istniejące zadanie o nowe parametry, jeśli znaleziono pasujący identyfikator .

więc moja kolejka zadań będzie miała unikalny job_id za każdym razem :).

czy to możliwe? , Dużo szukałem, ale nie znalazłem pomocy, sprawdziłem kue json API. ale może tylko tworzyć i otrzymywać zadania pobierania, nie może aktualizować istniejących rekordów.

Z góry dziękuję.

Answer 1

Nie jest to wspomniane w dokumentacji i przykładach, ale istnieje metoda update dla job.

można aktualizować swoje zadania przez job_id ten sposób:

// you have the job_id 
var job_id_to_update = 1; 
// get delayed jobs 
jobs.delayed(function(err, ids) { 
    ids.forEach(function(id) { 
    kue.Job.get(id, function(err, job) { 
     // check if this is job we want 
     if (job.data.job_id === job_id_to_update) { 
      // change job properties 
      job.data.title = 'set another title'; 
      // save changes 
      job.update(); 
     } 
    }); 
    }); 
}); 

Pełne przykładem jest here.

Aktualizacja: można także rozważyć użycie "natywnego" ID zadania, znanego z kue. można uzyskać identyfikator zadania podczas tworzenia zadania:

var myjob = jobs.create('myQueue', ... 
    .save(function(err) { 
     if (err) { 
      console.log('jobs.create.err', err); 
     } 
     var job_id = myjob.id; 
     // you can send job_id back to the client 
}); 

Teraz można bezpośrednio modyfikować pracę bez pętli na liście:

kue.Job.get(id, function(err, job) { 
    // change job properties 
    job.data.title = 'set another title'; 
    // save changes 
    job.update(); 
}); 

Answer 2

Chciałem odpowiedzieć aktualizacji. Ten bilet https://github.com/Automattic/kue/issues/505 ma odpowiedź na moje pytanie.