将 Eventhouse 目标添加到事件流

本文介绍如何在 Microsoft Fabric 事件流中向事件流添加 Eventhouse 作为目标。

注意

如果要使用处于预览状态的增强功能,请选择顶部的“增强功能”。 否则,请选择“标准功能”。 有关预览版中增强功能的信息,请参阅 Fabric 事件流简介

先决条件

  • 使用“参与者”或更高级别权限访问事件流所在之 Fabric“高级工作区”
  • 访问在 Fabric“高级工作区”(你在其中具有“参与者”或更高权限)中创建的 Eventhouse。

注意

一个事件流的源和目标的最大数量为 11

将 Eventhouse 添加为目标

要将 Eventhouse 添加为目标,需要在两种引入模式之间进行选择:“直接引入”和“引入前进行事件处理”。

直接引入模式

直接引入模式会将事件数据直接引入到 Eventhouse 中,而无需任何处理。 可以使用直接引入模式将 Eventhouse 目标添加到默认流。

重要

只能对默认流使用“直接引入”。 直接引入无法遵循处理运算符或派生流。 如果要在处理运算符或派生流后添加 Eventhouse 目标,请改为“在引入前进行事件处理”。

  1. 在事件流的“编辑模式”下,选择功能区上的“添加目标”或选择画布上的“转换事件或添加目标”卡,然后选择“Eventhouse”。

    在“添加目标”下拉列表中选择“Eventhouse”的屏幕截图。

  2. 在 Eventhouse 屏幕上,选择“直接引入”。

  3. 从所选工作区输入“目标名称”、“工作区”以及“Eventhouse”.

  4. 选择“保存”。

    Eventhouse 配置屏幕的屏幕截图。

  5. 将新的 Eventhouse 目标卡连接到事件流的输出(如果尚未连接),然后选择“发布”。

    事件流的屏幕截图,其中突出显示了“发布”按钮。

  6. 在“实时视图”中,在 KQL 数据库目标节点中选择“配置”

    已发布事件流的屏幕截图,其中突出显示了 KQL 数据库目标中的“配置”按钮。

  7. KQL 数据库将在“获取数据”屏幕中打开。 选择 KQL 数据库的现有表,或选择“新建表”创建新的表,用以路由和引入数据。

  8. 提供“数据连接名称”或保留提供的名称,然后选择“下一步”。 从事件流拉取数据可能需要几分钟时间。

    KQL 数据库目标的“获取数据”屏幕的屏幕截图,其中突出显示了“下一步”按钮。

  9. 在“检查数据”屏幕上,可以:

    • 选择“格式”以预览数据发送到 KQL 数据库的方式。
    • 选择“编辑列”,为数据配置列。
    • 选择“高级”以选择要包含的事件,或选择映射选项。

    显示“检查数据”屏幕上的数据格式和“高级”选项的屏幕截图。

  10. 如果选择“编辑列”,可以在“编辑列”屏幕上执行以下操作:

    • 要添加列,选择“添加列”
    • 选择要映射的“源”列。
    • 将“映射转换”应用于列。
    • 更改“示例数据”值。

    然后,选择应用

    “编辑”列屏幕的屏幕截图。

  11. 完成数据配置后,在“检查数据”屏幕上选择“完成”

  12. 在“摘要”屏幕上,查看数据引入的详情和状态,包括使用定义架构的表,以及事件流与 KQL 数据库之间的连接。 选择“关闭”以完成 KQL 数据库设置。

    “摘要”屏幕的屏幕截图,突出显示了“关闭”按钮。

现在可以在“实时视图”中的画布上查看 KQL 数据库目标。

实时视图中配置的 KQL 数据库目标的屏幕截图。

引入前的事件处理

“引入前的事件处理”模式会先处理事件数据,然后再将其引入到 KQL 数据库中。 如果应用运算符(例如筛选或聚合)来处理引入前的数据,或者是派生流之后的数据,请使用此模式。

  1. 在事件流的“编辑模式”下,将鼠标悬停在运算符或派生流上,选择 +,然后选择“KQL 数据库”

    选择运算符输出的 + 符号并选择 KQL 数据库的屏幕截图。

  2. 在“KQL 数据库”屏幕上,应已选择“引入前的事件处理”。 完成有关 KQL 数据库的其余信息,然后选择“保存”

    用于引入前事件处理的 KQL 数据库配置屏幕的屏幕截图。

  3. 若要实现新添加的 KQL 数据库目标,请选择“发布”

    添加了 KQL 数据库目标的编辑模式下的事件流屏幕截图。

完成这些步骤后,有 KQL 数据库目标的事件流可用于“实时视图”中的可视化效果。

实时视图中配置的 KQL 数据库事件处理流的屏幕截图。

若要了解如何向 eventstream 添加其他目的地,请参阅以下文章:

先决条件

开始之前,你必须满足以下先决条件:

  • 获取访问具有参与者或更高级别权限的高级工作区的权限,你的事件流放置在此工作区中。
  • 使用参与者或更高权限访问 KQL 数据库所在的高级工作区

注意

一个事件流的源和目标的最大数量为 11

添加 KQL 数据库作为目标

若要将 KQL 数据库添加为目标,需要在工作区中创建 KQL 数据库,并在两种引入模式之间进行选择:直接引入引入前的事件处理

直接引入

此模式无需任何处理,就可将事件数据直接引入到 KQL 数据库中。 如果想按原样引入事件数据并随后使用 KQL 查询在 KQL 数据库中执行任何处理或转换,可以使用此模式。

  1. 在功能区上选择“新建目标”或在主编辑器画布中选择“+”,然后选择“KQL 数据库”。 显示了 KQL 数据库目标配置屏幕。

  2. 选择“直接引入”,输入目标名称,选择工作区,从所选工作区中选择 KQL 数据库,然后选择“添加和配置”。

    注意

    只能选择与事件流具有相同区域 Fabric 容量的工作区。

    KQL 数据库拉取模式目的地配置屏幕的屏幕截图。

  3. 在“获取数据”页面上,浏览选项卡以完成配置:

    1. 配置:使用 KQL 数据库的现有表或创建新表来路由和引入数据。 填写必填字段并选择“下一步”。

      创建 KQL 数据库目标的“引入数据”屏幕的“目标”选项卡的屏幕截图。

    2. 检查:选择数据格式,并预览数据发送到 KQL 数据库的方式。

      屏幕截图显示用于创建 KQL 数据库目的地的“引入数据”屏幕的数据格式。

      还可以通过单击表标题中的箭头来更改列名、数据类型或更新列。 填写必填字段并选择“完成”。

      屏幕截图显示如何更改用于创建 KQL 数据库目的地的“引入数据”屏幕的列。

      屏幕截图显示如何更改用于创建 KQL 数据库目的地的“引入数据”屏幕的列名、数据类型。

    3. 摘要:查看数据引入的状态,包括使用定义的架构创建的表,以及事件流与 KQL 数据库之间的连接。

      创建 KQL 数据库目标的“引入数据”屏幕的“摘要”选项卡的屏幕截图。

  4. 配置所有内容并选择“关闭”后,画布上会显示一个连接到你的 Eventstream 的 KQL 数据库目标。

    屏幕截图显示新的 KQL 数据库拉取模式目的地。

引入前的事件处理

此模式会先处理事件数据,然后再将其引入到 KQL 数据库中。 如果想在引入事件数据之前对其进行一些处理或转换(例如筛选、聚合或扩展),可以使用此模式。 可以使用事件处理器来设计处理逻辑。

  1. 选择“引入前的事件处理”,填写有关 KQL 数据库的信息,然后选择“打开事件处理程序”。

    KQL 数据库推送模式目的地配置屏幕的屏幕截图。

  2. 使用事件处理器设计事件处理,然后选择“保存

    推送模式事件处理器屏幕的屏幕截图。

  3. 如果选择现有 Kusto 表,会在此事件流中的当前架构与目标 KQL 表之间执行架构验证。 如果两个架构不匹配,会显示一条错误消息,提醒打开事件处理器以相应调整此 Eventstream 中的架构。

    推送模式事件处理器错误屏幕的屏幕截图。

    打开事件处理器后,将在“创作错误”选项卡中显示详细的不匹配信息。

    推送模式事件处理器不匹配信息屏幕的屏幕截图。

  4. 配置完所有内容并选择“保存”后,画布上会出现一个连接到你的 Eventstream 的 KQL 数据库目标,可以检查“数据见解”中的指标和“运行时日志”中的日志

    屏幕截图显示新的 KQL 数据库推送模式目的地。

管理目标

编辑/删除:可以通过导航窗格或画布编辑或删除事件流目标。

选择“编辑”时,会在主编辑器的右侧打开编辑窗格。 可以根据需要修改配置,包括通过事件处理程序编辑器的事件转换逻辑。

屏幕截图显示在画布上选择修改和删除目标选项的位置。

若要了解如何向 eventstream 添加其他目的地,请参阅以下文章: