从HttpTrigger函数读取Azure IoT集线器遥测

Question

用例

我有一个物联网中心设备，它向物联网中心发送遥测数据。我想处理遥测数据，例如使用函数存储到数据库。

功能

我在VS2019中创建了以下函数并将其发布到Azure：

[FunctionName("HttpTrigger")]
public static async Task<HttpResponseMessage> Run(
[HttpTrigger(AuthorizationLevel.Anonymous, "post")]HttpRequestMessage req,
ILogger log)
{
    log.LogInformation("C# HTTP trigger function processed a request.");

    var messages = await req.Content.ReadAsAsync<JArray>();

    // If the request is for subscription validation, send back the validation code.
    if (messages.Count > 0 && string.Equals((string)messages[0]["eventType"],
        "Microsoft.EventGrid.SubscriptionValidationEvent",
        System.StringComparison.OrdinalIgnoreCase))
    {
        log.LogInformation("Validate request received");
        return req.CreateResponse<object>(new
        {
            validationResponse = messages[0]["data"]["validationCode"]
        });
    }

    // The request is not for subscription validation, so it's for one or more events.
    foreach (JObject message in messages)
    {
        // Handle one event.
        EventGridEvent eventGridEvent = message.ToObject<EventGridEvent>();
        log.LogInformation($"Subject: {eventGridEvent.Subject}");
        log.LogInformation($"Time: {eventGridEvent.EventTime}");
        log.LogInformation($"Event data: {eventGridEvent.Data.ToString()}");
    }

    return req.CreateResponse(HttpStatusCode.OK);
}

资料来源：https://docs.microsoft.com/en-us/azure/azure-functions/functions-bindings-event-grid#use-作为事件网格触发器的http触发器

事件订阅

在IoT Hub中，我使用Web钩子endpoint类型创建了一个触发函数的事件订阅。

问题

事件数据的主体似乎被加密了（？）：

{{
  "properties": {},
  "systemProperties": {
    "iothub-connection-device-id": "smartmeter",
    "iothub-connection-auth-method": "{\"scope\":\"device\",\"type\":\"sas\",\"issuer\":\"iothub\",\"acceptingIpFilterRule\":null}",
    "iothub-connection-auth-generation-id": "637057961942743477",
    "iothub-enqueuedtime": "2019-10-05T08:09:17.973Z",
    "iothub-message-source": "Telemetry"
  },
  "body": "eyJEYXRlVGltZSI6IjIwMTktMTAtMDVUMTA6MDk6MjkiLCJBY3R1YWxUYXJyaWYiOjEsIkFjdHVhbFBvd2VyRGVsaXZlcmVkIjoyNzEuMCwiVG90YWxFbGVjdHJpY2l0eURlbGl2ZXJlZFRhcnJpZjEiOjYwMTU1NzcuMCwiVG90YWxFbGVjdHJpY2l0eURlbGl2ZXJlZFRhcnJpZjIiOjYwMjc5NTIuMH0="
}}

虽然在云Shell中，我可以看到可读的数据。我还可以通过使用EventHubClient读取设备到云的消息来查看可读数据。网

我错过了什么？我如何解密尸体？

Answer 1

主体是Base64编码的，您可以使用https://docs.microsoft.com/en-us/dotnet/api/system.convert.frombase64string?view=netframework-4.8

这是您的邮件的可读正文：{“DateTime”：“2019-10-05T10:09:29”，“ActualArrif”：1，“ActualPowerDelivered”：271.0，“TotalElectricityDeliveredTerrif1”：6015577.0，“TotalElectricityDeliveredTerrif2”：6027952.0}

Answer 2

设备发送遥测数据时未指定内容类型和内容编码，请参阅systemProperties对象中缺少这些属性。

设备在发送遥测数据时需要填充这些系统属性，然后您将在事件消息中看到：

 "systemProperties":{
    "iothub-content-type":"application/json",
    "iothub-content-encoding":"utf-8",
    ...

事件的data.body将是json格式的文本。

这里有更多细节。