使用 Amazon IoT Core 规则提取数据

您可以使用 Amazon IoT Core 中的规则，将数据从 Amazon IoT 事物和其他 Amazon 服务发送到 Amazon IoT SiteWise。这些规则转换 MQTT 消息并执行与 Amazon 服务交互的操作。Amazon IoT SiteWise 规则操作将消息数据从 Amazon IoT SiteWise API 转发到 BatchPutAssetPropertyValue 操作。有关更多信息，请参阅Amazon IoT开发者指南中的规则和Amazon IoT SiteWise操作。

您可以按照教程逐步执行设置规则的步骤，该规则从 Amazon IoT 事物通过其设备影子提取数据。有关更多信息，请参阅将数据从 Amazon IoT 事物提取到 Amazon IoT SiteWise：

您还可以将数据从 Amazon IoT SiteWise 发送到其他 Amazon 服务。有关更多信息，请参阅与其他 Amazon 服务交互：

授予 Amazon IoT 所需的访问权限

您可以使用 IAM 角色来控制每个规则可以访问的Amazon资源。在创建规则之前，您必须创建一个 IAM 角色，并对其应用允许访问所需Amazon资源的策略。 Amazon IoT在运行规则时担任此角色。

如果您在Amazon IoT控制台中创建规则操作，则可以选择根资产来创建有权访问所选资产层次结构的角色。有关如何为规则手动定义角色的更多信息，请参阅Amazon IoT《Amazon IoT开发者指南》中的授予所需访问权限和传递角色权限。

对于 Amazon IoT SiteWise 规则操作，您必须定义一个角色，该角色允许 iotsitewise:BatchPutAssetPropertyValue 访问规则向其发送数据的资产属性。为了提高安全性，您可以在 Condition 属性中指定 Amazon IoT SiteWise 资产层次结构路径。

以下示例信任策略允许访问特定资产及其子级。

{
  "Version": "2012-10-17",
  "Statement": [
    {
      "Effect": "Allow",
      "Action": "iotsitewise:BatchPutAssetPropertyValue",
      "Resource": "*",
      "Condition": {
        "StringLike": {
          "iotsitewise:assetHierarchyPath": [
            "/root node asset ID",
            "/root node asset ID/*"
          ]
        }
      }
    }
  ]
}

您可以从策略中删除 Condition，以允许访问您的所有资产。以下示例信任策略允许访问您在当前区域中的所有资产。

{
  "Version": "2012-10-17",
  "Statement": [
    {
      "Effect": "Allow",
      "Action": "iotsitewise:BatchPutAssetPropertyValue",
      "Resource": "*"
    }
  ]
}

配置 Amazon IoT SiteWise 规则操作

Amazon IoT SiteWise规则操作将启动规则的 MQTT 消息中的数据发送到中的资产属性的数据Amazon IoT SiteWise。您可以同时将多个数据条目上传到不同的资产属性，这样就可以在一条消息中发送设备的所有传感器的更新。您还可以为每个数据条目一次上传多个数据点。

对于规则操作中的每个数据条目，您可以标识资产属性，并为该资产属性指定每个数据点的时间戳、质量和值。规则操作要求所有参数均为字符串。

要在条目中标识资产属性，可以指定以下项之一：

对于每个条目中的时间戳，您可以使用设备报告的时间戳或提供的时间戳Amazon IoT Core。时间戳有两个参数：

您可以使用操作中的多个参数的替代模板来执行计算、调用函数和从消息负载中提取值。有关更多信息，请参阅《Amazon IoT开发者指南》中的替代模板。

为未报告准确时间的设备获取时间戳

如果您的传感器或设备未报告准确的时间数据，则可以使用 timestamp () 从Amazon IoT规则引擎获取当前 Unix 纪元时间。此函数以毫秒为单位输出时间，因此必须将该值转换为以秒为单位的时间和以纳秒为单位的偏移量。为此，请使用以下转换：

转换字符串格式的时间戳

如果您的传感器或设备以字符串格式报告时间数据（例如，2020-03-03T14:57:14.699Z），则可以使用 time_to_epoch（字符串、字符串）。此函数将时间戳和格式模式作为参数输入，并以毫秒为单位输出时间。然后，必须将时间转换为以秒为单位的时间，并将偏移量以纳秒为单位。为此，请使用以下转换：

转换纳秒精度的时间戳字符串

如果您的设备以纳秒精度的字符串格式发送时间戳信息（例如，2020-03-03T14:57:14.699728491Z），请使用以下步骤配置您的规则操作。您可以创建一个Amazon Lambda函数，将字符串中的时间戳转换为以秒为单位的时间 (timeInSeconds) 和 nanos (offsetInNanos) 中的偏移量。然后，你可以在规则操作参数中使用 aws_lambda（functiinputJson SON）来调用该 Lambda 函数并在规则中使用输出。

规则配置示例

本节包含示例规则配置，您可以使用这些配置通过Amazon IoT SiteWise操作创建规则。

aws iot create-topic-rule \
  --rule-name SiteWiseWindFarmRule \
  --topic-rule-payload file://sitewise-rule-payload.json

{
  "sql": "SELECT * FROM '/company/windfarm/+/turbine/+/+' WHERE type = 'double'",
  "description": "Sends data to the wind turbine asset property with the same alias as the topic",
  "ruleDisabled": false,
  "awsIotSqlVersion": "2016-03-23",
  "actions": [
    {
      "iotSiteWise": {
        "putAssetPropertyValueEntries": [
          {
            "propertyAlias": "${topic()}",
            "propertyValues": [
              {
                "timestamp": {
                  "timeInSeconds": "${timeInSeconds}"
                },
                "value": {
                  "doubleValue": "${value}"
                }
              }
            ]
          }
        ],
        "roleArn": "arn:aws:iam::account-id:role/MySiteWiseActionRole"
      }
    }
  ]
}

{
  "type": "double",
  "value": "38.3",
  "timeInSeconds": "1581368533"
}

aws iot create-topic-rule \
  --rule-name SiteWiseAssetPropertyRule \
  --topic-rule-payload file://sitewise-rule-payload.json

{
  "sql": "SELECT * FROM 'my/asset/property/topic'",
  "description": "Sends device data to an asset property",
  "ruleDisabled": false,
  "awsIotSqlVersion": "2016-03-23",
  "actions": [
    {
      "iotSiteWise": {
        "putAssetPropertyValueEntries": [
          {
            "assetId": "a1b2c3d4-5678-90ab-cdef-22222EXAMPLE",
            "propertyId": "a1b2c3d4-5678-90ab-cdef-33333EXAMPLE",
            "propertyValues": [
              {
                "timestamp": {
                  "timeInSeconds": "${floor(timestamp() / 1E3)}",
                  "offsetInNanos": "${(timestamp() % 1E3) * 1E6}"
                },
                "value": {
                  "doubleValue": "${value}"
                }
              }
            ]
          }
        ],
        "roleArn": "arn:aws:iam::account-id:role/MySiteWiseActionRole"
      }
    }
  ]
}

{
  "type": "double",
  "value": "38.3"
}

通过基本提取降低成本

Amazon IoT Core 提供了一项名为“基本提取”的功能，您可以使用该功能通过 Amazon IoT Core 发送数据，而不会产生 Amazon IoT 消息发送成本。基本提取功能通过从提取路径中删除发布/订阅消息代理来优化大量数据提取工作负载的数据流。如果您知道消息应该路由到哪些规则，则可以使用“基本提取”。

要使用基本提取，您可以使用特殊主题 $aws/rules/rule-name，直接将消息发送到特定规则。例如，要向名为 SiteWiseWindFarmRule 的规则发送消息，您可以向主题 $aws/rules/SiteWiseWindFarmRule 发送消息。

如果您的规则操作使用包含 topic(Decimal) 的替换模板，则可以在“基本提取”特殊主题的末尾传递原始主题，例如 $aws/rules/rule-name/original-topic。例如，要将基本提取与之前部分中的风电场属性别名示例结合使用，您可以向以下主题发送消息。

$aws/rules/SiteWiseWindFarmRule//company/windfarm/3/turbine/7/temperature

有关更多信息，请参阅《Amazon IoT开发者指南》中的 “通过基本采集降低消息传送成本”。

Amazon IoT SiteWise 规则操作问题排查

要对中的Amazon IoT SiteWise规则操作进行故障排除Amazon IoT Core，您可以配置 CloudWatch 日志，也可以为规则配置重新发布错误操作。有关更多信息，请参阅Amazon IoT SiteWise 规则操作故障排除：