Sqs-router NPM

sqs-router

SQS reader with simple router by type

SQS Message Format

{
   "type": "TYPE_1",
   "content": { /* your message */ }
}

Usage

  const sqsWorkerFactory = require('sqs-worker').workerFactory;

  const sqsWorker = new sqsWorkerFactory.create('/tmp/controllers', 'https://sqs.us-east-1.amazonaws.com/123123/my-queue', options);
  sqsWorker.on('error', console.error);
  (await sqsWorker.init()).start();

 |-- tmp
 |---- controllers
 |-------- myController.js

myController.js

const Joi = require('joi');
const BaseController = require('sqs-worker').BaseController;

class myController extends BaseController {
    constructor() {
        super();
    }

    get type() {
        return 'TYPE_1';
    }
    
    get messageContentSchema() {
        // Joi schema for message.content (https://github.com/hapijs/joi)
        // schema example: 
        return Joi.object({
            age: Joi.number().required()
        }).required();
    }

    async initDefaults() {
        return this;
    }
    
    async handleMessage(messageContent) {
        // your handling code
    }
}

module.exports = myController;

Configuration

options

aws
- credentials
  - region: (default from env AWS_REGION)
  - accessKeyId: (default from env AWS_ACCESS_KEY_ID)
  - secretAccessKey: (default from env AWS_SECRET_ACCESS_KEY)
- batchSize: Size of batch (default 10)