将主eventmessage中的额外属性添加到IoT Hub时消息负载发生更改-（使用rest客户端）

Question

我正在使用Azure sdk和rest客户端向IoT中心发送事件。

我必须使用IoT中心路由功能，所以我在发送到IotHub之前将添加属性添加到主负载

案例1：使用Azure SDK发送数据

事件模型

RealTimeMachineData realTimeData = new RealTimeMachineData();
realTimeData.Date = DateTime.UtcNow;          
realTimeData.MachineCode = "M1";

当我在服务总线资源管理器中看到此消息时，我看起来像这样

{
  "MachineCode": "M1",
  "Date": "2017-08-27T10:05:22.7063498Z",  
}

案例2：当我通过RESTAPI调用做同样的事情时

 HttpClient client = new HttpClient();

 string deviceId = "DemoDevice";
 string baseUrl = "https://******.azure-devices.net/devices/" + deviceId + "/messages/events?api-version=2016-02-03";
 client.BaseAddress = new Uri(baseUrl);

 var sas = @"SharedAccessSignature sr=********";
 client.DefaultRequestHeaders.Add("Authorization", sas);
 client.DefaultRequestHeaders.Accept.Add(new  MediaTypeWithQualityHeaderValue("application/json"));

   var message1 = new Microsoft.Azure.Devices.Client.Message(Encoding.ASCII.GetBytes(realTimeData.ToString()));
 message1.Properties.Add("Source", "AiR");


 HttpResponseMessage response = client.PostAsJsonAsync(baseUrl, message1).Result;

以这种方式发送事件后，当我检查消息到服务总线资源管理器时，它看起来像

我必须在流分析中使用这种方法，因为当通过rest客户端发送时，负载变得不同，所以面临很多问题。

在通过Rest客户端发送时，我是否做错了什么，或者我必须做些不同的事情？

Answer 1

以下是修复方法：

var message1 = new StringContent(JsonConvert.SerializeObject(new RealTimeMachineData() { Date = DateTime.UtcNow, MachineCode = "M1" }));
client.DefaultRequestHeaders.Add("iothub-app-Source", "AiR");