AWS - SQS Scheduler

A tiny helper to manage scheduled lambda function and sqs + lambda using BBC`s sqs-consumer.

Installation

npm install aws-sqs-schedule

Usage

sqs_scheculer.init(opt)

Launch the scheduler and sqs queue consumers.

• opt (Object) options.

• opt.aws (Object) aws region, accessKeyId and secretAccessKey.

• opt.consumers[] (Array) List of consumers.

  • id (String) internal identifier to be used in logs
  • queueUrl (String) sqs url
  • batchSize (Number) size batch max = 10
  • functionName (String) aws lambda function name
  • waitTimeSeconds (String) time to wait

• opt.schedules[] (Array) List of event`s schedules.

  • id (String) internal idetifier to be used in logs
  • cron (String) cron, ex: */2 * * * 1-5,
  • functionName (String) event name,
  • Payload (String) lambda event payload

• opt.cb (Function) function thats is called in every aws lambda invoke, with {id, FunctionName, InvocationType, Payload}

example:

var sqs_scheculer = require('./aws_sqs_scheduler');
 
sqs_scheculer.init({
    aws: {
        region: 'us-east-1',
        accessKeyId: '12312312313123',
        secretAccessKey: '312321312321312321312313131'
    },
    consumers: [{
        id: 'update_transactions',
        queueUrl: 'https://sqs.us-east-1.amazonaws.com/111111/transactions',
        batchSize: '1',
        functionName: 'update-transaction'
    }],
    schedules: [{
        id: 'list_user',
        cron: '*/2 * * * 1-5',
        functionName: 'queue_users',
        Payload: ''
    }],
    cb: (event) => {
        // event.id
        // event.FunctionName
        // event.InvocationType
        // event.Payload
        console.log(event);
    }
});

Debug mode

DEBUG=info,error node index
```

------
Very useful [cron helper ](http://crontab.guru/)