Lambda Function to Connect to AWS IoT and Publish MQTT Messages

[nbibin001]

Hi I was trying to develop a lambda function which will connect to the AWS thing and publish an MQTT message, I want to receive these published messages on a raspberry Pi which is connected to the thing as well, and subscribed to the same topic. I managed to create the thing, certificate and connect to it. But the lambda function seems to not send the MQTT message. I am attaching my sample code here in the index.js. I kept all my certificates and keys in a folder and zipped and uploaded. Since I am testing this lambda function now, I am not using the event to trigger the connection and message publishing, I just did it like whenever the function is called , it will connect and publish the message. The function seems to be running without error, but I dont see any message coming to my Pi when this runs, (I have a python code running at the Pi side which is subscribed to the same topics, and it is connected to AWS as well).
Below is the lambda code I am using, could anyone please help me if I am missing something here ?

var awsIot = require('aws-iot-device-sdk');
var deviceName = "Bibin_Pi_3"; // Updated by Bibin from AWS IOT Thing name

var thingShadows = awsIot.thingShadow({
keyPath: './private.pem.key',
certPath: './certificate.pem.crt',
caPath: './rootCA.pem',
clientId: deviceName,
region: "eu-east-1",
});

var ctx = null;

exports.handler = function (event, context) {
ctx = context;

thingShadows.on('connect', function() {
		thingShadows.register(deviceName);
		console.log("Connected...");
        console.log("Registering...");

	});
	
	thingShadows.on('message', function(topic, payload) {
        console.log('message', topic, payload.toString());
    });

thingShadows.publish('qrio/test/pi/voice', 'BedroomLightOn', function(){
		var cardTitle = "Bedroom Lamp on";
		var repromptText = "";
		var sessionAttributes = {};
		var shouldEndSession = false;
		var speechOutput = "Your bedroom light is on. ";
		repromptText = "Your bedroom light is on. ";
		var shouldEndSession = false;
		
	});
	console.log('value1 =', 'Bibin');
	ctx.succeed();

};

[JAPDD]

Hi i just took the reference of internet and wants to send the MQTT message to AWS IOT through a lambda function .
I did in following manner

Step 1. index.js

var awsIot = require('aws-iot-device-sdk');

var device = awsIot.device({
keyPath: 'XXXX.private.key',
certPath: 'XXXX.cert.pem',
caPath: 'root-CA.crt',
clientId: 'XXXX',
host: 'XXXXXspv.iot.ap-northeast-1.amazonaws.com'
});

device
.on('connect', function () {
console.log('connect');
device.subscribe('dd_receive_topic_1');
device.publish('dd_send_topic_2', JSON.stringify({ test_data: 'HELLO '}));
console.log('Message send Success.....');
});

device
.on('message', function (topic, payload) {
console.log('message', topic, payload.toString());
});

Step 2
Along with the index.js , async,gm and aws-iot-device-sdk.---->created a zip file

Step 3:
Load the zip file on lambda and test run..

I got the following error
{
"errorMessage": "Invalid "keyPath" option supplied.",
"errorType": "Error",
"stackTrace": [
"new DeviceClient (/var/task/index/node_modules/aws-iot-device-sdk/device/index.js:416:7)",
"Object.DeviceClient [as device] (/var/task/index/node_modules/aws-iot-device-sdk/device/index.js:201:14)",
"Object. (/var/task/index/index.js:3:21)",
"Module._compile (module.js:570:32)",
"Object.Module._extensions..js (module.js:579:10)",
"Module.load (module.js:487:32)",
"tryModuleLoad (module.js:446:12)",
"Function.Module._load (module.js:438:3)",
"Module.require (module.js:497:17)"
]
}

But with the same code if i would to send from my local PC to AWS IOT ..it works fine ...can you plz guide me .

[nelsonic]

@nbibin001 have you seen: https://github.com/dwyl/aws-lambda-iot-chat ?

[soundarsurya]

when i do test my lambda function.....
i get this error
"errorMessage": "Invalid connect options supplied.",
"errorType": "Error",
"stackTrace": [
"Object.Module._extensions..js (module.js:579:10)",
"Module.load (module.js:487:32)",
"tryModuleLoad (module.js:446:12)",
"Function.Module._load (module.js:438:3)"

what it mean? where do i fix this..?? and how
help me to fix this
i have almost complete