Ist es möglich, einen bereits erstellten Job in einem Knoten zu aktualisieren? Js

Question

Hallo, ich erstelle Jobs mit Kue.

Jeder Job hat eine Verzögerungszeit, normalerweise sind es 3 Stunden.

Jetzt werde ich jede eingehende Anfrage überprüfen, die einen neuen Job erstellen und die ID erhalten möchte.

Wie Sie aus dem obigen Code sehen können, wenn ich Job erstellen werde ich die Job-ID zum Job hinzufügen.

jetzt möchte ich die eingehende ID mit den Job-IDs der vorhandenen Jobs in der Warteschlange überprüfen und den vorhandenen Job mit den neuen Parametern aktualisieren, wenn eine übereinstimmende ID gefunden wird.

so dass meine Jobwarteschlange jedes Mal eine eindeutige job_id hat :).

ist es möglich? Ich habe viel gesucht, aber keine Hilfe gefunden, ich habe die Ku json API überprüft. Es kann jedoch nur Jobs erstellen und abrufen, vorhandene Datensätze nicht aktualisieren.

Vielen Dank im Voraus.

Answer 1

Dies ist nicht in der Dokumentation und Beispielen erwähnt, aber es gibt eine update Methode für eine job.

// 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(); 
     } 
    }); 
    }); 
}); 

Das vollständige Beispiel here ist:

Sie können Ihre Aufträge von job_id auf diese Weise aktualisieren.

Update: Sie können auch die "native" Job-ID verwenden, die für kue bekannt ist. Sie können die Job-ID erhalten, wenn Sie den Auftrag erstellen:

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 
}); 

Jetzt können Sie direkt den Auftrag ändern, ohne über die Liste Looping:

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

Answer 2

Ich wollte nur ein Update veröffentlichen. Dieses Ticket https://github.com/Automattic/kue/issues/505 hat die Antwort auf meine Frage.