我有一个带有2个IoT设备的IoT Hub,它们都发送环境数据(温度和湿度)我创建了一个自定义端点并路由到我的Azure存储帐户,它被保存在那里我可以回顾一下.问题是它发送原始遥测数据,包括奇怪的字符和类似的东西.我发现它是CSV格式但我仍然无法解析它.
我的问题是,
我想直接从blob获取原始遥测数据,并使用C#将其解析为SensorResult类.
我想出了如何读取解析遥测数据所需的blob数据.但我无法弄明白这一部分.
原始遥测数据片段:
Objavro.codecnullavro.schemaÐ{"type":"record","name":"Message","namespace":"Microsoft.Azure.Devices","fields":[{"name":"EnqueuedTimeUtc","type":"string"},{"name":"Properties","type":{"type":"map","values":"string"}},{"name":"SystemProperties","type":{"type":"map","values":"string"}},{"name":"Body","type":["null","bytes"]}]}°ÈF¬êYâS:á…ð82018-06-29T18:34:10.4320000Z temperatureAlert
falsemessageIdmessage_0correlationIdcorrelation_0$connectionDeviceIdraspi(connectionAuthMethodœ{"scope":"device","type":"sas","issuer":"iothub","acceptingIpFilterRule":null}8connectionDeviceGenerationId$0enqueuedTime82018-06-29T18:34:10.4320000Z¨{"deviceId": "Raspberry Pi - Python","temperature": 28.801060,"humidity": 40.097196}82018-06-29T18:34:12.3400000Z temperatureAlert
第一行是遥测的标题,下面的所有行都只是来自物联网设备的消息.
谢谢.
解决方法:
以下是avro阅读器的代码片段:
using Microsoft.Hadoop.Avro.Container;
// ...
using (var reader = AvroContainer.CreateGenericReader(myBlob))
{
while (reader.MoveNext())
{
foreach (dynamic record in reader.Current.Objects)
{
var bodyText = Encoding.UTF8.GetString(record.Body);
log.Info($"AvroRecord = {bodyText}");
}
}
}
原文地址:https://codeday.me/bug/20190701/1346485.html
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。