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

使用从流分析无代码编辑器生成的 Power BI 数据集生成实时仪表板

本文介绍如何使用无代码编辑器轻松创建流分析作业,以便将已处理的数据生成到 Power BI 数据集中。 它持续从事件中心读取数据,处理数据并将其输出到 Power BI 数据集,以生成实时 Power BI 仪表板。

先决条件

  • Azure 事件中心资源必须可供公开访问,并且不能位于防火墙后面或在 Azure 虚拟网络中受到保护
  • 应有一个现有的 Power BI 工作区,并且有权在该工作区中创建数据集。
  • 事件中心中的数据必须以 JSON、CSV 或 Avro 格式进行序列化。

开发流分析作业以使用所选数据创建 Power BI 数据集

  1. Azure 门户中,找到并选择 Azure 事件中心实例。

  2. 选择“功能”>“处理数据”,然后在“使用 Power BI 生成准实时数据仪表板”卡上选择“开始”

    屏幕截图,显示事件中心的“进程数据”页面。

  3. 输入流分析作业的名称,然后选择“创建”。

    显示在何处输入作业名称的屏幕截图。

  4. 在事件中心窗口中指定数据的“序列化类型”,并指定作业将用于连接到事件中心的“身份验证方法”。 然后选择“连接” 。

    显示事件中心连接配置的屏幕截图。

  5. 成功建立连接并且数据流流入事件中心实例后,你将立即看到两项内容:

    • 输入数据中存在的字段。 可以选择“添加字段”,也可以选择字段旁边的三个点符号来删除、重命名或更改其类型。

      屏幕截图显示事件中心字段列表,可在其中移除、重命名或更改字段类型。

    • 图表视图下的“数据预览”表中的传入数据的实时示例。 它会定期自动刷新。 可以选择“暂停流式预览”以查看示例输入数据的静态视图。

      显示“数据预览”下的示例数据的屏幕截图。

  6. 选择“管理”磁贴。 在“管理字段”配置面板中,选择要输出的字段。 如果要添加所有字段,请选择“添加所有字段”。

    显示“管理字段运算符配置”的屏幕截图。

  7. 选择“Power BI”磁贴。 在“Power BI”配置面板中,填写所需的参数并进行连接。

    • 数据集:Azure 流分析作业输出数据写入到的 Power BI 目标。
    • 表:要将输出数据发送到的数据集中的表名称。

    显示 Power BI 输出配置的屏幕截图。

  8. 也可以选择“获取静态预览/刷新静态预览”,查看将在事件中心引入的数据预览。
    屏幕截图显示“获取静态预览/刷新静态预览”选项。

  9. 选择“保存”,然后选择“启动”以启动流分析作业。
    屏幕截图显示“保存”和“启动”选项。

  10. 要开始作业,请指定以下内容:

    • 作业运行时使用的“流单元 (SU)”数量。 SU 表示分配给作业的计算和内存量。 建议先选用 3,然后根据需要进行调整。
    • 输出数据错误处理 - 它允许指定作业因数据错误而无法输出到目标时所需的行为。 默认情况下,作业会重试,直到写入操作成功。 你也可以选择删除此类输出事件。
      显示“启动流分析作业”选项的屏幕截图,可在其中更改输出时间、设置流单元数,然后选择“输出数据错误处理”选项。
  11. 选择“启动”后,作业将在两分钟内开始运行,并且指标将在选项卡部分中打开

    显示启动后的作业指标的屏幕截图。

    还可以在“流分析作业”选项卡的“处理数据”部分下查看作业。根据需要选择“打开指标”来监控它,或者停止并重新启动它。

    “流分析作业”选项卡的屏幕截图,可在其中查看正在运行的作业状态。

在 Power BI 中生成实时仪表板

现在,Azure 流分析作业正在运行,数据持续写入到配置的 Power BI 数据集的表中。 现在可以在 Power BI 工作区中创建实时仪表板。

  1. 转到你在上述 Power BI 输出磁贴中配置的 Power BI 工作区,在左上角选择“+ 新建”,然后选择“仪表板”以便为新仪表板命名。 创建 pbi 仪表板的屏幕截图。
  2. 创建新仪表板后,你会转到该仪表板。 选择“编辑”,然后在顶部菜单栏中选择“+ 添加磁贴”。 此时会打开右侧窗格。 选择“自定义流式处理数据”转到下一页。 pbi 仪表板添加磁贴的屏幕截图。
  3. 选择在 Power BI 节点中配置的流式处理数据集(例如 nocode-pbi-demo-xujx),然后转到下一页。 pbi 仪表板添加磁贴的屏幕截图,其中选择了数据集。
  4. 填写磁贴详细信息,然后按照下一步骤完成磁贴配置。 pbi 仪表板添加磁贴的屏幕截图,其中显示了配置详细信息。
  5. 然后,可以调整其大小并获取持续更新的仪表板,如以下示例所示。 pbi 仪表板报表的屏幕截图。

使用事件中心的异地复制功能时的注意事项

Azure 事件中心最近在公共预览版中推出了异地复制功能。 此功能与 Azure 事件中心的异地灾难恢复功能不同。

当故障转移类型为“强制”且复制一致性为“异步”时,流分析作业无法保证只将数据输出到 Azure 事件中心一次

Azure 流分析作为使用事件中心作为输出的生产者,可能会在故障转移期间以及当主服务器和辅助服务器之间的复制延迟达到配置的最大延迟时在事件中心进行限制期间观察到作业上的水印延迟

Azure 流分析作为使用事件中心作为输入的使用者,可能会在故障转移期间观察到作业上的水印延迟,并且可能会在故障转移完成后跳过数据或找到重复的数据

考虑到这些注意事项,我们建议你在事件中心故障转移完成后立即在适当的开始时间重启流分析作业。 此外,由于事件中心异地复制功能为公共预览版,因此我们目前不建议将此模式用于生产性流分析作业。 在事件中心异地复制功能正式发布并可用于流分析生产作业之前,当前的流分析行为会得到改进。

后续步骤

详细了解 Azure 流分析以及如何监视已创建的作业。