教程：使用设备 AWS IoT Core 将 AWS IoT 设备连接到 SDK

1. 在开始练习之前，请尝试根据 AWS IoT Core 教程入门教程在您的设备上运行此命令，确保一切都准备就绪，可正常进行练习。

   cd ~/aws-iot-device-sdk-python-v2/samples
   python3 pubsub.py --topic topic_1 --ca_file ~/certs/Amazon-root-CA-1.pem --cert ~/certs/device.pem.crt --key ~/certs/private.pem.key --endpoint your-iot-endpoint
   

   您看到的输出应该与您在入门教程看到的一样。

2. 在本练习中，请更改这些命令行参数。

   操作	命令行参数	效果
   添加	--message ""	配置 pubsub.py以仅侦听
   添加	--count 2	收到两条消息后结束程序
   更改	--topic device/+/details	设定要订阅的主题筛选条件

   对初始命令行进行这些更改将得到此命令行。在设备的终端窗口中输入此命令。

   python3 pubsub.py --message "" --count 2 --topic device/+/details --ca_file ~/certs/Amazon-root-CA-1.pem --cert ~/certs/device.pem.crt --key ~/certs/private.pem.key --endpoint your-iot-endpoint
   

   程序应该类似如下所示：

   Connecting to a3qexamplesffp-ats.iot.us-west-2.amazonaws.com with client ID 'test-24d7cdcc-cc01-458c-8488-2d05849691e1'...
   Connected!
   Subscribing to topic 'device/+/details'...
   Subscribed with QoS.AT_LEAST_ONCE
   Waiting for all messages to be received...
   

   如果您在终端上看到类似的内容，则表示您的设备已准备就绪，并侦听主题名称以 device开始并以结束 /detail的消息。所以，让我们来测试吧。

3. 以下是您的设备可能会收到的几条消息。

   主题名称	消息负载
   device/temp/details	{ "desiredTemp": 20, "currentTemp": 15 }
   device/light/details	{ "desiredLight": 100, "currentLight": 50 }

4. 使用 AWS IoT 控制台中的MQTT测试客户端，将上一步中所述的消息发送到您的设备。

   1. 在 AWS IoT 控制台中打开MQTT测试客户端。

   2. 在 Subscribe to topic（订阅主题）中，在 Subscription topic field（订阅主题字段）输入主题筛选条件：device/+/details，然后选择 Subscribe to topic（订阅主题）。

   3. 在MQTT测试客户端的 “订阅” 列中，选择设备/+/详细信息。

   4. 对于上表中的每个主题，请在MQTT测试客户端中执行以下操作：

      1. 在 Publish（发布）中，在表中输入 Topic name（主题名称）列的值。

      2. 在主题名称下方的消息负载字段中，在表中输入 Message payload（消息负载）列的值。

      3. 查看pubsub.py正在运行的终端窗口，然后在MQTT测试客户端中选择 “发布到主题”。

      您应该看到该消息是由终端窗口中的 pubsub.py接收的。

评估消息主题

1. 将 pubsub.py复制到 pubsub2.py。

2. pubsub2.py在您最喜欢的文本编辑器中打开或IDE.

3. 在 pubsub2.py中，查找 on_message_received函数。

4. 在 on_message_received中，在以 print("Received message开头的行之后和在以 global received_count开头的行之前插入以下代码。

       topic_parsed = False
       if "/" in topic:
           parsed_topic = topic.split("/")
           if len(parsed_topic) == 3:
               # this topic has the correct format
               if (parsed_topic[0] == 'device') and (parsed_topic[2] == 'details'):
                   # this is a topic we care about, so check the 2nd element
                   if (parsed_topic[1] == 'temp'):
                       print("Received temperature request: {}".format(payload))
                       topic_parsed = True
                   if (parsed_topic[1] == 'light'):
                       print("Received light request: {}".format(payload))
                       topic_parsed = True
       if not topic_parsed:
           print("Unrecognized message topic.")
   

5. 保存更改并使用此命令行运行修改后的程序。

   python3 pubsub2.py --message "" --count 2 --topic device/+/details --ca_file ~/certs/Amazon-root-CA-1.pem --cert ~/certs/device.pem.crt --key ~/certs/private.pem.key --endpoint your-iot-endpoint
   

6. 在 AWS IoT 控制台中，打开MQTT测试客户端。

7. 在 Subscribe to topic（订阅主题）中，在 Subscription topic field（订阅主题字段）输入主题筛选条件：device/+/details，然后选择 Subscribe to topic（订阅主题）。

8. 在MQTT测试客户端的 “订阅” 列中，选择设备/+/详细信息。

9. 对于此表中的每个主题，请在MQTT测试客户端中执行以下操作：

   主题名称	消息负载
   device/temp/details	{ "desiredTemp": 20, "currentTemp": 15 }
   device/light/details	{ "desiredLight": 100, "currentLight": 50 }

   1. 在 Publish（发布）中，在表中输入 Topic name（主题名称）列的值。

   2. 在主题名称下方的消息负载字段中，在表中输入 Message payload（消息负载）列的值。

   3. 查看pubsub.py正在运行的终端窗口，然后在MQTT测试客户端中选择 “发布到主题”。

   您应该看到该消息是由终端窗口中的 pubsub.py接收的。

让您的MQTT测试客户端做好监控本练习中消息的准备

1. 在 Subscribe to topic（订阅主题）中，在 Subscription topic field（订阅主题字段）输入主题筛选条件：device/data，然后选择 Subscribe to topic（订阅主题）。

2. 在MQTT测试客户端的 “订阅” 列中，选择 “设备/数据”。

3. 保持MQTT测试客户端窗口处于打开状态，等待设备发来的消息。

使用 pubsub.py 示例应用程序发送JSON文档

1. 在您的设备上，将 pubsub.py复制到 pubsub3.py。

2. 编辑 pubsub3.py来更改其所发布消息的格式。

   1. 在文本编辑器中打开 pubsub3.py。

   2. 查找此代码行：

      message = "{} [{}]".format(message_string, publish_count)

   3. 将其更改为：

      message = "{}".format(message_string)

   4. 查找此代码行：

      message_json = json.dumps(message)

   5. 将其更改为：

      message = "{}".json.dumps(json.loads(message))

   6. 保存您的更改。

3. 在您的设备上运行此命令以发送消息两次。

   python3 pubsub3.py  --ca_file ~/certs/Amazon-root-CA-1.pem  --cert ~/certs/device.pem.crt  --key ~/certs/private.pem.key  --topic device/data  --count 2 --message '{"timestamp":1601048303,"sensorId":28,"sensorData":[{"sensorName":"Wind speed","sensorValue":34.2211224}]}'  --endpoint your-iot-endpoint
   

4. 在MQTT测试客户端中，检查它是否已解释并格式化了消息负载中的JSON文档，如下所示：