如何在Amazon AWS Lambda函数中发布到MQTT主题？

Question

我希望有一个简单的命令，就像我在bash中使用的一样，在AWS Lambda函数中发布一些内容到MQTT上的主题。按照：mosquitto_pub-h my.server.com-t“light/set”-m“on”

背景：我想和Alexa一起打开和关闭一盏灯。Alexa可以启动一个Lambda函数，在这个Lambda函数中，我想启动一个MQTT发布，因为lamp可以侦听MQTT主题并对那里的消息做出反应。（可能有更简单的解决方案，但我们处于一个复杂的（大学）网络中，这使得许多其他方法更加困难）

Answer 1

如果您使用的是Node.js，这将起作用-

var AWS = require('aws-sdk');
var iotdata = new AWS.IotData({ endpoint: '*****************.iot.us-east-1.amazonaws.com' });

exports.handler = async(event) => {
    console.log("Event => " + JSON.stringify(event));
    var params = {
        topic: "MyTopic",
        payload: JSON.stringify(event),
        qos: 0
    };

    return iotdata.publish(params, function(err, data) {
        if (err) {
            console.log("ERROR => " + JSON.stringify(err));
        }
        else {
            console.log("Success");
        }
    }).promise();
};

记住要添加iot：对这个lambda函数使用的角色的发布权限。

Answer 2

AWS SDK有两个类来处理物联网：物联网和物联网数据。IotData.publish是您正在寻找的方法。看起来Iot对象用于处理事物，IotData用于处理MQTT和阴影。这应该在关于MQTT和shadows的文档中直接引用，但事实并非如此。

此服务（IotData）也可在CLI中使用。

Answer 3

如果您正在使用Python，我可以使用下面的处理程序函数获得AWS Lambda函数来向AWS IoT发布消息：

import boto3
import json

client = boto3.client('iot-data', region_name='us-east-1')

# Change topic, qos and payload
response = client.publish(
        topic='$aws/things/pi/shadow/update',
        qos=1,
        payload=json.dumps({"foo":"bar"})
    )

您还需要确保角色（在Lambda功能配置中）附加了允许访问IoT发布功能的策略。在我的领导下-

{
   "Version": "2016-6-25",
   "Statement": [
    {
        "Effect": "Allow",
        "Action": [
            "iot:Publish"
        ],
        "Resource": [
            "*"
        ]
    }
   ]
}