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

创建新 AWS Lambda 函数。

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

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

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

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

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

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

   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（部署）。

在新窗口中，从教程中查找有关如何操作的亚马逊SNS主题的亚马逊资源名称 (ARN) 教程：发送 Amazon SNS 通知。

1. 在新窗口中，打开 Amazon SNS 控制台的主题页面。

2. 在主题页面中，在亚马逊主题列表中找到 high_temp_notice 通知主题。SNS

3. 找到要在下ARN一步中使用的 high_temp_notice 通知主题。

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

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

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

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

4. 在事件名称下方的JSON编辑器中，粘贴此示例JSON文档。这是您的 AWS 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中的值。

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

7. 选择创建。

使用示例数据测试函数。

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

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

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

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

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

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

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

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

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

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

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

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

   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中包含您的通知主题。

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

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（创建规则）。

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

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

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

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

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

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

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

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

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

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

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

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

确认文本消息已发送。

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客户端的 “订阅” 下，选择 “发布到主题”。

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

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

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

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

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

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