Azure IoT Hub消息路由至Blob Storage：实现动态存储路径

可以通过IoT Hub原生的消息路由功能实现你需要的动态存储路径，不需要手动编写代码直接保存到Blob Storage，具体步骤如下：

1. 调整设备端消息发送逻辑，将messageParameter放入消息自定义属性 #

IoT Hub的Blob路由路径模板仅支持引用系统属性或消息自定义属性，无法直接解析消息体中的JSON字段。因此需要把你要作为路径节点的messageParameter（比如示例消息中的MessageId）提取出来，添加到消息的自定义属性中。

修改你的C#代码中创建消息的部分，添加自定义属性：

using var iotMessage = new Message(Encoding.UTF8.GetBytes(message))
{
  ContentEncoding = "utf-8",
  ContentType = "application/json",
};
// 从消息体提取目标参数，添加到自定义属性
var messageObj = JObject.Parse(message);
iotMessage.Properties.Add("MessageParameter", messageObj["MessageId"].ToString());

2. 配置Blob端点的动态路径模板 #

在Azure门户的IoT Hub中，找到已创建的Blob自定义端点，编辑以下配置：

• Blob名称格式设置为：{iothub}/{deviceId}/{MessageParameter}/{partition}/{YYYY}/{MM}/{DD}/{HH}/{mm}
  各变量说明：
  • {iothub}：自动填充IoT Hub的名称
  • {deviceId}：自动填充发送消息的设备ID
  • {MessageParameter}：对应你在代码中添加的自定义属性名，需完全一致
  • {partition}：自动填充IoT Hub的消息分区ID
  • {YYYY}/{MM}/{DD}/{HH}/{mm}：基于消息的入队时间自动生成时间层级路径

3. 验证效果 #

发送测试消息后，前往对应的Blob Storage容器查看，消息文件会按照你定义的动态路径结构存储。

备选方案（不推荐） #

如果无法修改设备端代码，必须直接使用消息体中的字段作为路径节点，可以通过Azure Functions触发IoT Hub消息，在Function中解析消息体字段，然后手动将消息写入Blob Storage并自定义路径。但这种方式性能和效率不如原生路由，仅作为特殊场景下的备选。

你的需求是后续快速读取特定设备、特定参数的消息，这种动态路径结构可以通过Blob的前缀搜索功能快速定位目标文件，完全匹配你的使用场景。

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