无法修改设备及消息结构时，如何强制Azure IoT Hub将遥测消息以application/json类型存储至Blob存储

由于你无法修改设备及消息结构，且已将自定义存储端点的编码设为JSON，以下是几种可行的方案，按推荐优先级排序：

1. 利用IoT Hub路由的消息转换（Message Transformations）直接修改Content-Type #

这是最直接的方案，无需额外组件，通过IoT Hub的内置功能在消息路由到Blob存储前修改系统属性：

• 登录Azure门户，进入你的IoT Hub
• 导航到路由页面，找到指向Blob存储的目标路由规则
• 点击该规则，在消息转换区域启用转换功能
• 在转换编辑器中，使用JSON表达式设置系统属性的contentType：

  {
    "$set": {
      "$sys.contentType": "application/json"
    }
  }
  

• 保存规则后，后续路由到Blob存储的消息会被自动设置Content-Type: application/json属性

注意：消息转换功能仅支持IoT Hub标准层（S1/S2/S3），免费层无法使用该特性。

2. 通过Azure Functions作为中间层处理消息 #

如果你的IoT Hub是免费层，或者需要更灵活的处理逻辑，可以通过Azure Functions中转消息：

• 创建一个Azure Function，选择IoT Hub触发器，关联你的IoT Hub事件中心兼容端点
• 在Function代码中，接收遥测消息后手动设置Content-Type属性，再将消息写入Blob存储：
  示例C#代码片段：

  public static async Task Run([EventHubTrigger("messages/events", Connection = "IoTHubConnectionString")] EventData message,
      [Blob("your-container-name/{datetime:yyyy-MM-dd}/{datetime:HH}/{rand-guid}.json", FileAccess.Write)] CloudBlockBlob outputBlob)
  {
      // 设置目标Content-Type
      outputBlob.Properties.ContentType = "application/json";
      // 写入消息内容并更新Blob属性
      await outputBlob.UploadFromByteArrayAsync(message.Body.Array, 0, message.Body.Array.Length);
      await outputBlob.SetPropertiesAsync();
  }
  

• 修改IoT Hub的路由规则，将遥测消息路由到这个Function的触发器对应的事件中心端点，而非直接指向Blob存储

3. 事后修改Blob的Content-Type属性 #

如果上述两种方案都无法实施，还可以通过Blob存储的事件触发自动化流程来修正已存储文件的属性：

• 进入你的Blob存储账户，导航到事件页面，创建事件订阅，触发条件选择「Blob创建完成」
• 将事件订阅的端点指向Azure Logic Apps或Azure Functions
• 在Logic Apps/Functions中编写逻辑：获取新创建的Blob，将其Content-Type属性修改为application/json

这种方案属于事后修正，会存在短暂时间窗口内Blob的Content-Type仍为默认值的情况，适合对实时性要求不高的场景

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