如何从DynamoDB传感器数据表中获取所有属性的最新值集合？

针对你现在用latest条目存储所有传感器最新值的问题，我整理了几种更规范的解决方案，帮你摆脱需要传感器写两次数据的麻烦：

方法1：直接用PartiQL查询单个属性的最新值（适合属性不多的场景） #

如果你的传感器属性数量不多，可以针对每个属性单独执行查询，直接拿到该属性的最新非空值，完全不需要维护额外的latest条目。

比如查询空气质量的最新值：

SELECT AirQuality, TimeEpoch FROM "SensorTable" WHERE AirQuality IS NOT NULL ORDER BY TimeEpoch DESC LIMIT 1;

同理，温度、水温等属性都可以用类似的语句查询。这种方式逻辑简单，不需要额外的写入操作，唯一的缺点是属性多的话要执行多个查询，但小规模场景下完全够用。

方法2：用全局二级索引（GSI）优化全局最新值查询（适合数据量大的场景） #

如果你的传感器数据量较大，多次查询效率不高，可以创建一个GSI来优化全局最新值的获取：

• GSI设计：分区键用固定常量（比如GLOBAL_SENSOR_DATA），排序键用TimeEpoch（设置为降序排列），投影所有传感器属性。
• 写入逻辑：传感器只需要写入主表的条目（用新GUID作为Id），GSI会自动同步所有数据。
• 查询逻辑：查询GSI中PartitionKey = 'GLOBAL_SENSOR_DATA'的条目，按TimeEpoch从新到旧扫描，逐一收集每个属性的最新值——比如第一个条目有AirQuality，第二个条目有Temperature，直到你收集到所有需要的属性为止。

这种方式不需要客户端做额外写入，也避免了数据不一致的问题，查询效率比全表扫描高很多。

方法3：用DynamoDB Stream + Lambda自动维护聚合条目（保留latest条目的规范方案） #

如果你还是想保留Id = 'latest'的聚合条目，但不想让传感器写两次数据，可以把维护逻辑移到后端：

1. 启用主表的DynamoDB Stream，捕获所有写入/更新事件；
2. 写一个Lambda函数监听Stream事件：
   • 每次有新的传感器数据写入时，提取其中的非空属性；
   • 查询主表中现有的latest条目；
   • 用新数据的非空属性更新latest条目（只覆盖有值的字段，保留其他属性的现有值）；
   • 将更新后的latest条目写回主表。

这样传感器只需要写一次数据，Lambda自动帮你维护最新的聚合条目，既保留了你想要的便捷查询方式，又避免了客户端写两次的繁琐和数据不一致风险。

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