producer for clickstream tracker

producer.js

var QUEUE_URL = '<url>/clickstreamQueueDev';
var AWS = require('aws-sdk');
var sqs = new AWS.SQS({region : 'ap-northeast-1'});

exports.handler = function(event, context, callback) {
    var params = {
        MessageBody: event.body,
        QueueUrl: QUEUE_URL
    };
    
    sqs.sendMessage(params, function(err, data){
        if(err) {
          console.log('error:',"Fail Send Message" + err);
          callback(null, { statusCode: 400, body: '{"message":"Failed to queue the message!"}' });
        }else{
          console.log('data:',data.MessageId);
          callback(null, { statusCode: 200, body: '{"message":"Success!"}' });
        }
    });
     
    // console.log(event.body);
    // callback(null, { statusCode: 200, body: '{"message":"Success!"}' });
};