SQS Publisher

1'use strict';
2
3exports.handler = (event, context, callback) => {
4  const AWS = require('aws-sdk');
5  const SQS = new AWS.SQS({ apiVersion: '2012-11-05' });
6
7  const SQSParams = {
8    QueueUrl: 'https://sqs.us-east-1.amazonaws.com/xxxxx/yyyyyy',
9    MessageBody: ''
10  };
11
12  const sendMessageToSQS = (message) => {
13    SQSParams.MessageBody = JSON.stringify(message);
14    SQS.sendMessage(SQSParams, () => { });
15  }
16
17  const message = { timestamp: new Date() };
18  sendMessageToSQS(message);
19};
20
21callback(null, { result: 'ok' });