如何获取设备总数和发送到azure IoT hub的消息总数c＃

作者: 机器设备维修
发布时间: 2024-12-28 02:58:41 (5小时前)
转自：

3 条回复

0#
回复此人
没身份别烦我 | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”> <P> 你感兴趣的价值观是其中的一部分 <a href="https://docs.microsoft.com/en-us/azure/iot-hub/iot-hub-metrics" rel="nofollow noreferrer"> Azure IoT Hub指标 </A> 。基本上你可以获得他们的： </p> <UL> <LI> 使用 <a href="https://docs.microsoft.com/en-us/rest/api/monitor/metrics/list" rel="nofollow noreferrer"> REST API </A> 和 <a href="https://docs.microsoft.com/en-us/rest/api/monitor/metricdefinitions" rel="nofollow noreferrer"> 这里 </A> </LI> <LI> 添加的<strong> 诊断设置 </强> 对于Azure IoT Hub并选择以下目标之一 <EM> AllMetrics </EM> ： <OL> <LI> 归档的<strong> 事件驱动的存储 </强> 。使用具有输入blob绑定的订户（例如EventGridTrigger函数），可以在函数体中查询度量。 </LI> <LI> 或通过一个将指标推送到流媒体管道的<strong> 活动中心 </强> 并使用流分析作业来查询度量数据。 </LI> </醇> </LI> </UL> </DIV>

编辑
1#
回复此人
不易青年。 | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”> <P> 据我所知， </p> <P> 没有直接的方法来实际获得的<strong> <code> total number of devices </code> </强> 。或者，您可以执行的操作是创建一个List以及每当您使用添加设备时的<strong> <code> AddDeviceAsync </code> </强> 你应该把对象推到列表中。 </p> <P> 与消息总数相同，您应该创建自己的方法来更新值。 </p> <P> 以下代码应该有所帮助。 </p> <pre> <code> static async Task startClient(string IoTHub, string IoTDevicePrefix, int deviceNumber, string commonKey, int maxMessages, int messageDelaySeconds) { allClientStarted++; runningDevices++; string connectionString = "HostName=" + IoTHub + ";DeviceId=" + IoTDevicePrefix + deviceNumber + ";SharedAccessKey=" + commonKey; DeviceClient device = DeviceClient.CreateFromConnectionString(connectionString, Microsoft.Azure.Devices.Client.TransportType.Mqtt); await device.OpenAsync(); Random rnd = new Random(); int mycounter = 1; Console.WriteLine("Device " + IoTDevicePrefix + deviceNumber + " started"); while (mycounter <= maxMessages) { Thread.Sleep((messageDelaySeconds * 1000) + rnd.Next(1, 100)); string message = "{ \'loadTest\':\'True\', 'sequenceNumber': " + mycounter + ", \'SubmitTime\': \'" + DateTime.UtcNow + "\', \'randomValue\':" + rnd.Next(1, 4096 * 4096) + " }"; Microsoft.Azure.Devices.Client.Message IoTMessage = new Microsoft.Azure.Devices.Client.Message(Encoding.UTF8.GetBytes(message)); await device.SendEventAsync(IoTMessage); totalMessageSent++; mycounter++; } await device.CloseAsync(); Console.WriteLine("Device " + IoTDevicePrefix + deviceNumber + " ended"); runningDevices--; } static void createDevices(int number) { for (int i = 1; i <= number; i++) { var registryManager = RegistryManager.CreateFromConnectionString(iotHubConnectionString); Device mydevice = new Device(IoTDevicePrefix + i.ToString()); mydevice.Authentication = new AuthenticationMechanism(); mydevice.Authentication.SymmetricKey.PrimaryKey = commonKey; mydevice.Authentication.SymmetricKey.SecondaryKey = commonKey; try { registryManager.AddDeviceAsync(mydevice).Wait(); Console.WriteLine("Adding device: " + IoTDevicePrefix + i.ToString()); } catch (Exception er) { Console.WriteLine(" Error adding device: " + IoTDevicePrefix + i.ToString() + " error: " + er.InnerException.Message); } } } </code> </pre> </DIV>

编辑

登录后才能参与评论