教程：重新发布消息 MQTT

打开AWS IoT 控制台的 “规则” 中心。

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

在 Create a rule（创建规则）顶部：

1. 在 Name（名称）下，输入规则的名称。在本教程中，将其命名为 republish_temp。

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

2. 在 Description（说明）中，描述规则。

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

在 Create a rule（创建规则）的 Rule query statement（规则查询语句）中：

1. 在使用SQL版本中，选择2016-03-23。

2. 在 Rule query statement（规则查询语句）编辑框中，输入语句：

   SELECT topic(2) as device_id, temperature FROM 'device/+/data'

   本语句：

   • 监听主题与device/+/data主题筛选条件匹配的MQTT消息。

   • 从主题字符串中选择第二个元素，并将其分配给 device_id字段。

   • 从消息负载中选择 temperature字段的值，并将其分配给 temperature字段。

在 Set one or more actions（设置一个或多个操作）中：

1. 要打开此规则的规则操作列表，请选择 Add action（添加操作）。

2. 在 “选择操作” 中，选择 “将消息重新发布到 AWS IoT 主题”。

3. 在操作列表底部，选择 Configure action（配置操作）以打开选定操作的配置页面。

在 Configure action（配置操作）中：

1. 在 Topic（主题）中输入 device/data/temp。这是该规则将发布的消息MQTT的主题。

2. 在 Quality of Service（服务质量）中，选择 0 - The message is delivered zero or more times（0-消息传递零次或多次）。

3. 在选择或创建角色以授予执行此操作的 AWS IoT 访问权限中：

   1. 请选择 Create Role(创建角色)。Create a new role（创建新角色）对话框打开。

   2. 输入描述新角色的名称。在本教程中，请使用 republish_role。

      创建新角色时，将创建用于执行规则操作的正确策略并将其附加到新角色。如果更改此规则操作的主题或在其它规则操作中使用此角色，则必须更新该角色的策略以授权新主题或操作。要更新现有角色，请在本部分中选择 Update role（更新角色）。

   3. 选择 Create Role（创建角色）以创建角色并关闭对话框。

4. 选择 Add action（添加操作）将操作添加到规则并返回到 Create a rule（创建规则）页。

“将消息重新发布到 AWS IoT 主题” 操作现在列在 “设置一个或多个操作” 中。

在新动作的磁贴中，在 Republish a message to an AWS IoT topic（将消息重新发布至 IoT 主题）下，您可以看到重新发布操作将发布到的主题。

这是您将添加到此规则的唯一规则操作。

在 Create a rule（创建规则）中，向下滚动到底部，然后选择 Create rule（创建规则）以创建规则并完成此步骤。

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

1. 在MQTT客户端的 “订阅” 下，选择 “订阅主题”。

2. 在 Subscription topic（订阅主题）中，输入输入主题筛选条件的主题，device/+/data。

3. 将其它字段保留为默认设置。

4. 选择 Subscribe to topic（订阅主题）。

   在 Subscriptions（订阅）栏，在 Publish to a topic（发布到主题）项下，将会显示 device/+/data。

订阅您的规则将发布的主题：device/data/temp。

1. 在 Subscriptions（订阅）中，再次选择 Subscribe to a topic（订阅主题），并在 Subscription topic（订阅主题）中，输入重新发布消息的主题，device/data/temp。

2. 将其它字段保留为默认设置。

3. 选择 Subscribe to topic（订阅主题）。

   在 Subscriptions（订阅）栏，在 device/+/data 下，将会显示 device/data/temp。

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

1. 在MQTT客户端的 “订阅” 下，选择 “发布到主题”。

2. 在 Publish（发布）字段中，输入输入主题名称，device/22/data。

3. 复制此处显示的示例数据，然后在主题名称下方的编辑框中粘贴示例数据。

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

4. 要发送MQTT消息，请选择发布到主题。

查看已发送的消息。

1. 在MQTT客户端中，在 “订阅” 下，您之前订阅的两个主题旁边有一个绿点。

   绿色圆点表示自您上次查看它们以来已收到一条或多条新消息。

2. 在 Subscriptions（订阅）中，选择 device/+/data 来检查消息负载是否与刚刚发布的内容匹配，如下所示：

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

3. 在 Subscriptions（订阅）中，选择 device/data/temp 来检查重新发布的消息负载，如下所示：

   {
     "device_id": "22",  
     "temperature": 28
   }

   请注意，device_id 值是一个带引号的字符串，temperature 值为数字。这是因为 topic()函数从输入消息的主题名称中提取字符串，而 temperature值使用输入消息负载中的数值。

   如果您想使 device_id值为数值，请在规则查询语句中将 topic(2)替换为：

   cast(topic(2) AS DECIMAL)

   请注意，将 topic(2)值设置为数字值仅在主题的该部分仅包含数字字符时才起作用。

如果您看到正确的消息已发布到 device/data/temp 主题，那么您的规则已起作用。请在下一部分中了解有关“重新发布规则”操作的更多信息。

如果您没有看到正确的消息发布到 device/+/data 或者 device/data/temp 主题中，请查看故障排除提示。