编辑和发布 Microsoft Fabric 事件流

本文介绍如何编辑和发布 Microsoft Fabric 事件流。

编辑模式和实时视图

Fabric 事件流提供两种不同的模式,即“编辑模式”和“实时视图”,以提供灵活性和对数据流的控制。 如果创建启用了增强功能的新事件流,则可以在编辑模式中修改事件流并使用无代码编辑器为数据流设计流处理操作。 完成后,可以发布事件流并直观显示事件流如何在实时视图中开始流式传输和处理数据。

下面是在两种不同模式下发现的所有内容的概述:

编辑模式

  • 在选择发布更改之前,不会实现在编辑模式下所做的任何更改,从而确保完全控制事件流的开发过程。

  • 不存在测试数据流式传输到事件流或目标的风险。 此模式旨在提供一个安全的环境进行测试,而不会影响实际的数据流。

  • 如果对现有事件流进行更改,则在发布事件流之前,不会实现这些更改。

实时视图:

  • 可以在发布更改后直观显示事件流如何接收、转换并将事件从源路由到各种目的地。

  • 可以在任何选定的源和目的地上暂停数据流动,从而更好地控制数据流。

新建事件流

  1. 导航到 Fabric 门户。

  2. 选择左侧导航栏上的“我的工作区”

  3. “我的工作区” 页上,选择命令栏上的 + 新建项目

  4. “新建项”页上,搜索 Eventstream,然后选择 Eventstream

    显示“新建项”页的屏幕截图,其中选择了“事件流”。

  5. “新建事件流”窗口中,输入事件流的 名称,然后选择 “创建”。

    显示“新建事件流”窗口的屏幕截图。

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

    屏幕截图显示编辑器。

  1. 在下一个屏幕上,选择“添加外部源”,以将数据传输到 Fabric 事件流。

    选择“添加外部源”的屏幕快照。

  2. Azure 事件中心 磁贴上选择 连接

    屏幕截图显示“选择数据源”页,其中选择了“Azure 事件中心”。

  3. 在“连接数据源”页上,选择“新建连接”

    屏幕截图显示“连接数据源”页,其中选择了“新建连接”链接。

  4. 在弹出窗口的“连接设置”部分中,指定事件中心命名空间的名称及其中的事件中心

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

  5. 在“连接凭据”部分中,指定访问密钥名称及其值,然后选择“连接”

    显示事件中心连接凭据的屏幕截图。

  6. 现在,在“连接”页上,指定使用者组,并选择要使用的数据格式,然后选择“下一步”

    显示“连接”页的屏幕截图,其中包含事件中心的其他配置。

  7. 在“查看 + 连接”页上,查看设置,然后选择“添加”

    屏幕截图显示了新事件流的摘要。

  8. 你现在处于事件流编辑模式中。 选择“刷新”以预览 Azure 事件中心数据。

    屏幕截图显示了选择“刷新”以预览事件中心数据。

发布事件流

要发布事件流,请确保事件流同时具有已配置的源和目的地,并且不会显示任何编辑错误。

以下步骤演示如何向事件流添加事件处理操作和目标,然后进行发布。

  1. 你可以展开编辑器上的下拉菜单,然后选择要添加到事件流的“目标”或“操作”

    屏幕截图显示了选择目标或操作。

  2. 如果存在任何创作错误,则禁用“发布”按钮。 例如,必须先添加“筛选器”操作的目标,然后才能进行发布。

    屏幕截图显示了阻止发布的创作错误。

  3. 配置 Lakehouse 目标后,选择“发布”以提交更改。

    发布事件流的屏幕截图。

    此操作将事件流从“编辑”模式切换到“实时”视图,从而启动实时数据处理。

    屏幕截图显示了查看来自新事件流的实时数据。