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

Question

我生成一个IoT数据流并将其发送到亚马逊网络服务IoT核心。我有一个包含4列的DynamoDB：id、timestamp、data1和data2。data1是一个字符串，data2是一个映射(数据)。

然后我创建了一个Action。通过SQL，我抓取了IoT流上的所有字段，但是当我选择"Insert to DB“时，我只有两个字段，并且可以选择将所有数据写入一列。

​

​

是否可以将"Prg“中的数据之一写入其自己的字段？我是否必须创建一个Lambda函数，从地图中获取数据并将其写回DynamoDB back split？希望有更好的方法:)。

Answer 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

消息有效负载必须包含一个与表的主分区键匹配的根级键，以及一个与表的主排序键匹配的根级键。