本概述介绍了有关在典型 Azure 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 运行时上也可用,使流分析能够在边缘而不是云中处理数据。
若要了解详细信息,请参阅:
- 适用于 Azure Functions 的 Azure IoT 中心绑定
- 使用 Power BI 可视化 Azure IoT 中心的实时传感器数据
- 使用流分析、Azure Functions 和 SendGrid 通过自定义规则扩展 Azure IoT Central