本文属于机器翻译版本。若本译文内容与英语原文存在差异,则一律以英文原文为准。
将属性值更新发布到 Amazon DynamoDB
您可以将数据存储在 Amazon Dynam
在本教程中,您将在提供风力发电场示例数据集的 Amazon IoT SiteWise 演示基础上进行构建。您可以配置从风电场演示的属性值更新,通过 Amazon IoT Core 规则将数据发送到您创建的 DynamoDB 表。启用属性值更新后, Amazon IoT SiteWise 会以 MQTT 消息的 Amazon IoT Core 形式将您的数据发送到。然后,您可以根据这些消息的内容定义执行操作(例如 DynamoDB 操作)的 Amazon IoT 核心规则。有关更多信息,请参阅与其他 Amazon 服务交互。
主题
先决条件
要完成本教程,您需要:
-
一个 Amazon 账户。如果没有,请参阅设置一个 Amazon Web Services 账户。
-
一台运行 Windows、macOS、Linux 或 Unix 的开发计算机,用于访问。 Amazon Web Services Management Console有关更多信息,请参阅 Amazon Web Services Management Console 入门。
-
具有管理员权限的 IAM 用户。
-
正在运行的 Amazon IoT SiteWise 风力发电场演示。当你设置演示时,它会定义模型和资产, Amazon IoT SiteWise 并将数据流式传输到它们以表示风力发电场。有关更多信息,请参阅使用演 Amazon IoT SiteWise 示。
配置 Amazon IoT SiteWise 为发布属性值更新
在该过程中,您在演示涡轮机资产的 Wind Speed 属性上启用属性值通知。启用属性值通知后,在 MQTT 消息中将每个值更新 Amazon IoT SiteWise 发布到 Amazon IoT Core。
在资产属性上启用属性值更新通知
-
如有Amazon 必要 Amazon IoT SiteWise ,请查看支持的 Amazon 区域并切换区域。切换到您运行 Amazon IoT SiteWise 演示的区域。
-
在左侧导航窗格中,选择 资产。
-
选择 Demo Wind Farm Asset 旁边的箭头,展开风电场资产的层次结构。
-
选择一个演示涡轮机,然后选择 编辑。
-
将 Wind Speed 属性的 通知状态 更新为 已启用。
-
选择页面底部的 保存资产。
-
对于每个演示涡轮机资产,重复步骤 5 至 7。
-
选择演示涡轮机(例如,Demo Turbine Asset 1)。
-
选择 测量值。
-
选择 Wind Speed 属性旁边的复制图标,以将通知主题复制到剪贴板。保存通知主题以在本教程后面使用。您只需记录一个涡轮机中的通知主题。
通知主题应类似于以下示例。
$aws/sitewise/asset-models/
a1b2c3d4-5678-90ab-cdef-11111EXAMPLE
/assets/a1b2c3d4-5678-90ab-cdef-22222EXAMPLE
/properties/a1b2c3d4-5678-90ab-cdef-33333EXAMPLE
在 C Amazon IoT ore 中创建规则
在此过程中,您将在 Amazon IoT Core 中创建一条规则,用于解析属性值通知消息并将数据插入到 DynamoDB 表中。 Amazon IoT 核心规则解析 MQTT 消息,并根据每条消息的内容和主题执行操作。您可以创建带有 DynamoDB 操作的规则,将数据插入到 DynamoDB 表(这是您在本教程中创建的表)中。
使用 DynamoDB 操作创建规则
-
导航到 Amazon IoT 控制台
。如果显示 开始 按钮,请选择该按钮。 -
在左侧导航窗格中,选择行动,然后选择规则。
-
如果显示您还没有任何规则对话框,请选择创建规则。否则,选择 创建。
-
为规则输入名称和描述。
-
查找您在本教程前面保存的通知主题。
$aws/sitewise/asset-models/
a1b2c3d4-5678-90ab-cdef-11111EXAMPLE
/assets/a1b2c3d4-5678-90ab-cdef-22222EXAMPLE
/properties/a1b2c3d4-5678-90ab-cdef-33333EXAMPLE
将主题中的资产 ID(后面的 ID
assets/
)替换为+
。这将为所有演示风力涡轮机资产选择风速属性。+
主题筛选器接受主题中的单个级别的所有节点。您的主题应类似于以下示例。$aws/sitewise/asset-models/
a1b2c3d4-5678-90ab-cdef-11111EXAMPLE
/assets/+/properties/a1b2c3d4-5678-90ab-cdef-33333EXAMPLE
-
输入以下规则查询语句。将
FROM
部分中的主题替换为您的通知主题。SELECT payload.assetId AS asset, (SELECT VALUE (value.doubleValue) FROM payload.values) AS windspeed, timestamp() AS timestamp FROM '$aws/sitewise/asset-models/
a1b2c3d4-5678-90ab-cdef-11111EXAMPLE
/assets/+/properties/a1b2c3d4-5678-90ab-cdef-33333EXAMPLE
' WHERE type = 'PropertyValueUpdate' -
在 设置一个或多个操作 下,选择 添加操作。
-
在选择操作页面上,选择将消息拆分为 DynamoDB 表 (DynamoDBv2) 的多个列。
-
选择页面底部的 配置操作。
-
在 配置操作 页面,选择 创建新资源。
DynamoDB 控制台将打开新的选项卡。在完成以下过程时,请将规则操作选项卡保持打开状态。
创建 DynamoDB 表
在该过程中,您创建一个 DynamoDB 表以从规则操作中接收风速数据。
创建 DynamoDB 表
-
在 DynamoDB 控制台控制面板中,选择创建表。
-
输入表的名称。
-
对于 主键,请执行以下操作:
-
输入
timestamp
以作为分区键。 -
选择 数字 类型。
-
选中 添加排序键 复选框。
-
输入
asset
以作为排序键,并保留默认排序键类型 字符串。
-
-
选择 创建。
在 正在创建表 通知消失时,您的表将准备就绪。
-
返回到具有 配置操作 页面的选项卡。在完成以下过程时,请将 DynamoDB 选项卡保持打开状态。
配置 DynamoDB 规则操作
在此过程中,您将配置 DynamoDB 规则操作,将来自属性值更新的数据插入到新的 DynamoDB 表中。
配置 DynamoDB 规则操作
-
在配置操作页面上,刷新表名称列表,然后选择新的 DynamoDB 表。
-
选择创建角色以创建一个 IAM 角色,该角色向 Amazon IoT 核心授予执行规则操作的访问权限。
-
输入角色名称,然后选择创建角色。
-
选择添加操作。
-
选择页面底部的 创建规则 以完成创建规则的过程。
将开始在 DynamoDB 表中显示您的演示资产数据。
在 DynamoDB 中探索数据
在该过程中,您在新的 DynamoDB 表中浏览演示资产的风速数据。
在 DynamoDB 中浏览资产数据
-
返回到打开了 DynamoDB 表的选项卡。
-
在您以前创建的表中,选择 项目 选项卡以查看表中的数据。如果您没有看到表中的行,请刷新页面。如果在几分钟后没有显示行,请参阅排查规则问题。
-
在表的一行中,选择编辑图标以展开数据。
-
选择 windspeed 结构旁边的箭头,以展开风速数据点列表。每个列表都反映了风电场演示发送到 Amazon IoT SiteWise 的一批风速数据点。如果您设置规则操作以供自己使用,则可能需要使用不同的数据格式。有关更多信息,请参阅查询资产属性通知消息。
完成本教程后,您可以禁用或删除规则并删除 DynamoDB 表,避免产生额外费用。请按照以下过程清理您的资源。
在完成教程后清理资源
完成本教程后,清理资源以避免产生额外费用。您的演示风电场资产将在您在创建演示时选择的持续时间结束时删除。您也可以手动删除演示。有关更多信息,请参阅删除演 Amazon IoT SiteWise 示。
使用以下过程禁用属性值更新通知(如果您没有删除演示)、禁用或删除您的 Amazon IoT 规则,以及删除您的 DynamoDB 表。
禁用资产属性上的属性值更新通知
-
在左侧导航窗格中,选择 资产。
-
选择 Demo Wind Farm Asset 旁边的箭头,展开风电场资产的层次结构。
-
选择一个演示涡轮机,然后选择 编辑。
-
将 Wind Speed 属性的 通知状态 更新为 已禁用。
-
选择页面底部的 保存资产。
-
对于每个演示涡轮机资产,重复步骤 4 至 6。
禁用或删除中的规则 Amazon IoT Core
-
导航到 Amazon IoT 控制台
。 -
在左侧导航窗格中,选择行动,然后选择规则。
-
选择您的规则上的菜单,然后选择 禁用 或 删除。
删除 DynamoDB 表
-
导航到 DynamoDB 控制台
。 -
在左侧导航窗格中,选择 表。
-
选择您之前创建的表 WindSpeedData。
-
选择 删除表。
-
在 删除表 对话框中,选择 删除。
排查规则问题
如果演示资产数据未按预期方式显示在 DynamoDB 表中,请按照该过程中的步骤排除规则故障。在该过程中,您将重新发布规则操作配置为错误操作,以在 MQTT 测试客户端中查看错误消息。您也可以配置日志记录以 CloudWatch 进行故障排除。有关更多信息,请参阅《Amazon IoT 开发人员指南》中的使用 CloudWatch 日志进行监控。
在规则中添加重新发布错误操作
-
导航到 Amazon IoT 控制台
。 -
在左侧导航窗格中,选择行动,然后选择规则。
-
选择您以前创建的规则。
-
在 错误操作 下面,选择 添加操作。
-
选择 “将消息重新发布到某个 Amazon IoT 主题”。
-
选择页面底部的 配置操作。
-
在 Topic(主题)中输入
windspeed/error
。 Amazon IoT Core 将重新发布此主题的错误消息。 -
选择 Select 以授予使用您之前创建的角色执行错误操作的 C Amazon IoT ore 访问权限。
-
选择您的角色旁边的 选择。
-
选择 更新角色 以在角色中添加其他权限。
-
选择 添加操作 以完成添加错误操作的过程。
-
选择主机左上角的后退箭头返回 Amazon IoT 酷睿主机主页。
设置重新发布错误操作后,您可以在 Core 的 MQTT 测试客户端中 Amazon IoT 查看错误消息。
在以下过程中,您在 MQTT 测试客户端中订阅错误主题。
订阅错误操作主题
-
在 Amazon IoT Core 控制台的左侧导航页中,选择 “测试”。
-
在 订阅主题 字段中,输入
windspeed/error
并选择 订阅主题。 -
观察显示的错误消息,并在错误消息中浏览
failures
数组以诊断以下常见问题:-
规则查询语句中的错别字
-
角色权限不足
如果未显示错误,请检查是否启用了您的规则,以及您是否订阅了在重新发布错误操作中配置的相同主题。如果仍未显示错误,请检查您的演示风电场资产是否仍然存在,以及是否在风速属性上启用了通知。如果您的演示资产已过期并从中消失 Amazon IoT SiteWise,则可以创建一个新的演示并更新规则查询语句以反映更新的资产模型和属性 ID。
-