job-sceduler
Installation
npm install @lordmelique/job-scheduler
const {Scheduler, Consumer} = require('job-scheduler')Scheduler
First of all we need to declare scheduler and give the job names which will be scheduled by this scheduler.
const scheduler = new Scheduler({
redis: {
port: 6378,
},
enqueueMaxTries: 5,
retryInterval: 10,
types: ['myjob'],
});Then we need to add consumer that will consume AWS SQS queue and fire events.
const consumer = new Consumer({
jobName: 'myjob',
sqsUrl: 'https://sqs.<REGION>.amazonaws.com/<ACCOUNT_ID>',
message: function handleMessage(message) {
console.log(message.Body)
},
error: function handleError(err) {
console.log(err);
},
processingError: function handleProcessingError(err) {
console.log(err);
},
})Now we are ready to schedule jobs with scheduler. Lets generate jobs with random Ids and TTLs
(async function() {
await sch.wait(5);
try {
for (let i = 0; i < 10; i++) {
await sch.scheduleEvent({
type: 'myjob',
id: parseInt(Math.random() * 200),
ttl: parseInt(Math.random() * 10) + 5,
});
}
} catch (e) {
console.log(e);
}
})();