IoT 解决方案中的消息处理

本概述介绍了有关在典型 Azure IoT 解决方案中处理从资产和设备发送的消息的关键概念。 每个部分都包含指向提供进一步详细信息和指导的内容的链接。

下图显示了 典型基于边缘的 IoT 解决方案中组件的概要视图。 本文重点介绍基于边缘的 IoT 解决方案的消息处理组件。

显示高级基于边缘的 IoT 解决方案体系结构的示意图,其中突出显示了消息处理区域。

在 Azure IoT 中,消息处理是指路由和扩充资产和设备发送的消息等过程。 这些进程用于控制通过 IoT 解决方案的消息流,以及向消息添加其他信息。

路由消息

若要将消息从资产路由到各种终结点,Azure IoT 操作将使用 数据流。 目标终结点可能位于云中或边缘。 可用目标终结点的列表包括:

终结点类型 DESCRIPTION
MQTT 适用于使用 MQTT 代理的双向消息传送,包括内置到 Azure IoT 操作和事件网格的消息传送。
卡 夫 卡 适用于使用 Kafka 代理(包括 Azure 事件中心)的双向消息传送。
Data Lake 适用将数据上传到 Azure Data Lake Gen2 存储帐户。
Microsoft Fabric OneLake 将数据上传到 Microsoft Fabric OneLake 湖屋。
Azure 数据资源管理器 将数据上传到 Azure 数据资源管理器数据库。
本地存储 若要将数据发送到本地可用的永久性卷,可选择性地使用 Azure Arc 启用的 Azure 容器存储进行配置。

操作体验 Web UI 提供一个无代码环境,用于构建和运行数据流。

为了增强路由到终结点的数据的安全性,云/边缘 同步机密 用于数据流终结点进行身份验证。

虽然数据流允许在边缘配置路由,但也可以在云中定义路由。 如果数据流将消息传送到 Azure 事件网格,则可以使用其路由功能来确定消息的发送位置。

若要了解详细信息,请参阅使用数据流处理和路由数据

扩充、转换和处理消息

扩充和转换可以在处理阶段应用于数据,以执行各种作。 这些操作可能包括:

  • 计算新属性:根据消息中的现有属性
  • 重命名属性:标准化或阐明数据
  • 转换单位:将值转换为不同的度量单位
  • 标准化值:将属性值缩放到用户定义的范围
  • 对数据进行背景化处理:向消息添加引用数据以扩充和驱动见解

架构注册表存储来自资产的消息的架构。 数据流使用这些消息架构从各种格式解码消息,以便数据流可以处理它们。

操作体验 Web UI 提供一个无代码环境,用于在数据流中生成和运行转换。

若要了解详细信息,请参阅 使用数据流扩充数据

在 Azure IoT作中,可以将自己的高可用性边缘应用程序部署到 Kubernetes 群集。 边缘应用程序可以与内置的 MQTT 中转站交互,以便:

  • 在 MQTT 消息上使用自定义消息处理逻辑。
  • 生成要在 Edge 运行的自定义应用程序逻辑。
  • 运行 Edge AI 模型,以便在生成数据源进行实时数据处理和决策,从而减少延迟和带宽使用。

若要了解详细信息,请参阅 开发适用于 Azure IoT Operations MQTT 中转站的高可用性应用程序

其他云服务

可以使用其他云服务来处理来自资产和设备的消息。

使用 Azure IoT 操作中的数据流终结点可以连接到云服务,以便从资产发送和接收数据。 数据流终结点是数据流的连接点。

若要了解详细信息,请参阅:

在 IoT 中心和 IoT Central 中,可以将消息路由到其他服务。 例如,可以将消息转发到 Azure 流分析 ,以分析和处理大量流数据或 Azure Functions 以运行代码以响应事件。 流分析在 Azure IoT Edge 运行时上也可用,使流分析能够在边缘而不是云中处理数据。

若要了解详细信息,请参阅: