aws lambda iot

gistfile1.txt

//import and prepare iot for pubsub
const IotData = require("aws-sdk/clients/iotdata");
let iotData;

export default function getIotData() {
  if (iotData) {
    return iotData;
  } else {
    iotData = new IotData({
      endpoint: process.env["AWS_IOT_ENDPOINT"],
      region: process.env["AWS_IOT_REGION"]
    });

    return iotData;
  }
}
And then publish like so:

import getIotData from "./getIotData";

export default async function publishDataObjToChannel(channelName, payload) {
  const iotData = getIotData();
  const topic = channelName;

  const iotParams = {
    payload: JSON.stringify(payload),
    topic,
    qos: 0
  };

  return await iotData.publish(iotParams).promise();
}

https://github.com/aws-amplify/amplify-js/issues/1638