- html - 出于某种原因,IE8 对我的 Sass 文件中继承的 html5 CSS 不友好?
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景?
我有一个 IoT 设备 (ESP32),每 x 秒向 IoT 中心(免费层)发送数据包。每个数据包都包含一个整数属性PacketID,每次发送新数据包时该属性都会递增,从1开始,依此类推。当 IoT 中心收到数据时,将调用 Azure IoT 中心触发器(托管在门户上)并进一步处理数据 - 首先插入到 CosmosDB(从 StorageQueue 触发器),然后作为消息发送到 SignalR 服务(从另一个 StorageQueue 触发器) )并连接到客户端 Web 应用程序。
IoT 中心触发器如下所示:
[FunctionName("FramesPacketAdd_IoTHubTrigger")]
public async Task Run(
[IoTHubTrigger("messages/events", Connection = "IoTHubConnectionString")] EventData message, ILogger _logger,
[Queue("dbinsert-frames-packet-queue", Connection = "AzureStorageAccountConnectionString")] IAsyncCollector<FramesPacket> dbInsertFramesPacketQueue,
[Queue("eventdata-parse-error-queue", Connection = "AzureStorageAccountConnectionString")] IAsyncCollector<string> eventDataParseErrorQueue)
{
try
{
_logger.LogInformation($"C# IoT Hub trigger function FramesPacketAdd processed a message: {Encoding.UTF8.GetString(message.Body.Array)}");
string messageBody = Encoding.UTF8.GetString(message.Body.Array);
var jsonObj = JsonConvert.DeserializeObject<FramesPacket>(messageBody);
var framesPacket = new FramesPacket
{
PacketID = jsonObj.PacketID,
SessionID = jsonObj.SessionID,
DeviceID = jsonObj.DeviceID,
Frames = jsonObj.Frames
};
await dbInsertFramesPacketQueue.AddAsync(framesPacket);
}
catch (Exception ex)
{
await eventDataParseErrorQueue.AddAsync($"[IoTHubTrigger] function [FramesPacketAdd] caught exception: {ex.Message} \nStackTrace: {ex.StackTrace} \nJSON: {Encoding.UTF8.GetString(message.Body.Array)}");
_logger.LogError($"[IoTHubTrigger] function [FramesPacketAdd_IoTHubTrigger] caught exception: {ex.Message} \nStackTrace: {ex.StackTrace} \nJSON: {Encoding.UTF8.GetString(message.Body.Array)}");
}
}
问题是,当数据包发送速度很快时,例如每个数据包之间间隔 200 毫秒,IoT 中心接收到的数据完全无序,这意味着有时数据包 #7 和 #8 在数据包 #1、# 之前被接收和处理。 2 和 #3,这对于我的客户端应用程序来说是一个问题,因为它依赖于按照从 ESP32 芯片发送的相同顺序接收数据包。我尝试以 1 秒的延迟发送每个数据包,但问题仍然存在,但它似乎只影响前三个数据包 - 有时它们按 3、1、2 的顺序接收,其余的顺序正确。更长的延迟似乎可以完全消除这个问题。我确实相信这是因为函数/触发器的异步性质?最后,我希望能够相对较快地发送它们,每个之间有 200-500 毫秒的延迟。
我对 Azure IoT 中心非常陌生,我的问题是,是否可以在门户端执行某些操作来确保按正确的顺序接收数据包,或者这是此类方法和此类情况的限制接收到数据后需要处理,可能在调用 IoT 中心触发器后使用存储队列或服务总线?
我希望我的问题有意义,否则我非常乐意提供更多详细信息。
提前致谢。
最佳答案
以下是两种可能的路径:
1.使用 EventHub 触发的 Azure Function 处理来自 IoT 中心的事件中心兼容终结点的消息。
保证来自特定设备的每条消息都将发送到同一分区。
分区中的消息是有序的,因此您需要的是每个分区的事件处理器。
您可以使用 Azure 函数来实现此目的,在本例中,Azure 函数所做的是为每个分区创建租约,这使得每个分区只有一个 Azure 函数实例。这意味着如果您有 10 个分区,则将有 10 个 Azure 函数实例处理来自每个分区的消息。现在您要做的是确保在Azure函数中,您按顺序处理消息批处理,例如:
[FunctionName("EventHubTrigger")]
public static async Task RunAsync([EventHubTrigger("ordered", Connection = "EventHub")] EventData[] eventDataSet, TraceWriter log)
{
log.Info($"Triggered batch of size {eventDataSet.Length}");
//processing event by event
foreach (var eventData in eventDataSet) {
try
{
// process the event here
}
catch
{
// handle event exception
}
}
}
这里,在 foreach 循环之前,除了 native 行为之外,您还可以根据 sequenceNumber
(如果您要发送它)对 eventDataSet
进行排序,仅用于案例。
这是blog .
2.第二种方法非常相似,是关于使用服务总线队列和 session ,如以下代码示例所示:
public async Task Run(
[ServiceBusTrigger("queue", Connection = "ServiceBusConnectionString", IsSessionsEnabled = true)]Message message,
ILogger log)
{
log.LogInformation($"C# ServiceBus queue trigger function processed message: {Encoding.UTF8.GetString(message.Body)}");
// process the message here
}
这是blog也是如此。
需要注意的重要一点是,如果任何 Azure 函数实例(在第一种情况下)失败,租约将被续订,并且它可能会处理某些消息两次。如果这是一个问题,那么您应该选择第二种情况。
关于Azure IoT Hub触发器按顺序处理数据,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/64917114/
我有一个用例,我需要将文件从 Azure blob 位置下载到在 IoT 中心注册的 IoT 设备。 在本例中,我将向 IoT 设备发送指令(通过 IoT 中心),以将文件从 Azure blob 位
Azure 物联网套件和物联网中心之间的区别及其用法是什么?请告诉我 .NET 在物联网中如何工作的基础知识。感谢您的帮助! 最佳答案 Azure IoT Suite 只是 IoT Hub 的加速器。
我订阅 Aws Iot 主题; 12345678/state 我尝试编写一条规则来获取该主题的有效负载 12345678/shadow/update 我按照以下步骤编写了我的规则; 我的查询字符串是
使用与 Azure IoT Explorer 中输入的相同 DTDL 模型创建 Azure IoT 中心和数字孪生资源后,Explorer 表示设备未被识别为 IoT P&P 设备。 DTDL 模型使
我似乎无法在任何地方获取此信息。我想知道如果发送此消息的设备未在 IoT 中心注册,遥测消息会发生什么情况。 这是因为我发现来自 IoT 中心中未注册设备的一些消息正在被处理到内置事件中心,并在内置事
我们已经使用 AWS-IoT 服务创建了一个事物。我们已经针对该特定事物创建了一个主题。订阅者已订阅该主题,发布者正在向该主题发送消息。 以下是发布者消息传递顺序: message 0 message
首先,抱歉我的英语水平。 我是一名来自韩国的高中生,正在使用 Azure IoT 中心进行项目。 我正在开发一个项目,其中树莓派设备将值发送到 Azure IoT 中心。我想将此数据保存在 Azure
iotedge logs 暴露的日志在哪里?命令存储? 通常在 Linux 上会在哪里? 最佳答案 只需执行 docker inspect 及以下 LogPath您将获得容器的当前位置。例如。对于
我打算使用 IoT 中心利用其双向功能更新我的 Edison 设备的固件,尽管我不确定在哪里可以找到有关如何操作的详细说明。我在该主题上找到的唯一信息是 HERE但没有详细说明如何做到这一点,更多的是
我想知道 IoT Central 将存储我的遥测数据多长时间。感谢您提前的每一个回答! 最佳答案 定价页面注明数据保留期为 30 天。 https://azure.microsoft.com/en-a
我的目标是使用 serverless framework 在 AWS 上创建一个系统让多个 IoT 设备将 JSON 有效负载发送到 AWS IoT,然后将其保存到 DynamoDB。 除了创建 EC
正如主题行所示,我想知道 Azure IoT 中心作业和 Azure 自动设备管理之间到底有什么区别。 今年早些时候,我使用 IoT 中心作业为 IoT 中心中的所有设备设计了固件更新,在更多地了解
我想通过数据记录器将数据发送到 MS Azure 或 AWS IoT 平台。我该怎么做? 最佳答案 Azure IoT 中心公开设备端点: Device endpoints For each devi
我正在将图像从 Raspberry Pi 发送到 Cloud IoT Core。这是可行的,但我现在意识到,当将其存储在 Google Cloud Storage 中时,我还需要文件的文件名(或我添加
我想编写一个 C# 应用程序,它从 IoT Edge hub 中获取消息。在将它们发送到 IoT 中心之前,先在 IoT Edge 设备上执行此操作。 我想为我的 IoT 边缘模块编写端到端测试。为此
我不明白什么时候 Azure IoT 中心可以优于 Azure IoT Central。从迄今为止的读数来看,IoTcentral 在所有方面似乎都更好。任何人都可以向我解释一下 IoT hub 在哪
我想编写一个 C# 应用程序,它从 IoT Edge hub 中获取消息。在将它们发送到 IoT 中心之前,先在 IoT Edge 设备上执行此操作。 我想为我的 IoT 边缘模块编写端到端测试。为此
我不明白什么时候 Azure IoT 中心可以优于 Azure IoT Central。从迄今为止的读数来看,IoTcentral 在所有方面似乎都更好。任何人都可以向我解释一下 IoT hub 在哪
我正在 .NET Core 3 中开发 Web 应用程序,我正在使用 Microsoft.Azure.Devices.RegistryManager 访问 Azure Iot 中心。 当我调用 reg
我们将 IoT Edge 与 DPS 结合使用,我们需要在配置时提供额外信息,以便在正确的 IoT 中心配置设备并提供特定的孪生信息。我们注意到 DPS 提供了一个 solution for this
我是一名优秀的程序员,十分优秀!