教程：使用 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. 对于 Execution role（执行角色），请选择 Create a new role from AWSpolicy templates（从亚马逊云科技策略模板创建新角色）。

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

   4. 在 Policy templates - optional（策略模板 — 可选）中，搜索并选择 Amazon SNS publish popolicy（Amazon SNS 发布策略）。

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

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

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

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

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 Resource Name (ARN)。

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

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

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

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

1. 在控制台的 Lambda Functions（Lambda 函数）页面上，在 format-high-temp-notification 详细信息页面，在页面右上角选择 Select a test event（选择测试事件）,即使它看起来已禁用，然后选择 Configure test events（配置测试事件）。

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

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

4. 在 Event name（事件名称）下方的 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. 选择 Choose（创建）。

使用示例数据测试函数。

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

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

打开 AWS IoT控制台的 Rules（规则）页面。

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

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

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

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

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

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

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

1. 在 Using SQL version（使用 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 值 (arn:aws:sns:us-east-1:57EXAMPLE833:high_temp_notice)。

在 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 客户端中，在 Subscriptions（订阅）项下，选择 Subscribe to a topic（订阅主题）。

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

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

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

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

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

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

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

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

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

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

确认文本消息已发送。

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

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

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. 在 Publish（发布）字段中，输入输入主题名称，device/33/data。

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

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

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

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

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