AWS IoT核心版：一条MQTT消息的多个DynamoDB插入

问题描述

我将AWS IoT Core与MQTT主题的DynamoDB规则结合使用。我的JSON有效负载看起来像这样：

{
  "car_id": 52,"timestamp": "2020-08-31 12:50:00","passengers": [
    {
      "passenger_id": 143,"passenger_name": "Foo"
    },{
      "passenger_id": 144,"passenger_name": "Bar"
    }
  ]
}

我希望IoT规则从此负载中将多个行插入DynamoDB表中，如下所示：

car_id    timestamp              passenger_id    passenger_name
52        2020-08-31 12:50:00    143             Foo
52        2020-08-31 12:50:00    144             Bar

即本质上是在外部数据（car_id，timestamp）和内部行（passengers）之间进行JOIN，然后为每个passenger向数据库插入一行。>

有关如何使用IoT规则sql做到这一点的任何建议？有可能吗？

注意：我已经考虑过将其分解为多条MQTT消息（每条passenger一条消息），但这冒着某些消息成功插入并插入某些消息的风险。我不希望插入任何记录，除非可以插入car的所有记录。

编辑：相关但独立的问题：是否可以将模板化字段用于可用于策略的${iot:Connection.Thing.ThingName}字段之类的东西？

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）