a labda function that subscribes to an sns queue and pushes data to an mqtt queue

sns-mqtt-lambda

index.js

'use strict';

let publishTopic = require("./publishTopic");

exports.handler = (event, context, callback) => {
  console.log('topic:', event.topic);
  console.log('action:', event.action);

  var topic = "***YOUR TOPIC***" + event.topic;
  var action = event.action;
  publishTopic([topic, action]);
  //callback(null, "action: " + actionApi + " published to: " + topic);
  callback(null, "{'status':'ok'}");
};

publishTopic.js

"use strict"

var mqtt    = require('mqtt');

module.exports = (req, done) => {
  var client  = mqtt.connect("***YOUR ENDPOINT***")

  client.on('connect', () => {
    console.log("Connected");
    console.log(req[0]);
    console.log(req[1]);

    client.publish(req[0],req[1]);
    client.end();
    console.log("published");
    //req.result = "Successfully";

  });
};