AWS IoT Core规则查询双层嵌套MQTT JSON写入Timestream失败求助

错误根源分析 #

报错核心是维度值为空和度量无效，结合你的场景：

• 原SQL仅提取streams[0]单个数组元素，既没覆盖所有传感器数据，还可能因规则配置的维度/度量映射未正确关联字段，导致空值触发报错。
• 仅导入datetime成功，说明基础链路正常，但嵌套数组的字段提取和多记录生成逻辑存在问题。

修正步骤 #

1. 调整IoT Core规则SQL语句 #

使用UNNEST函数展开streams数组，将每个传感器条目转换为独立记录，确保每条记录都包含有效维度和度量值：

SELECT 
  datetime,
  stream.id AS sensorid,
  ROUND(stream.value) AS sensordata
FROM 'topicname'
CROSS JOIN UNNEST(payload.streams) AS t(stream)

• UNNEST(payload.streams)会把数组中的每个对象拆分为单独的行，一次性处理所有传感器数据
• 直接通过stream.id和stream.value提取嵌套字段，比get()函数更直观且不易出错

2. 检查Timestream动作配置 #

在IoT Core规则的Timestream动作中，确保以下配置正确：

• 数据库/表：确认目标数据库和表已创建，且规则执行角色有写入权限
• 时间戳：选择「使用消息中的时间戳」，字段填写datetime（对应SQL输出的字段）
• 维度：添加维度，名称设为sensorid，值选择「从SQL查询结果中选择」，字段填写sensorid
• 度量：添加度量，名称设为sensordata，值选择「从SQL查询结果中选择」，字段填写sensordata，类型选择BIGINT（因用ROUND转换为整数）

3. 验证SQL输出 #

在IoT Core规则的SQL测试界面，输入你提供的MQTT消息，测试上述SQL是否能输出如下格式的多条有效记录：

[
  {"datetime": "2023-06-20T08:49:00Z", "sensorid": "RS62", "sensordata": 885},
  {"datetime": "2023-06-20T08:49:00Z", "sensorid": "S55", "sensordata": 36},
  {"datetime": "2023-06-20T08:49:00Z", "sensorid": "S56", "sensordata": 1},
  ...
]

确保每条记录的sensorid和sensordata都非空。

4. 权限确认 #

检查IoT Core规则执行角色的权限策略，确保包含timestream:WriteRecords动作，且目标Timestream表的资源策略允许该角色写入。

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