教程：使用 Amazon Lambda 函数格式化通知

创建新Amazon Lambda函数。

1. 在 Amazon Lambda控制台中，选择 Create function（创建函数）。

2. 在 Create function（创建函数）中，选择 Use a blueprint（使用蓝图）。

   搜索并选择 hello-world-python 蓝图，然后选择配置。

3. 在 Basic information（基本信息）中：

   1. 在 Function name（函数名称）中，输入函数的名称，format-high-temp-notification。

   2. 在执行角色中，选择从Amazon策略模板创建新角色。

   3. 在 Role name（角色名称）中，为新角色输入名称，format-high-temp-notification-role。

   4. 在策略模板 - 可选中，搜索并选择 Amazon SNS 发布策略。

   5. 选择 Create function（创建函数）。

修改蓝图代码以格式化并发送 Amazon SNS 通知。

1. 创建函数后，您应该会看到format-high-temp-notification详细信息页面。如果您不这样做，请从 Lambda Functions（Lambda 函数）页打开它。

2. 在format-high-temp-notification详细信息页面中，选择配置选项卡，然后滚动到函数代码面板。

3. 在 Function code（函数代码）窗口中的 Environment（环境）窗格中，选择 Python 文件，lambda_function.py。

4. 在 Function code（函数代码）窗口中，从蓝图中删除所有原始程序代码，并将其替换为此代码。

   import boto3
   #
   #   expects event parameter to contain:
   #   {
   #       "device_id": "32",
   #       "reported_temperature": 38,
   #       "max_temperature": 30,
   #       "notify_topic_arn": "arn:aws:sns:us-east-1:57EXAMPLE833:high_temp_notice"
   #   }
   # 
   #   sends a plain text string to be used in a text message
   #
   #      "Device {0} reports a temperature of {1}, which exceeds the limit of {2}."
   #   
   #   where:
   #       {0} is the device_id value
   #       {1} is the reported_temperature value
   #       {2} is the max_temperature value
   #
   def lambda_handler(event, context):
   
       # Create an SNS client to send notification
       sns = boto3.client('sns')
   
       # Format text message from data
       message_text = "Device {0} reports a temperature of {1}, which exceeds the limit of {2}.".format(
               str(event['device_id']),
               str(event['reported_temperature']),
               str(event['max_temperature'])
           )
   
       # Publish the formatted message
       response = sns.publish(
               TopicArn = event['notify_topic_arn'],
               Message = message_text
           )
   
       return response

5. 选择 Deploy（部署）。

在新窗口中，从关于如何 教程：发送 Amazon SNS 通知 的教程中查找 Amazon SNS 主题的 Amazon 资源名称（ARN）。

1. 在新窗口中，打开 Topics page of the Amazon SNS console（Amazon SNS 控制台主题页面）。

2. 在主题页面上，在 Amazon SNS 主题列表中找到 high_temp_notice 通知主题。

3. 查找 high_temp_notice 通知主题的 ARN，以在下一步中使用。

为您的 Lambda 函数创建一个测试使用案例。

1. 在控制台的 Lambda F un ctions 页面的format-high-temp-notification详细信息页面上，选择页面右上角的选择测试事件（尽管它看起来已禁用），然后选择配置测试事件。

2. 在 Configure test event（配置测试事件）中，选择 Create new test event（创建新测试事件）。

3. 在 Event name（事件名称）中，输入 SampleRuleOutput。

4. 在 Event name（事件名称）下方的 JSON 编辑器中，请粘贴此示例 JSON 文档。这是您的Amazon IoT规则将向 Lambda 函数发送的内容的示例。

   {
     "device_id": "32",
     "reported_temperature": 38,
     "max_temperature": 30,
     "notify_topic_arn": "arn:aws:sns:us-east-1:57EXAMPLE833:high_temp_notice"
   }

5. 请参阅具有 high_temp_notice通知主题的 ARN 的窗口并复制 ARN 值。

6. 在 JSON 编辑器中将 notify_topic_arn 值替换成您通知主题中的 ARN。

   保持此窗口打开状态，以便在创建 Amazon IoT 规则时再次使用该 ARN 值。

7. 选择 Choose（创建）。

使用示例数据测试函数。

1. 在页面右上角的format-high-temp-notification详细信息页面中，确认SampleRuleOutput显示在 “测试” 按钮旁边。如果没有，请从可用测试事件列表中选择它。

2. 要将示例规则输出消息发送到您的函数，请选择 Test（测试）。

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

要在 Rule（规则）中创建新规则，请选择 Create（创建）。

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

1. 在 Name（名称）中，输入规则的名称，wx_friendly_text。

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

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

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

在创建规则的规则查询语句中：

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

2. 在规则查询语句编辑框中，输入语句：

   SELECT 
     cast(topic(2) AS DECIMAL) as device_id, 
     temperature as reported_temperature,
     30 as max_temperature,
     'arn:aws:sns:us-east-1:57EXAMPLE833:high_temp_notice' as notify_topic_arn
   FROM 'device/+/data' WHERE temperature > 30

   本语句：

   • 侦听主题与 device/+/data主题筛选条件相符，并且 temperature值大于 30 的 MQTT 消息。

   • 从主题字符串中选择第二个元素，将其转换为十进制数，然后将其分配给 device_id 字段。

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

   • 创建常数值 30 来表示限制值，并将其赋值给 max_temperature 字段。

   • 为 notify_topic_arn 字段创建常数值。

3. 请参阅具有 high_temp_notice 通知主题的 ARN 的窗口并复制 ARN 值。

4. 将规则查询语句编辑器中的 ARN 值 (arn:aws:sns:us-east-1:57EXAMPLE833:high_temp_notice) 替换为通知主题的 ARN。

在设置一个或多个操作中：

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

2. 在 Select an action（选择操作）中，选择 Send a message to a Lambda function（向 Lambda 函数发送消息）。

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

在 Configure action（配置操作）中：

1. 在 Function name（函数名称）中，选择 Select（选择）。

2. 选择 format-high-temp-notification。

3. 在 Configure action（配置操作）底部，选择 Add action（添加操作）。

4. 要创建规则，请在 Create a rule（创建一条规则）底部，选择 Create rule（创建规则）。

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

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

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

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

4. 选择订阅主题。

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

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

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

2. 在发布字段中，输入输入主题名称，device/32/data。

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

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

4. 如需发布 MQTT 消息，请选择 Publish to topic（发布到主题）。

确认文本消息已发送。

1. 在 MQTT 客户端的订阅下，您之前订阅的主题旁边会有一个绿色圆点。

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

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

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

3. 检查您用于订阅 SNS 主题的电话，并确认消息负载的内容，如下所示：

   Device 32 reports a temperature of 38, which exceeds the limit of 30.

   如果您更改消息主题中的主题 ID 元素，请记住，将 topic(2) 值投射为数字值仅在消息主题中的元素仅包含数字字符时才起作用。

尝试发送温度未超过限制的 MQTT 消息。

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

2. 在发布字段中，输入输入主题名称，device/33/data。

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

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

4. 要发送您的 MQTT 消息，请选择 Publish to topic（发布到主题）。

您应在 device/+/data 订阅中看到您发送的消息；但是，由于温度值低于规则查询语句中的最大温度，因此您不应收到文本消息。

如果您未看到正确的行为，请检查故障排除提示。