如何在断开状态上的Azure IoT设备上创建警报

Question

我有许多Azure IoT中央设备，其中2个设备经常断开连接，但是有人可以告诉我，如果将EVENT_STATUS断开超过5分钟，是否有办法创建真正的警报。

谢谢

Answer 1

在物联网中，中央规则只能应用于其关联模板和其报告属性的设备上的遥测值。设备连接/断开事件可通过数据导出获得，但是规则逻辑需要在Azure函数或逻辑应用程序，API等中运行该应用程序外部。

除非您具有心跳遥测作为布尔或数字，否则您无法从设备中进行heartemetry。使用内置规则功能推断断开事件的时间汇总计数。一种骇客和非理想的方法是计数在时间聚集窗口中出现的度量的次数，说明5分钟，如果其小于1，则将其推断为断开的设备。如果该度量标准的遥测频率高于聚合窗口，则这将行不通。

例如，如果在聚合窗口中的设备中一次接收湿度测量，则可以通过计算在5分钟时间聚集窗口中收到多少次来推断断开的设备。

Answer 2

以下屏幕片段是使用设备连接功能中使用设备连接事件的示例（ @umblyjay的答案），以适用于您的设备连接watchDog：

如上图所示，概念非常简单，当设备断开连接时，将带有时间表（5分钟）的看门狗消息（例如CloudEvents消息）发送到看门狗队列。在这种情况下，当设备在看门狗时间内重新连接时，该消息将从看门狗队列中删除，否则将在其TTL过期时将消息转发到警报队列。

请注意，设备连接事件是有限制的，请参见更多详细信息此处。

1. 数据导出：

1A。目标 - webhook：

1B。数据转换：

if .messageSource == "deviceConnectivity" then
{
  specversion:"1.0",
  id:.applicationId,
  source: .device.id,
  subject: ("/" + .applicationId + "/" + .device.id + "/" + .messageSource),
  type:.messageType,
  time:.enqueuedTime,
  dataschema:"#",
   data:{  
    reportedProperties: .device.properties.reported,
    cloudProperties: .device.cloudProperties
  }
}
else
  empty
end

2. httptrigger azure函数（版本3.x）：

    #r "Newtonsoft.Json"
    #r "..\\bin\\Microsoft.Azure.ServiceBus.dll"

    using System.Text;
    using System.Net;
    using Microsoft.Azure.ServiceBus;
    using Microsoft.Azure.ServiceBus.Core;
    using Microsoft.AspNetCore.Mvc;
    using Microsoft.Extensions.Primitives;
    using Newtonsoft.Json;
    using Newtonsoft.Json.Linq;

    public static async Task<IActionResult> Run(CloudEvent ce, IDictionary<string, string> headers, ILogger log)
    {
        log.LogInformation($"Device: {ce?.source}, Type: {ce?.type}, Subject: {ce?.subject}");

        string servicebusConnectionString = System.Environment.GetEnvironmentVariable("rk2016_SERVICEBUS"); 
        string queueName = headers.ContainsKey("queueName") ? headers["queueName"] : "iotc";
        double timeToLiveInMinutes = headers.ContainsKey("timeToLiveInMinutes") ? Convert.ToInt32(headers["timeToLiveInMinutes"]) : 5;
   
        if(ce != null && ce.subject.LastIndexOf("/deviceConnectivity") > 0)
        {
            // delete a device watchdog message
            var receiver = new MessageReceiver(servicebusConnectionString, queueName, ReceiveMode.PeekLock);
            var messages = await receiver.ReceiveAsync(100, TimeSpan.FromSeconds(2)); 
            if(messages != null)
            {  
                log.LogInformation($"Number of watchdogs {messages.Count()} in the queue '{queueName}'");
                foreach(var message in messages) 
                {          
                    string deviceId = message.UserProperties.ContainsKey("deviceId") ? message.UserProperties["deviceId"].ToString() : "";    
                    if(message.Label.StartsWith("Watchdog_") && ce.source == deviceId)  
                    {
                        await receiver.CompleteAsync(message.SystemProperties.LockToken);
                        log.LogInformation($"Watchdog deleted: Device={ce.source}, ttl={ce.time - message.SystemProperties.EnqueuedTimeUtc}.");
                        // break;
                    }
                };
            } 
            else 
            {
                log.LogInformation($"No Watchdog in the queue '{queueName}'.");
            }
            await receiver.CloseAsync();

            if(ce.type == "disconnected")
            {
                // create a device watchdog message
                var sender = new MessageSender(servicebusConnectionString, queueName);
                var message = new Message(Encoding.UTF8.GetBytes(JsonConvert.SerializeObject(ce)))
                {
                    ContentType = "application/json",
                    Label = $"Watchdog_{ce.source}",
                    TimeToLive = TimeSpan.FromMinutes(timeToLiveInMinutes)
                };
                message.UserProperties.Add("deviceId", ce.source);

                await sender.SendAsync(message);
                log.LogInformation($"Watchodg created: Device={ce.source}, time={ce.time}.");
            }
        }
        else
        {
        log.LogWarning("Wrong event message");
        }
  
        return await Task.FromResult<IActionResult>(new NoContentResult());
    }

    public class CloudEvent 
    {
        public string  specversion {get; set;}
        public string  type {get; set;}
        public string  source {get; set;}
        public string  id {get; set;}
        public DateTime  time {get; set;}
        public string  subject {get; set;}
        public JObject  data {get; set;}
    }
  

另外，我建议添加一个目标目标，例如带有CloudEvents Input Schema的Azure事件Grid自定义主题的端点，请参见以下屏幕snippet：

将上述httptrigger azure函数移动到AEG订阅者正在为您的解决方案提供一个pub/substimity，用于分发设备连接事件（例如过滤），等等。