我有多个 IOT 设备,它们发送每个值的串行更新,而不是同一 json 中所有值的完整更新。我得到一个
{
"4099": 0,
"device": "Unit1",
"TS": 1633539386
}
然后是一个新的有效载荷:
{
"4097": 232000,
"device": "Unit1",
"TS": 1633539386
}
另一个喜欢
{
"146": 9.249749,
"device": "Unit1",
"TS": 1633539382
}
属性 device 和 TS 始终可用,但属性是动态的 4099 值为 0、4097 值为 232000 和 146 值为 9.249749
我一直在研究https://aws.amazon.com/blogs/iot/designing-dataflows-for-multi-schema-messages-in-aws-iot-analytics/的类型 2 架构,这绝对是有道理的。然而,不清楚的是如何编写一个 SELECT 规则,它只给我出现属性的消息,以便我可以将它重定向到正确的管道。
或者这是否意味着做SELECT * FROM topic
一个管道然后以某种方式添加属性。似乎是一个非常基本的问题,我相信其他人已经遇到过但不是 100% 清楚在哪个阶段将属性之间的转移转换为公共数据存储。