Dans bull
Il n'est pas possible de répéter le même travail immédiatement après son échec avant de prendre le travail suivant dans la file d'attente.
Solution :
- Créer une nouvelle tâche et définir sa priorité sur une valeur inférieure au type de tâche actuel.
- Lancer la tâche ayant échoué (
resolve()
oudone()
) - Ce nouveau travail sera repris immédiatement par le
bull
pour traitement.
Exemple de code :dans le code ci-dessous Job-3 échouera et créera un nouveau travail et ainsi de suite jusqu'à ce que "l'objectif du travail" réussisse à un moment donné.
var Queue = require('bull');
let redisOptions = {
redis: { port: 6379, host: '127.0.0.1' }
}
var myQueue = new Queue('Linear-Queue', redisOptions);
myQueue.process('Type-1', function (job, done) {
console.log(`Processing Job-${job.id} Attempt: ${job.attemptsMade}`);
downloadFile(job, async function (error) {
if (error) {
await repeatSameJob(job, done);
} else {
done();
}
});
});
async function repeatSameJob(job, done) {
let newJob = await myQueue.add('Type-1', job.data, { ...{ priority: 1 }, ...job.opts });
console.log(`Job-${job.id} failed. Creating new Job-${newJob.id} with highest priority for same data.`);
done(true);
}
function downloadFile(job, done) {
setTimeout(async () => {
done(job.data.error)
}, job.data.time);
}
myQueue.on('completed', function (job, result) {
console.log("Completed: Job-" + job.id);
});
myQueue.on('failed', async function (job, error) {
console.log("Failed: Job-" + job.id);
});
let options = {
removeOnComplete: true, // removes job from queue on success
removeOnFail: true // removes job from queue on failure
}
for (let i = 1; i <= 5; i++) {
let error = false;
if (i == 3) { error = true; }
setTimeout(i => {
let jobData = {
time: i * 2000,
error: error,
description: `Job-${i}`
}
myQueue.add('Type-1', jobData, options);
}, i * 2000, i);
}
Sortie :