MQTT_LexClient_index.js

const aws = require('aws-sdk');

exports.handler = async (event) => {
    if(event.type != 'req') {
        return;
    }
    const message = await lexClient(event.body, event.userId);
    await sendMqtt(message);
};


async function lexClient(message, userId) {
    const botAlias = '$LATEST';
    const botName = 'OrderFlowers';
    const sessionAttributes = {};
    
    const lexruntime = new aws.LexRuntime( {region: 'us-east-1'});
 
    const params = {
        botAlias: botAlias,
        botName: botName,
        inputText: message,
        userId: userId,
        sessionAttributes: sessionAttributes
    };
 
    const data = await lexruntime.postText(params).promise();
    console.log(JSON.stringify(data));
    return data.message;
}

async function sendMqtt(message) {

    const endpoint = 'xxxxxxxxxxxx-ats.iot.ap-northeast-1.amazonaws.com';
    const topic = "Sample_Topic"
    const region = 'ap-northeast-1';
    
    var iotdata = new aws.IotData({
        endpoint: endpoint,
        region: region
    });

    const param = {
        type: 'res',
        body: message
    }

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

    let result = await iotdata.publish(iotParams).promise();
}