Azure IoT Edge消息经IoT Hub至Stream Analytics部分丢失排查咨询

一、消息丢失排查步骤 #

• 检查IoT Hub路由与指标
  先确认IoT Hub的消息路由是否正确指向Stream Analytics输入对应的端点，重点看路由的筛选规则——如果设置了属性或内容过滤，丢失的消息可能不符合规则被拦截。同时查看IoT Hub监控指标里的「消息已送达」「消息已路由」计数，和设备发送的消息数做对比，判断是否在IoT Hub环节就出现丢失。
• 验证Stream Analytics输入配置
  确认输入的事件序列化格式和设备发送的消息格式完全匹配（比如设备发JSON，输入不能设成CSV），格式不匹配会直接导致消息被丢弃。另外检查输入的起始时间设置，如果起始时间晚于设备发消息的时间，早期消息不会出现在查询预览里。同时查看Stream Analytics监控指标的「输入事件数」「输入事件丢弃数」，有丢弃数就说明输入环节存在格式或权限问题。
• 排查Stream Analytics查询逻辑
  检查查询语句是否包含过滤条件（比如WHERE子句），是否不小心过滤掉了部分消息；如果用了窗口函数（比如TumblingWindow），预览时窗口未闭合的话，部分消息还不会被计算到结果里。
• 中间环节验证
  给IoT Hub加一条临时路由，把设备消息同时转发到Blob存储，对比Blob里的完整消息和Stream Analytics查询到的内容：如果Blob里有但Stream Analytics没有，问题出在Stream Analytics的输入或查询；如果Blob里也没有，问题就出在IoT Hub的路由配置。

二、Stream Analytics前确认数据类型的方法 #

完全可以在Stream Analytics之前确认数据类型，常用方法有：

• IoT Hub设备资源管理器查看
  在IoT Hub的「设备资源管理器」中选中目标设备，直接查看从设备到云的消息内容，JSON格式的消息能直接看到每个字段的类型（字符串、数字、布尔等）。
• 通过CLI/脚本导出消息分析
  用Azure CLI或PowerShell命令导出IoT Hub的历史消息，或者调用IoT Hub的REST API获取消息内容，直接分析字段的数据类型。
• 临时路由到存储验证
  配置临时路由将消息转发到Blob或Table存储，下载消息文件后直接查看内容，直观确认每个字段的数据类型，这种方式适合批量消息的验证。

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