如何将 IoT 流数据映射到索引的 Dynamo DB 列答案

【问题标题】：How to map IoT Stream Data to a indexed Dynamo DB column如何将 IoT 流数据映射到索引的 Dynamo DB 列
【发布时间】：2019-05-14 14:08:57
【问题描述】：

我生成一个 IoT 数据流并将其发送到 AWS IoT Core。我有一个包含 4 列的 DynamoDB：id、timestamp、data1 和 data2。 data1 是一个字符串，data2 是一个映射（数据）。

然后我创建了一个动作。我通过 SQL 获取 IoT Stream 上的所有字段，但是当我选择“插入到 DB”时，我只有 2 个字段和将所有数据写入一列的选项。

是否可以将“Prg”中的数据之一写入其自己的字段？我是否必须创建一个 Lambda 函数，从 Map 中获取数据并将其写入 DynamoDB 反向拆分？希望有更好的方法:)。

【问题讨论】：

【解决方案1】：

使用 DynamoDB v2 操作。 SELECT 语句的结果是写入 DynamoDB 表的对象。您必须在对象中包含分区键（和排序键，如果适用）。

你可能需要一个类似这样的 select 语句：

SELECT Device as id, timestamp() as timestamp, data1 as data1, Prg as data2 
FROM 'your/topic/here'

另外，请记住负载中的属性之一必须与目标表的主分区键同名。来自DynamoDB docs：

MQTT 消息负载必须包含与表的主分区键匹配的根级键和与表的主排序键匹配的根级键（如果已定义）。

【讨论】：