如何通过AWS IoT与DynamoDBv2将多条消息存储到同一行

完全可以实现，你当前遇到的覆盖问题是因为AWS IoT Core的DynamoDBv2动作默认使用PUT_ITEM操作，相同分区键的新条目会全量覆盖旧条目所有属性，只要修改操作配置即可实现属性增量更新：

具体修改步骤 #

1. 进入你配置的IoT Core规则编辑页面，找到关联的DynamoDBv2动作配置项
2. 将操作类型从默认的PUT_ITEM修改为UPDATE_ITEM
3. 主键映射保持原有配置即可：分区键deviceId对应取值${deviceId}
4. 原有规则查询语句SELECT *, topic(2) AS deviceId FROM 'device/+'无需调整

修改完成后再测试：

• 发布第一条消息{"deviceId": "Name1","temperature":25}时，DynamoDB会新增对应条目，写入temperature属性
• 发布第二条消息{"deviceId": "Name1","setpoint":23}时，DynamoDB会在同一条目下新增setpoint属性，不会删除已有的temperature属性，最终得到你需要的合并存储效果

补充说明 #

如果后续发布的消息包含已存在的属性，新属性值会自动覆盖旧值，符合常规增量更新逻辑。如果你需要保留每一条消息的历史记录而非合并属性，可以给DynamoDB表新增一个时间戳类型的排序键，在IoT规则里把消息发布时间作为排序键值写入，这样每条消息都会作为独立条目存储不会互相覆盖。

内容的提问来源于stack exchange，提问作者Nakamoto