你当前正在访问 Microsoft Azure Global Edition 技术文档网站。 如果需要访问由世纪互联运营的 Microsoft Azure 中国技术文档网站，请访问 https://docs.azure.cn。
使用数据流处理和路由数据
你可通过数据流连接各种数据源并执行数据操作，从而简化数据路径的设置，以便移动、转换和扩充数据。 数据流组件是 Azure IoT 操作的一部分，部署为 Azure Arc 扩展。 数据流的配置是通过 Kubernetes 自定义资源定义 (CRD) 完成的。
可以为各种用例编写配置，例如：
- 转换数据并将其发送回 MQTT
- 转换数据并将其发送到云
- 在不转换的情况下将数据发送到云或边缘
数据流不限于部署 IoT 操作实例的区域。 可以使用数据流将数据发送到不同区域中的云终结点。
关键功能
下面是数据流的重要功能。
数据处理和路由
数据流支持引入、处理消息和将消息路由到指定的接收器。 可以指定：
- 源：从中引入消息的位置
- 目标：消息流向的位置
- 转换（可选）：数据处理操作的配置
转换功能
在处理阶段可以对数据应用转换来执行各种操作。 这些操作可能包括：
- 计算新属性：根据消息中的现有属性
- 重命名属性：标准化或阐明数据
- 转换单位：将值转换为不同的度量单位
- 标准化值：将属性值缩放到用户定义的范围
- 对数据进行上下文化处理：向消息添加引用数据以扩充和推动产生见解
配置和部署
配置是使用 Kubernetes CRD 指定的。 根据此配置，数据流操作员创建数据流实例，以确保高可用性和可靠性。
好处
- 简化设置：轻松连接数据源和目标。
- 灵活转换：执行各种数据操作。
- 可缩放配置：使用 Kubernetes CRD 实现可扩展且易于管理的配置。
- 高可用性：Kubernetes 本机资源可确保可靠性。
通过使用数据流，可以有效地管理数据路径。 可以确保准确发送、转换和扩充数据以满足操作需求。
架构注册表
架构注册表（Azure 设备注册表提供的一项功能）是云中和边缘的同步存储库。 架构注册表能够存储来自边缘资产的消息的定义，然后公开 API 以访问边缘上的这些架构。 OPC UA 连接器等南向连接器可以创建消息架构并将其添加到架构注册表，或者客户可以将架构上传到操作体验 Web UI。
数据流使用消息架构将消息转换为目标终结点预期的格式。
有关详细信息，请参阅了解消息架构。