从存储帐户 blob 读取和解析 Azure IoT 中心遥测

Question

我有一个 IoT 中心，其中有 2 个 IoT 设备都发送环境数据（温度和湿度）我创建了一个自定义端点并路由到我的 Azure 存储帐户，它保存在那里以便我可以回顾。问题是它发送原始遥测数据，包括奇怪的字符和类似的东西。我发现它是 CSV 格式的，但我仍然无法解析它。

我的问题是，我想直接从 blob 获取原始遥测数据，并使用 C# 将其解析为 SensorResult class。我想出了如何读取我只需要解析遥测数据的 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[=10=]enqueuedTime82018-06-29T18:34:10.4320000Z¨{"deviceId": "Raspberry Pi - Python","temperature": 28.801060,"humidity": 40.097196}82018-06-29T18:34:12.3400000Z temperatureAlert

第一行是遥测的 header，下面的所有行都是来自 IoT 设备的消息。

谢谢。

Answer 1

以下是 avro reader 的代码片段：

 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}");
       }
    }
 }

从存储帐户 blob 读取和解析 Azure IoT 中心遥测

Reading & parsing Azure IoT Hub Telemetry from a storage account blob

c#

azure

iot

azure-blob-storage

azure-iot-hub