教程：将设备数据存储在 DynamoDB 表中

打开 DynamoDB 控制台，然后选择 Create table（创建表格）。

在 Create table（创建表）中：

1. 在 Table name（表名称）框中输入表名：wx_data。

2. 在 Partition key（分区键）中，输入 sample_time，然后在字段旁边的选项列表中，选择 Number。

3. 在 Sort key（排序键）中，输入 device_id，然后在字段旁边的选项列表中，选择 Number。

4. 在页面底部，选择 Create（创建）。

打开 AWS IoT 控制台的规则中心。或者，您可以在 AWS Management Console中打开 AWS IoT 主页，并导航到消息路由 > 规则。

要开始在 Rules（规则）中创建新规则，请选择 Create rule（创建规则）。

在 Rule properties（规则属性）中：

1. 在 Rule name（规则名称）中，输入 wx_data_ddb。

   请记住，规则名称在您的AWS 账户和区域中必须唯一，并且不能包含任何空格。我们在此名称中使用了下划线字符来分隔规则名称中的两个单词。

2. 在 Rule description（规则描述）中，描述规则。

   有意义的描述可以更容易地记住此规则的作用以及您创建它的原因。描述可以根据需要延长，因此请尽可能详细。

选择下一步以继续。

在 SQL statement（SQL 语句）中：

1. 在 SQL version（SQL 版本）中，选择 2016-03-23。

2. 在 SQL statement（SQL 语句）编辑框中，输入语句：

   SELECT temperature, humidity, barometer,
     wind.velocity as wind_velocity,
     wind.bearing as wind_bearing,
   FROM 'device/+/data'

   本语句：

   • 侦听主题符合 device/+/data主题筛选条件的 MQTT 消息。

   • 将 wind属性的元素格式化为单个属性。

   • 传递 temperature、humidity、barometer 属性，使其保持不变。

选择下一步以继续。

在 Rule actions（规则操作）中：

1. 要打开此规则的规则操作列表，请在 Action 1（操作 1）中，选择 DynamoDB。

   注意

   确保选择 DynamoDB 而不是 DynamoDBv2 作为规则操作。

2. 在 Table name（表名称）中，选择在上一步中创建的 DynamoDB 表的名称：wx_data。

   Partition key type（分区键类型）和 Sort key type（排序键类型）字段将使用 DynamoDB 表中的值填充。

3. 在分区键中，输入 sample_time。

4. 在分区键值中，输入 ${timestamp()}。

   这是您将在此规则中使用第一个 替换模板。它将使用 timestamp 函数返回的值，而不是消息负载中的值。要了解更多信息，请参阅《AWS IoT Core 开发人员指南》中的时间戳。

5. 在 Sort key（排序键）中，输入 device_id。

6. 在排序键值中，输入 ${cast(topic(2) AS DECIMAL)}。

   这是您将在此规则中使用的第二个 替换模板。它将第二个元素的值插入到主题名称，即设备的 ID，后面其将投射为十进制值以匹配密钥的数字格式。要了解有关主题的更多信息，请参阅《AWS IoT Core 开发人员指南》中的主题。或者，要了解有关强制转换的更多信息，请参阅《AWS IoT Core 开发人员指南》中的强制转换。

7. 在 Write message data to this column (将消息数据写入到此列) 中，输入 device_data。

   这将在 DynamoDB 表中创建 device_data列。

8. 将 Operation (操作) 留空。

9. 在 IAM Role（IAM 角色）中，选择 Create new role（创建新角色）。

10. 在 Create role（创建角色）对话框中，为 Role name（角色名称）输入 wx_ddb_role。这个新角色将自动包含一个前缀为“aws-iot-rule”的策略，该策略将允许该 wx_data_ddb 规则向您创建的 wx_data DynamoDB 表发送数据。

11. 在 IAM role（IAM 角色）中，选择 wx_ddb_role。

12. 在页面底部，选择 Next。

在 Review and create（审核和创建）页面的底部，选择 Create（创建）以创建规则。

在 AWS IoT控制台中的 MQTT 客户端中，订阅输入主题，device/+/data。

1. 在 MQTT 客户端中，选择 Subscribe to a topic（订阅主题）。

2. 对于 Topic filter（主题筛选条件）中，输入输入主题筛选条件的主题，device/+/data。

3. 选择订阅。

现在，使用特定设备 ID device/22/data向输入主题发布消息。您无法发布到包含通配符的 MQTT 主题。

1. 在 MQTT 客户端中，选择 Publish to a topic（发布到主题）。

2. 对于 Topic name（主题名称），输入输入主题名称 device/22/data。

3. 对于 Message payload（消息负载），输入以下示例数据。

   {
     "temperature": 28,
     "humidity": 80,
     "barometer": 1013,
     "wind": {
       "velocity": 22,
       "bearing": 255
     }
   }

4. 要发布 MQTT 消息，请选择 Publish（发布）。

5. 现在，在 MQTT 客户端中，选择 Subscribe to a topic（订阅主题）。在 Subscribe（订阅）列中，选择 device/+/data订阅。确认上一步骤中的示例数据是否显示在此处。

检查以查看您的规则创建的 DynamoDB 表中的行。

1. 在 AWS IoT 控制台的 DynamoDB 表中心中，选择 wx_data，然后选择 Items（项目）选项卡。

   如果您已经在 Items（项目）选项卡上，则可能需要通过选择表格标题右上角的刷新图标来刷新显示。

2. 请注意，表中的 sample_time 值是链接，请打开一个。如果您刚刚发送了第一条消息，那么这将是列表中唯一的消息。

   此链接显示表的该行中所有的数据。

3. 展开 device_data 条目以查看规则查询语句生成的数据。

4. 浏览此显示中可用数据的不同表示形式。您也可以编辑此显示中的数据。

5. 查看完此行数据后，要保存所做的任何更改，请选择 Save（保存），或者要退出而不保存任何更改，请选择 Cancel（取消）。