为离散事件创建事件流(预览版)

本文介绍如何为离散事件创建 Microsoft Fabric 事件流。

开发应用程序进行实时分析时,通常会遇到两种类型的事件:离散事件和连续事件(或流)。 Microsoft Fabric 事件流可以引入和处理离散事件和连续事件。

了解离散事件和连续事件

若要在 Fabric 中构建高效且可缩放的事件流,务必要了解离散事件与连续事件(或流)之间的区别。

  • “离散事件”(通常称为通知事件)是在特定时间点发生的单个事件。 每个事件均相互独立,并且有明确的起点和终点。 离散事件的示例包括用户在网站上下订单,或对数据库进行更改。

  • “连续事件”(或流)表示一段时间内的连续数据流。 与离散事件不同,连续事件没有清晰的起点或终点。 相反,它们表示稳定且持续不断的数据流,通常没有预定义的边界。 示例包括来自 IoT 设备的传感器数据、股票市场股票代码数据或实时信息提要中的社交媒体帖子。

注意

建议在一个事件流中仅包含离散事件源或连续事件(流)源,而不是两者混合。

支持的离散事件

Fabric 事件流可生成事件驱动的解决方案,用于捕获 Fabric 数据源中的系统状态更改或事件。 Fabric 事件流支持以下类型的离散事件:

离散事件 说明
Azure Blob 存储事件 在对 Azure Blob 存储做任何更改(例如创建、修改或删除记录或文件)时生成。
Fabric 工作区项事件 在对 Fabric 工作区做任何更改(包括创建、更新或删除项)时生成。

将离散事件连接事件流

在 Fabric 事件流中,可以将离散事件源添加到事件流中,并将这些事件路由到实时中心。 然后,可以在 Fabric 事件流中转换这些事件,也可以在实时中心订阅这些事件。 在实时中心,还可以进行的操作包括使用 Fabric Activator 或创建执行 Fabric 作业项(如管道和笔记本)的警报。

先决条件

  • 使用“参与者”或更高权限在 Fabric 容量许可证模式(或)试用许可证模式下访问工作区。
  • 用于连接到 Fabric 工作区项事件的 Fabric 工作区,或访问用于连接到 Azure Blob 存储事件的 Azure Blob 存储帐户。

创建事件流

  1. 将 Fabric 体验更改为“实时智能”

    屏幕截图显示了切换到实时智能工作负载的切换器。

  2. 请按照以下步骤之一开始创建事件流:

    • 在“实时智能”主页上的“建议创建的项”部分,选择“事件流”磁贴

      显示主页上事件流磁贴的屏幕截图。

    • 选择左侧导航栏上的“我的工作区”。 在“我的工作区”页上,依次选择“新建项”、“事件流”

      屏幕截图显示在工作区页面的“新建”菜单中找到事件流选项的位置。

  3. 输入新事件流的名称,然后选择“创建”

    屏幕截图显示“新建事件流”对话框。

  4. 在工作区中创建新 eventstream 可能需要几秒钟时间。 创建事件流 后,将跳转到主编辑器,可以在其中开始向事件流添加源。

    屏幕截图显示编辑器。

连接离散事件

若要将离散事件连接到事件流,请执行以下步骤:

  1. 在下一个屏幕上,选择“使用外部源”

    选择“使用外部源”的屏幕截图。

  2. 在“选择数据源”页上,选择“查看所有源”

    在“选择数据源”窗口中选择“查看所有源”的屏幕截图。

  3. 在“选择数据源”屏幕上,选择要添加到事件流的离散事件的类型,应为“Azure Blob 存储事件”“Fabric 工作区项事件”。

    选择 Azure Blob 存储事件的屏幕截图。

  4. 按照以下文章之一中的说明添加事件源并发布事件流:

完成后,事件流将开始在离散事件发生时捕获它们。 在“实时中心”中,可以在“Fabric 事件”或“Azure 事件”下找到这些事件。 在右侧窗格中,可以设置警报以采取进一步操作。 有关详细信息,请参阅实时中心文档中的以下文章:

已知限制

  • 目前,当在离散事件源上发生错误时,错误消息不可用。
  • 目前,数据预览功能不适用于离散事件源。