与 Azure 流分析中的架构注册表集成

Azure 事件中心托管架构注册表,该 注册表 充当架构的集中式存储库。 通过与架构注册表的集成,Azure 流分析可以从架构注册表检索架构,并将数据从事件中心输入反序列化。 通过将架构元数据移动到架构注册表中,可以减少每条消息开销,并实现高效的架构验证,以确保数据的完整性。

本文介绍如何将 Schema Registry 添加到流分析作业,并连接 Event Hubs 输入。

先决条件

在开始之前,请确保具有以下各项:

管理对架构注册表的作业访问权限

若要访问事件中心架构注册表,需要使用安全主体将 架构注册表读取者 角色分配给流分析作业。

  1. 登录到 Azure 门户 并转到流分析作业页。

  2. 选择托管标识页面,并保存主体名称以供后续使用。 有关更多详细信息,请查看 托管身份。

    “托管标识”页面的屏幕截图。

  3. 转到托管架构注册表的事件中心命名空间页面。 选择“ 访问控制 ”并 添加角色分配。

    显示“访问控制”页的屏幕截图。

  4. 搜索 架构注册表读取器 ,然后单击“ 下一步”。

    显示“添加角色分配”页的屏幕截图。

  5. 在 “成员 ”页上,选择从步骤 1 保存的 主体名称 ,然后单击“ 查看 + 分配”。

将架构注册表添加到流分析作业

  1. 在流分析作业门户中,在左侧菜单中的“设置”下选择“架构注册表”。
  2. 选择 “添加架构注册表”
  3. 在 “新建架构注册表 ”页上,执行以下步骤:
    1. 对于 Name,请输入此架构注册表的别名,

    2. 对于 “订阅”,请选择包含事件中心命名空间的订阅,托管架构注册表。

    3. 对于 事件中心命名空间,请选择架构注册表位于的命名空间。

    4. 如果无权访问订阅,还可以使用 手动输入。

      显示“新建架构注册表”页的屏幕截图。

配置事件中心输入

Important

架构格式用于确定架构的结构和定义方式。 现在仅支持 AVRO 格式。

  1. 导航到“输入”页。 添加新的事件中心输入或选择现有的事件中心输入。

  2. 若要将架构注册表连接到选定的事件中心,请向下滚动到配置页的底部。

  3. 为事件序列化格式选择 AVRO。

  4. 从下拉菜单中选择架构注册表并 保存。

    显示“事件中心配置”页的屏幕截图。

预览输入数据

Azure 流分析会自动从流式处理输入中提取事件。 它提供了一种方便的方法来测试架构注册表集成,而无需启动或停止作业。

  1. 在“流分析作业”页上,选择“ 作业拓扑 -> 查询 ”以打开“查询编辑器”窗口。

  2. 选择已配置的事件中心(Event Hubs)输入。 请确保所选输入旁边有一个文件图标。

  3. 示例事件将自动显示在 输入预览中。

    显示预览输入页的屏幕截图。

有关查询测试的详细信息,请参阅 使用示例数据测试 Azure 流分析作业 。

局限性

  1. 架构注册表(Schema Registry)的身份验证方法仅支持托管标识(Managed Identity)。 选择架构注册表时,事件中心输入的身份验证方法必须是托管标识。
  2. 测试连接功能尚不适用于架构注册表。 验证与架构注册表建立的连接的最佳方式是通过查询测试页上的输入预览。

后续步骤