0

我在 AWS IoT Analytics 中创建了以下内容：

  • 频道：Iot Core 主题模式 => $aws/things/+/shadow/update/accepted
  • 管道：从上一个通道馈送，从消息中选择属性
  • 用于保存消息的数据存储

通道的传入消息是影子更新/已接受，如下所示：

{
  "state": {
    "reported": {
      "active": false,
      "telemetry": {
        "temperature": 72,
        "humidity": 58,
        "occupancy": 28
      },
      "config": null
    }
  },
  "metadata": {
    "reported": {
      "active": {
        "timestamp": 1533059587
      },
      "telemetry": {
        "temperature": {
          "timestamp": 1533059587
        },
        "humidity": {
          "timestamp": 1533059587
        },
        "occupancy": {
          "timestamp": 1533059587
        }
      },
      "config": {
        "timestamp": 1533059587
      }
    }
  },
  "version": 89,
  "timestamp": 1533059587,
  "clientToken": "..."
}

我想从主题结构中提取事物名称，我在这里将其作为通配符：

$aws/things/+/shadow/update/accepted

有没有办法做到这一点，或者如果我想在这里使用它进行处理，它必须直接包含在消息正文中吗？

谢谢。

4

3 回答 3

0

显然，这是通过添加到将有效负载传输到 IOT Analytics 的 IOT Core Rule 中的 SQL 语句来丰富离开 IOT Core 的有效负载来完成的。

于 2018-08-08T17:43:58.510 回答
0

topic()在 SQL 语句中使用函数：

SELECT *, topic() AS topic FROM 'your/thing/+/topic'

https://docs.aws.amazon.com/en_us/iot/latest/developerguide/iot-substitution-templates.html

于 2019-06-05T20:30:27.580 回答
0

有一个公认的答案，但似乎错过了问题的这一部分

我想从主题结构中提取事物名称，我在这里将其作为通配符

$aws/things/+/shadow/update/accepted

我想我会为那些需要提取事物名称的人发布这个。如果要提取事物名称，则可以使用topic(3)它的计算结果为 3（这是事物名称在主题中的位置）。这是重新发布到主题的规则的示例，该主题使用从主题中检索到的事物名称。

{
  "sql": "SELECT state, version FROM '$aws/things/+/shadow/update/delta'",
  "ruleDisabled": false,
  "actions": [
    {
      "republish": {
        "topic": "${topic(3)}/delta",
        "roleArn": "arn:aws:iam::123456789012:role/my-iot-role"
      }
    }
  ]
}

这是上述示例的链接。" topic()" 返回完整的主题。这些被称为替代模板。

另外需要注意的一件重要事情（可能会导致一些不必要的调试时间）是重新发布到以 开头的保留主题，$使用$$（使用另一个 '$' 转义 '$'）。例如，要重新发布到设备影子主题$aws/things/MyThing/shadow/update，请将主题指定为$$aws/things/MyThing/shadow/update

于 2020-10-04T18:42:45.050 回答