你当前正在访问 Microsoft Azure Global Edition 技术文档网站。 如果需要访问由世纪互联运营的 Microsoft Azure 中国技术文档网站,请访问 https://docs.azure.cn

使用数据流处理和路由数据

重要

Azure Arc 启用的 Azure IoT 操作预览版目前处于预览状态。 不应在生产环境中使用此预览版软件。

在正式版推出后,你需要部署新的 Azure IoT 操作安装。 无法升级预览版安装。

有关 beta 版本、预览版或尚未正式发布的版本的 Azure 功能所适用的法律条款,请参阅 Microsoft Azure 预览版的补充使用条款

你可通过数据流连接各种数据源并执行数据操作,从而简化数据路径的设置,以便移动、转换和扩充数据。 数据流组件是 Azure IoT 操作的一部分,部署为 Azure Arc 扩展。 数据流的配置是通过 Kubernetes 自定义资源定义 (CRD) 完成的。

可以为各种用例编写配置,例如:

  • 转换数据并将其发送回 MQTT
  • 转换数据并将其发送到云
  • 在不转换的情况下将数据发送到云或边缘

数据流不限于部署 IoT 操作实例的区域。 可以使用数据流将数据发送到不同区域中的云终结点。

关键功能

下面是数据流的重要功能。

数据处理和路由

数据流支持引入、处理消息和将消息路由到指定的接收器。 可以指定:

  • 源:从中引入消息的位置
  • 目标:消息流向的位置
  • 转换(可选):数据处理操作的配置

转换功能

在处理阶段可以对数据应用转换来执行各种操作。 这些操作可能包括:

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

配置和部署

配置是使用 Kubernetes CRD 指定的。 根据此配置,数据流操作员创建数据流实例,以确保高可用性和可靠性。

好处

  • 简化设置:轻松连接数据源和目标。
  • 灵活转换:执行各种数据操作。
  • 可缩放配置:使用 Kubernetes CRD 实现可扩展且易于管理的配置。
  • 高可用性:Kubernetes 本机资源可确保可靠性。

通过使用数据流,可以有效地管理数据路径。 可以确保准确发送、转换和扩充数据以满足操作需求。

架构注册表

架构注册表(一项 Azure 设备注册表预览版提供的功能)是云中和边缘的同步存储库。 架构注册表能够存储来自边缘资产的消息的定义,然后公开 API 以访问边缘上的这些架构。 OPC UA 连接器等南向连接器可以创建消息架构并将其添加到架构注册表,或者客户可以将架构上传到操作体验 Web UI。

数据流在源点和目标点使用消息架构。 对于源,消息架构可以作为筛选器来标识要为数据流捕获的特定消息。 对于目标,消息架构有助于将消息转换为目标终结点预期的格式。

有关详细信息,请参阅了解消息架构