hitfox/sqs-pipeline-lambdas-node-sink repository overview

 docker pull julianbei/data-pipeline-lambdas-sink

var Promise = require('bluebird');

var config = {
 RECEIVE_TOPIC     : process.env.RECEIVE_TOPIC,
 QUEUE_URL         : process.env.SQS_URL,
 AWS_ACCESS_KEY    : process.env.AWS_ACCESS_KEY,
 AWS_ACCESS_SECRET : process.env.AWS_ACCESS_SECRET,
 AWS_REGION        : process.env.AWS_REGION
};
module.exports.config = config;

var processor = function(message){
  return new Promise(function(resolve, reject) {
    // Processing logic goes here for example add fields to message objects:
    message.active = true;
    // after processing just resolve the final object
    resolve(message);
  });
};
module.exports.processor = processor;

var callback = function(result){
  // do something with the processing result
  console.log('processing result: '+result);
};
module.exports.callback = callback;

FROM julianbei/data-pipeline-lambdas-sink

RUN mkdir -p /app/lambda

# Copy the main application.
COPY . ./app/lambda

WORKDIR /app

FROM julianbei/data-pipeline-lambdas-sink

RUN mkdir -p /app/lambda

COPY ./package.json /app/package.json
WORKDIR /app
RUN npm install

# Copy the main application.
COPY . ./app/lambda/

sink-lambda:
  build: sink-lambda/.
  command: forever -m 5 /app/index.js
  environment:
    - RECEIVE_TOPIC=
    - SQS_URL=
    - AWS_ACCESS_KEY=
    - AWS_ACCESS_SECRET=
    - AWS_REGION=

volumes:
  - ./sink-lambda:/app/lambda/