教程:使用 Amazon Lambda函数格式化通知 - Amazon IoT Core
Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异,请参阅中国的 Amazon Web Services 服务入门

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

本教程将演示如何将 MQTT 消息数据发送到 Amazon Lambda操作来格式化并发送到另一个 Amazon服务。在本教程中,Amazon Lambda 操作使用 AmazonSDK 将格式化的消息发送到您在介绍如何教程:发送 Amazon SNS 通知的教程中创建的 Amazon SNS 主题。

在有关如何 教程:发送 Amazon SNS 通知的教程中,则由规则的查询语句生成的 JSON 文档将作为文本消息的正文发送。结果是一条文本消息,示例如下:

{"device_id":"32","reported_temperature":38,"max_temperature":30}

在本教程中,您将使用 Amazon Lambda规则操作来调用 Amazon Lambda函数,该函数将规则查询语句中的数据格式化为更便于使用的格式,示例如下:

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

您将在此教程中格式化的 Amazon Lambda函数将使用规则查询语句中的数据来设置消息字符串的格式,并调用 AmazonSDK 的 SNS 发布函数来创建通知。

在本教程中您将学到

  • 如何创建和测试 Amazon Lambda函数

  • 如何使用 Amazon Lambda函数中的 AmazonSDK 来发布 Amazon SNS 通知

  • 如何在规则查询语句中使用简单的 SQL 查询和函数

  • 如何使用 MQTT 客户端来测试 Amazon IoT规则

完成本教程需要大约 45 分钟。

在开始本教程之前,请确保您具有:

步骤 1:创建发送文本消息的 Amazon Lambda函数

本教程中的 Amazon Lambda函数会接收规则查询语句的结果,将元素插入到文本字符串中,然后将结果字符串作为通知中的消息发送到 Amazon SNS。

与有关如何 教程:发送 Amazon SNS 通知的教程不同,该教程中使用 Amazon IoT规则操作来发送通知,而本教程则通过使用 AmazonSDK 的函数来从 Lambda 函数发送通知。但是,本教程中使用的实际 Amazon SNS 通知主题与您在有关如何教程:发送 Amazon SNS 通知的教程中使用的主题相同。

创建发送文本消息的 Amazon Lambda函数

  1. 创建新的 Amazon Lambda函数

    1. Amazon 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 Amazonpolicy templates(从亚马逊云科技策略模板创建新角色)。

      3. 在 Role name(角色名称)中,为新角色输入名称,format-high-temp-notification-role

      4. Policy templates - optional(策略模板 — 可选)中,搜索并选择 Amazon SNS publish popolicy(Amazon SNS 发布策略)。

      5. 选择 Create function(创建函数)。

  2. 修改蓝图代码以格式化并发送 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(部署)。

  3. 在新窗口中,从关于如何教程:发送 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,以在下一步中使用。

  4. 为您的 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 文档。这是您的 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. 选择 Create (创建)

  5. 使用示例数据测试函数。

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

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

如果函数和通知都有效,您将在订阅通知的手机上收到一条文本消息。

如果您在手机上没有收到文本消息,请检查操作结果。在 Function code(函数代码)面板中的 Execution result(执行结果)选项卡上,查看响应以查找发生的任何错误。请勿继续执行下一步,直到您的函数可以将通知发送到您的手机。

步骤 2:使用 Amazon Lambda规则操作创建 Amazon IoT规则

在此步骤中,您将使用规则查询语句格式化来自虚拟气象传感器设备的数据,以发送到 Lambda 函数,该函数将格式化并发送文本消息。

从天气设备接收的示例消息负载如下所示:

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

在此规则中,您将使用规则查询语句为 Lambda 函数创建消息负载,如下所示:

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

这包含 Lambda 函数格式化和发送正确文本消息所需的所有信息。

创建一个 Amazon IoT规则来调用 Lambda 函数

  1. 打开 Amazon IoT控制台的 Rules(规则)页面

  2. 要在 Rule(规则)中创建新规则,请选择 Create(创建)。

  3. Create a rule(创建规则)顶部:

    1. Name(名称)中,输入规则的名称,wx_friendly_text

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

    2. Description(说明)中,描述规则。

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

  4. 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)。

  5. Set one or more actions(设置一个或多个操作)中:

    1. 要打开此规则的规则操作列表,请选择 Add action(添加操作)。

    2. Select an action(选择操作)中,选择 Send a message to a Lambda function(向 Lambda 函数发送消息)。

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

  6. Configure action(配置操作)中:

    1. Function name(函数名称)中,选择 Select(选择)。

    2. 选择 format-high-temp-notification

    3. Configure action(配置操作)底部,选择 Add action(添加操作)。

    4. 要创建规则,请在 Create a rule(创建一条规则)底部,选择 Create rule(创建规则)。

步骤 3:测试 Amazon IoT规则和 Amazon Lambda规则操作

要测试新规则,您将使用 MQTT 客户端发布和订阅此规则所使用的 MQTT 消息。

在新窗口中打开 Amazon IoT控制台中的 MQTT 客户端。现在,您可以在不丢失 MQTT 客户端配置的情况下编辑规则。如果您离开 MQTT 客户端并转到控制台中的其它页面,则将丢失您的订阅或消息日志。

如需使用 MQTT 客户端来测试您的规则

  1. Amazon 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

  2. 使用特定设备 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(发布到主题)。

  3. 确认文本消息已发送。

    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)值投射为数字值仅在消息主题中的元素仅包含数字字符时才起作用。

  4. 尝试发送温度未超过限制的 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订阅中看到您发送的消息;但是,由于温度值低于规则查询语句中的最大温度,因此您不应收到文本消息。

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

对您的 Amazon Lambda规则和通知进行故障排除

如果您没有看到期望的结果,可以检查以下事项。

  • 您收到了一个错误的广告条

    如果在您发布输入消息时出现错误,请先更正该错误。以下步骤可帮助您更正此错误。

  • 您未在 MQTT 客户端中看到输入消息

    每次将输入消息发布到 device/32/data主题时,如果您如流程中所述订阅了 device/+/data主题筛选条件,则消息应当会在 MQTT 客户端中显示。

    要检查的事项

    • 检查您订阅的主题筛选条件

      如果您如流程中所述订阅了输入消息主题,则每次发布输入消息时都应看到该输入消息的副本。

      如果没有看到该消息,请检查您订阅的主题名称,并将其与您发布的主题进行比较。主题名称区分大小写,您订阅的主题必须与发布消息负载的主题相同。

    • 检查消息发布函数

      在 MQTT 客户端中,在 Subscriptions(订阅)项下,选择device/+/data,检查发布消息的主题,然后选择 Publish to topic(发布到主题)。您应该会看到来自主题下方编辑框中的消息负载出现在消息列表中。

  • 您没有收到 SMS 消息

    要使规则起作用,规则必须具有授权其接收消息和发送 SNS 通知的正确策略,并且必须接收消息。

    要检查的事项

    • 检查 MQTT 客户端的 Amazon Web Services 区域和您创建的规则

      您在其中运行 MQTT 客户端的控制台必须位于您所创建规则的同一 Amazon区域。

    • 检查消息负载中的温度值是否超过测试阈值

      如果温度值小于或等于 30(如规则查询语句中定义),则规则将不会执行其任何操作。

    • 检查规则查询语句中的输入消息主题

      要使规则起作用,它必须收到一条消息,消息主题名称应与规则查询语句 FROM 子句中的主题筛选条件相匹配。

      检查规则查询语句中主题筛选条件的拼写与 MQTT 客户端中主题的拼写。主题名称区分大小写,消息的主题必须与规则查询语句中的主题筛选条件匹配。

    • 检查输入消息负载的内容

      要使规则起作用,则必须在 SELECT 语句中声明的消息负载中找到数据字段。

      检查规则查询语句 temperature字段中的拼写与 MQTT 客户端中消息负载的拼写。字段名称区分大小写,规则查询语句中 temperature字段必须与消息负载中的 temperature字段相同。

      确保消息负载中的 JSON 文档格式正确。如果 JSON 有任何错误(例如缺少逗号),则规则将无法读取它。

    • 查看 Amazon SNS 通知

      步骤 1:创建 Amazon SNS 主题,:发送 SMS 文本消息中,请参阅步骤 3,该步骤介绍如何测试 Amazon SNS 通知并测试通知以确保通知有效。

    • 检查 Lambda 函数

      步骤 1:创建发送文本消息的 Amazon Lambda函数中,请参阅步骤 5,该步骤介绍如何使用测试数据测试 Lambda 函数并测试 Lambda 函数。

    • 检查规则所使用的角色

      规则操作必须具有接收原始主题和发布新主题的权限。

      授权规则接收消息数据并重新发布的策略特定于所使用的主题。如果更改用于重新发布消息数据的主题,则必须更新规则操作的角色,以更新其策略来匹配当前主题。

      如果怀疑这里出现了问题,请编辑“重新发布”规则操作并创建新角色。规则操作创建的新角色将接收执行这些操作所需的授权。

步骤 4:查看结果和后续步骤

在本教程中:

  • 您创建了 Amazon IoT规则来调用 Lambda 函数,该函数发送使用您的自定义消息负载的 Amazon SNS 通知。

  • 您在规则查询语句中使用了简单的 SQL 查询和函数来为 Lambda 函数创建新的消息负载。

  • 您可以使用 MQTT 客户端来测试您的 Amazon IoT规则。

后续步骤

使用此规则发送了几条文本消息后,请尝试使用它来了解更改教程的某些方面如何影响消息以及发送消息的时间。以下想法可以帮助您开始操作。

  • 在输入消息主题中更改 device_id,并观察文本消息内容中的效果。

  • 更改规则查询语句中选定的字段,更新 Lambda 函数以在新消息中使用这些字段,并观察文本消息内容中的效果。

  • 将规则查询语句中的测试更改为测试最低温度而不是最高温度。更新 Lambda 函数以格式化新消息,并记得更改 max_temperature名称。

  • 要了解有关如何查找在开发和使用 Amazon IoT 规则过程中可能会出现的错误,请参阅 监控 Amazon IoT