0

我有多个 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% 清楚在哪个阶段将属性之间的转移转换为公共数据存储。

4

0 回答 0