使用事件中心数据探索器在事件中心上执行数据操作

Azure 事件中心是一种可缩放的事件处理服务,它引入和处理大量事件和数据,延迟低且可靠性高。 有关服务的高级概述,请参阅 什么是事件中心?

开发人员和操作员常常在寻找简单的工具,以便将示例数据发送到其事件中心进行端到端流程测试,或在特定偏移量(或时间点)查看事件,以便进行轻量级调试,通常是在事件发生后进行的。 事件中心数据资源管理器使这些常见工作流变得简单,无需编写定制的客户端应用程序来测试和检查事件中心中的数据。

本文重点介绍 Azure 门户上提供的 Azure 事件中心数据资源管理器的功能。

重要

如果事件中心命名空间只能通过专用终结点访问,则通过专用终结点从同一虚拟网络中的虚拟机访问事件中心数据资源管理器,这可确保 Web 浏览器必须访问专用终结点。

在 Azure 事件中心命名空间上运行的作有两种类型。

  • 管理操作 - 创建、更新、删除事件枢纽命名空间和事件枢纽。
  • 数据操作 - 从事件中心发送和查看事件。

重要

  • 事件中心数据资源管理器不支持管理操作。 必须先创建事件中心,然后数据资源管理器才能从该事件中心发送或查看事件。
  • 虽然使用 Kafka 协议发送的事件有效负载(称为 Kafka 中的)通过数据资源管理器可见,但特定事件的密钥不可见。
  • 建议不要对较大的消息使用事件中心数据资源管理器,因为它可能会导致超时,具体取决于消息大小、客户端和服务总线服务之间的网络延迟等。相反,我们建议使用自己的客户端来处理较大的消息,你可以在其中指定自己的超时值。
  • 用户可以在事件中心数据资源管理器中执行的操作取决于分配给用户的 基于角色的访问控制(RBAC) 角色。

先决条件

若要使用事件中心数据资源管理器工具, 请创建 Azure 事件中心命名空间和事件中心

使用事件中心数据浏览器

若要使用事件中心数据资源管理器,请进入要对其执行数据操作的事件中心命名空间。

要么直接导航到Data Explorer来选择事件中心,要么从entities中选择事件中心,然后从导航菜单中选择Data Explorer

显示左窗格导航的屏幕截图,其中选择了“数据资源管理器”。

发送事件

可以使用Send events功能将自定义有效负载或预定义数据集发送到所选事件中心。

为此,请选择 send events 启用右窗格的按钮。

显示数据资源管理器窗格的屏幕截图,其中选择了“发送事件”。

发送自定义有效负载

发送自定义有效负载 -

  1. 选择数据集 - 选取 Custom payload。 还可以选择预设的数据集,如黄色出租车数据、天气数据等,详见下一部分。
  2. 选择内容类型,从Text/PlainJSON或者XML中选择一种内容类型。
  3. 上传 JSON 文件,或在 “输入有效负载”框中键入有效负载
  4. [可选] 指定系统属性。
  5. [可选] 指定自定义属性 - 可用作键值对。
  6. [可选]如果要发送多个有效负载,请选中“重复发送”框,并指定要发送的有效负载数(即要发送的有效负载数)和重复发送之间的间隔(以毫秒为单位)。

定义有效负载详细信息后,选择“ 发送 ”以按定义发送事件有效负载。

显示自定义有效负载的发送事件体验的屏幕截图。

发送预先准备好的数据集

从预定义的数据集中发送事件有效负载 -

  1. 选择数据集 - 从 预装数据集中选择一个选项,例如黄色出租车、天气数据等。
  2. [可选] 指定系统属性。
  3. [可选] 指定自定义属性 - 可用作键值对。
  4. [可选]如果要发送多个有效负载,请选中“重复发送”框,并指定要发送的有效负载数(即要发送的有效负载数)和重复发送之间的间隔(以毫秒为单位)。

定义有效负载详细信息后,选择“ 发送 ”以按定义发送事件有效负载。

显示预设载荷的发送事件体验的屏幕截图。

查看事件

事件中心数据资源管理器允许查看事件以检查符合条件的数据。

若要查看事件,可以定义以下属性,或依赖于默认值 -

显示数据资源管理器菜单的屏幕截图,其中选择了“查看事件”。

  1. PartitionID - 选择特定分区或选择 “所有分区 ID”。
  2. 使用者组 - 选取 $Default 或其他使用者组,或动态创建一个。
  3. 事件位置 - 选取 最早的位置 (即事件中心的开始位置)、 最新位置 (即最新 位置)、自定义位置 (对于特定偏移量、序列号或时间戳)。
    1. 最早的位置:开始从由于保留策略而未过期的分区中的第一个事件接收事件。
    2. 自定义位置:添加筛选器以指定分区中开始接收事件的位置。
    3. 最近位置:开始接收视图调用后排队的下一个事件。 只有在上次查看事件后发送的事件才会被接收到。
  4. 高级属性 - 指定 最大批大小最长等待时间(以秒为单位)。

设置上述选项后,选择“ 查看事件 ”以拉取事件并在数据资源管理器上呈现它们。

显示事件网格的屏幕截图。

加载事件后,可以选择“ 查看下一个事件 ”以再次使用同一查询拉取事件,或 “全部清除 ”以刷新网格。

下载事件负载数据

查看给定事件中心上的事件时,可以下载事件有效负载以供进一步查看。

若要下载事件有效负载,请选择特定事件,然后选择事件有效负载正文上方显示的 下载 按钮。

显示事件网格的屏幕截图,选定事件和突出显示的“下载事件”按钮。