教程:创建和激活 Fabric 激活器规则

Microsoft Fabric 中的 Fabric 激活器允许在数据流中检测到模式或条件时采取措施。 如果你不熟悉 Fabric 激活器,请参阅 什么是 Fabric 激活器。 在本教程中,你将使用 Fabric 激活器附带的示例数据来完成以下任务:

  • 查看示例 Activator
  • 浏览数据
  • 浏览规则
  • 启动规则
  • 创建对象
  • 创建规则

先决条件

在开始之前,需要一个具有 Fabric 容量的工作区。 可以在工作区一文中了解 Fabric 工作区。 如果没有 Fabric,系统会提示你开始试用。

创建示例 Activator

  1. 导航到 Fabric 门户

  2. 在左侧导航窗格中,选择“创建”,然后在“Real-Time 智能”部分中选择“激活器”。 如果未看到 “创建”,请选择省略号(...),然后选择“ 创建”。

    显示左侧导航窗格的屏幕截图,其中选择了“创建”。

  3. “激活器 ”页上,选择“ 试用示例”。

    显示用于添加数据或使用示例数据的选项的屏幕截图。

浏览数据

在此步骤中,我们将探索构建此示例所基于的 Eventstream 数据。

新的 Activator 具有“资源管理器”部分。 向下滚动并选择“包交付事件”流

“Activator”的屏幕截图,其中选择了“包传递事件流”。

这些事件显示正在交付的包的实时状态。

查看传入事件,并将鼠标悬停在实时表中的事件数据上。 每个数据点都包含有关事件的信息。 可能需要滚动才能看到所有内容。

浏览规则

使用规则指定要监视的事件值、要检测的条件以及希望 Fabric 激活器执行的动作。

“资源管理器”窗格显示此 Activator 的对象,如 Eventstream。 传递事件是从“包传递事件”事件流创建的对象之一

  1. 在“资源管理器”窗格中,选择名为“交付事件”的对象。 可以创建有关使用“包交付事件”Eventstream 中的数据的对象的规则。 例如,检查包温度的规则。

    显示“传递事件”表和温度列的屏幕截图。

  2. 请注意,“按对象 ID 筛选事件”部分按“包 ID”进行组织。 “包 ID”是唯一标识每个包的列 ID。 我们使用此唯一 ID 将 Package 事件分配给 Package 对象。

    显示“按对象 ID 筛选事件”屏幕中唯一 ID 列的屏幕截图。

  3. 选择名为“药品温度过高”的“温度”规则

    显示示例规则的屏幕截图。

  4. 在最右侧的窗格中,请参阅 “定义 ”窗格以查看规则的工作原理。 在“监视器”部分中,选择“温度”。 温度值来自“交付事件”表中“温度”列。 可以在前面的屏幕截图中看到“温度”列

    屏幕截图显示定义窗格的监视部分。

  5. “摘要”部分中,可以看到窗口大小、步骤大小和聚合操作(平均值)的使用情况。 它基本在 10 分钟时间窗口内计算平均温度。

  6. “条件” 部分中,可以看到用于监视 温度高于 20 摄氏度的规则条件。

  7. 向下滚动到属性筛选器。 规则仅适用于包含药品的包。 在传递事件表中,规则查看名为“Special care contents”的列。 在“Special care contents”列中,部分包的值为“Medicine”

    显示“定义”窗格的属性筛选器部分的屏幕截图。

  8. 最后,向下滚动到“操作”。 如果满足条件,规则会发送 Teams 消息。

    显示“定义”窗格中“操作”部分的屏幕截图。

我们创建了 Fabric 激活器规则。 该规则正在针对“包交付事件”Eventstream 运行。 该规则查找含有药品的包裹,并检查当前温度是否大于20摄氏度。 当温度超过 20 摄氏度时,将发送 Teams 消息。

查看其他规则以了解它们的工作原理。

启动规则

现在,你已熟悉用于创建规则的事件和对象。 下一步是启动规则。

  1. 选择“药品温度过高”

  2. (可选)通过选择“向我发送测试操作”来发送测试消息。 首先检查你是否是“收件人”

    显示“定义”窗格的“动作”部分的屏幕截图,其中突出显示了“发送测试动作”按钮。

  3. 应收到类似以下的消息:

    显示示例 Teams 通知的屏幕截图。

  4. 选择开始。 这会导致规则处于活动状态。 每当药品包太热时,你都会收到 Teams 消息。 规则应每小时触发几次。

    屏幕截图,其中突出显示了“开始”按钮。

  5. 稍后,可以使用功能区上的 “停止 ”按钮关闭规则。

    显示突出显示功能区上的“停止”按钮的屏幕截图。

创建对象

现在是时候创建自己的对象了。 在本部分中,删除“包”对象。 然后,重新创建该包,以跟踪交付时间大于 25 小时的传输中的包的状态。

  1. “资源管理器” 窗格中,右键单击“ ”,然后选择“ 删除”。 在 “删除项 ”窗口中,选择“ 删除”。

    显示包对象上的“删除”菜单的屏幕截图。

  2. 选择 包传递事件 流,然后选择功能区上的 “新建”对象

    显示功能区上的“新建对象”按钮的屏幕截图。

  3. 在右侧的 “生成对象 ”窗格中,执行以下步骤:

    1. 将新对象 命名为 Package2

    2. 选择 PackageId 作为唯一 ID。

    3. 选择 HoursInTransitCity 作为对象的属性。

    4. 选择创建

      显示“生成对象”窗格的屏幕截图。

创建新规则

创建用于在交付过程中运输时间超过阈值时发出警报的规则。

  1. 选择新的“HoursInTransit”属性。 在功能区中,选择“新建规则”

    显示功能区上的“新建规则”按钮的屏幕截图。

  2. “创建规则 ”窗格中,执行以下步骤:

    1. 对于“条件”,请选择“增加”。

    2. 对于 ,请选择 25

    3. 对于 发生,请选择每次满足条件时这一选项。

    4. 对于“操作”,请选择一个选项,以便在 Teams 中发送消息。

    5. 选择创建

      显示“创建规则”窗格的屏幕截图。

  3. 应在“资源管理器”窗格中的 HoursInTransit 下看到规则。 选择规则。 在中间窗格中,选择顶部的铅笔图标,并将名称更新为 高于目标的平均传输时间

    显示用于更改规则名称的铅笔图标的屏幕截图。

  4. 在右侧的“ 定义 ”窗格中,选择 “HoursInTransit”。 然后选择“添加汇总”“平均值”>

    屏幕截图显示“定义”窗格选中了“平均聚合”。

  5. 设置聚合 窗口大小 5 分钟, 步骤大小 为 5 分钟,然后选择“ 保存”。

    显示“定义”窗格的屏幕截图,其中显示了窗口和步骤大小。

  6. 监视器图表会更新以反映汇总情况,规则监视器图表如下所示。

    激活器教程的平均传输时间图表的屏幕截图。

  7. 通过选择“向我发送测试操作”按钮来测试规则。 请确保收到警报。 如果使用的是电子邮件,则可能需要一两分钟才能送达。

    显示功能区上选择的“测试”按钮的屏幕截图。

  8. 通过选择“保存”并在“定义”窗格中启动或选择功能区上的“开始”来启动规则。

    显示所选功能区上的“开始”按钮的屏幕截图。

    你创建了第一个对象和规则。 后续步骤可能会尝试在 Package2 对象上设置一些其他规则

    准备好在自己的数据上使用 Fabric 激活器时,请按照 获取 Fabric 激活器数据 文章中的步骤进行操作。

清理资源

完成在本教程中创建的规则后,请务必停止这些规则。 如果不停用规则,则会继续接收规则通知。 还可能产生后台处理费用。 依次选择每个规则,然后按功能区中的“停止”按钮

还可以详细了解 Microsoft Fabric: