本文属于机器翻译版本。若本译文内容与英语原文存在差异,则一律以英文原文为准。
向亚马逊 DynamoDB 发布房产价值更新
本教程介绍了一种使用 Amazon Dynamo
在本教程中,您将在提供风力发电场示例数据集的 AWS IoT SiteWise 演示基础上进行构建。您可以配置从风电场演示的属性值更新,通过 AWS IoT Core 规则将数据发送到您创建的 DynamoDB 表。启用属性值更新后, AWS IoT SiteWise 会在MQTT消息 AWS IoT Core 中将您的数据发送到。然后,根据这些消息的内容定义执行操作(例如 DynamoDB 操作)的 AWS IoT 核心规则。有关更多信息,请参阅 与其他 AWS 服务互动。
主题
先决条件
要完成本教程,您需要:
-
一个 AWS 账户。如果没有,请参阅设置一个 AWS 账户。
-
一台运行 Windows、macOS、Linux 或 Unix 的开发计算机,用于访问。 AWS Management Console有关更多信息,请参阅 AWS Management Console入门。
-
具有管理员权限的 IAM 用户。
-
正在运行的 AWS IoT SiteWise 风力发电场演示。当你设置演示时,它会定义模型和资产, AWS IoT SiteWise 并将数据流式传输到它们以表示风力发电场。有关更多信息,请参阅 使用演 AWS IoT SiteWise 示。
步骤 1:配置 AWS IoT SiteWise 以发布属性值更新
在该过程中,您在演示涡轮机资产的 Wind Speed 属性上启用属性值通知。启用属性值通知后,会在MQTT消息中向 C AWS IoT ore AWS IoT SiteWise 发布每项值更新。
在资产属性上启用属性值更新通知
-
查看支持的AWS IoT SiteWise 终端节点和配额,必要时切换 AWS 区域。 AWS IoT SiteWise 切换到你正在运行 AWS IoT SiteWise 演示的区域。
-
在左侧导航窗格中,选择 资产。
-
选择 Demo Wind Farm Asset 旁边的箭头,展开风电场资产的层次结构。
-
选择一个演示涡轮机,然后选择 编辑。
-
将Wind Speed酒店的通知状态更新为ENABLED。
-
选择页面底部的 保存资产。
-
对于每个演示涡轮机资产,重复步骤 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
第 2 步:在 C AWS IoT ore 中创建规则
在此过程中,您将在 AWS IoT Core 中创建一条规则,用于解析属性值通知消息并将数据插入到 Amazon DynamoDB 表中。 AWS IoT 核心规则根据每MQTT条消息的内容和主题解析消息并执行操作。然后,您创建一个带有 DynamoDB 操作的规则,用于将数据插入您在本教程中创建的 DynamoDB 表。
使用 DynamoDB 操作创建规则
-
导航到 AWS 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 表的多列 (ynamoDBvD 2)。
-
选择页面底部的 配置操作。
-
在 配置操作 页面,选择 创建新资源。
DynamoDB 控制台将打开新的选项卡。在完成以下过程时,请将规则操作选项卡保持打开状态。
步骤 3:创建 DynamoDB 表
在此过程中,您将创建一个 Amazon DynamoDB 表来接收来自规则操作的风速数据。
创建 DynamoDB 表
-
在 DynamoDB 控制台控制面板中,选择创建表。
-
输入表的名称。
-
对于 主键,请执行以下操作:
-
输入
timestamp
以作为分区键。 -
选择 数字 类型。
-
选中 添加排序键 复选框。
-
输入
asset
以作为排序键,并保留默认排序键类型 字符串。
-
-
选择创建。
在 正在创建表 通知消失时,您的表将准备就绪。
-
返回到具有 配置操作 页面的选项卡。在完成以下过程时,请将 DynamoDB 选项卡保持打开状态。
步骤 4:配置 DynamoDB 规则操作
在此过程中,您将配置 Amazon DynamoDB 规则操作,以将属性值更新中的数据插入到新的 DynamoDB 表中。
配置 DynamoDB 规则操作
-
在配置操作页面上,刷新表名称列表,然后选择新的 DynamoDB 表。
-
选择 C re ate role 以创建一个IAM角色,该角色向 AWS IoT 核心授予执行规则操作的访问权限。
-
输入角色名称,然后选择创建角色。
-
选择添加操作。
-
选择页面底部的 创建规则 以完成创建规则的过程。
将开始在 DynamoDB 表中显示您的演示资产数据。
步骤 5:在 DynamoDB 中浏览数据
在此过程中,您将在新的 Amazon DynamoDB 表中浏览演示资产的风速数据。
在 DynamoDB 中浏览资产数据
-
返回到打开了 DynamoDB 表的选项卡。
-
在您以前创建的表中,选择 项目 选项卡以查看表中的数据。如果您没有看到表中的行,请刷新页面。如果在几分钟后没有显示行,请参阅对规则进行故障排除 (DynamoDB)。
-
在表的一行中,选择编辑图标以展开数据。
-
选择 windspeed 结构旁边的箭头,以展开风速数据点列表。每个列表都反映了风电场演示发送到 AWS IoT SiteWise 的一批风速数据点。如果您设置规则操作以供自己使用,则可能需要使用不同的数据格式。有关更多信息,请参阅 查询资产属性通知消息。
现在您已经完成了教程,请禁用或删除该规则并删除您的 DynamoDB 表,以免产生额外费用。要清理您的资源,请参阅步骤 6:完成教程后清理资源。
步骤 6:完成教程后清理资源
完成本教程后,清理资源以避免产生额外费用。您的演示风电场资产将在您在创建演示时选择的时间结束时删除。您也可以手动删除演示。有关更多信息,请参阅 删除演 AWS IoT SiteWise 示。
使用以下过程禁用属性值更新通知(如果您没有删除演示)、禁用或删除您的 AWS IoT 规则,以及删除您的 DynamoDB 表。
禁用资产属性上的属性值更新通知
-
导航到 AWS IoT SiteWise 控制台
。 -
在左侧导航窗格中,选择 资产。
-
选择 Demo Wind Farm Asset 旁边的箭头,展开风电场资产的层次结构。
-
选择一个演示涡轮机,然后选择 编辑。
-
将Wind Speed酒店的通知状态更新为DISABLED。
-
选择页面底部的 保存资产。
-
对于每个演示涡轮机资产,重复步骤 4 至 6。
禁用或删除中的规则 AWS IoT Core
-
导航到 AWS IoT 控制台
。 -
在左侧导航窗格中,选择行动,然后选择规则。
-
选择您的规则上的菜单,然后选择 禁用 或 删除。
删除 DynamoDB 表
-
导航到 DynamoDB 控制台
。 -
在左侧导航窗格中,选择 表。
-
选择您之前创建的表 WindSpeedData。
-
选择 删除表。
-
在 删除表 对话框中,选择 删除。