如何订阅 Amazon AWS Lambda 函数中的 MQTT 主题?
How can I subscribe to a MQTT topic in a Amazon AWS Lambda function?
我正在使用 python,我可以使用以下代码向 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"})
)
但是没有像
这样的方法
client.subscribe();
因为它作为配置工作。查看文档:https://docs.aws.amazon.com/iot/latest/developerguide/iot-lambda-rule.html
如果您想订阅所有主题而不需要执行任何其他操作,只需转到物联网规则部分并调用您的 lambda 函数并打印您的 json 字符串,如下所示:
def lambda_handler(event,context):
print(event)
我正在使用 python,我可以使用以下代码向 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"})
)
但是没有像
这样的方法client.subscribe();
因为它作为配置工作。查看文档:https://docs.aws.amazon.com/iot/latest/developerguide/iot-lambda-rule.html
如果您想订阅所有主题而不需要执行任何其他操作,只需转到物联网规则部分并调用您的 lambda 函数并打印您的 json 字符串,如下所示:
def lambda_handler(event,context):
print(event)