向 eventstream 添加 Azure 事件中心源

本文介绍如何向 eventstream 添加 Azure 事件中心源。

注意

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

先决条件

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

  • 获取访问具有参与者或更高级别权限的高级工作区的权限,你的事件流放置在此工作区中。
  • 需要具有适当的权限才能获取事件中心的访问密钥。 事件中心必须是可公开访问的,并且不能位于防火墙后面或在虚拟网络中受到保护。

重要

Fabric 事件流的增强功能目前以预览版方式提供。

注意

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

添加 Azure 事件中心作为源

如果你已有使用流数据创建的 Azure 事件中心,请按照以下步骤将 Azure 事件中心添加为你的事件流源:

  1. 创建具有增强功能的事件流。

  2. 如果尚未将任何源添加到事件流,请选择“入门”页上的“添加外部源”

    显示选择了“添加外部源”磁贴的新事件流的屏幕截图。

    如果要将 Azure 事件中心作为源添加到已发布的事件流,请切换到“编辑”模式,选择功能区上的“添加源”,然后选择“外部源”

    显示已发布事件流的“添加外部源”菜单的屏幕截图。

配置 Azure 事件中心连接器

  1. 在“选择数据源”页上,选择“Azure 事件中心”

    显示在“获取事件”向导中选择 Azure 事件中心作为源类型的屏幕截图。

  2. 如果 Azure 事件中心存在现有连接,请选择下图所示的现有连接,然后继续执行以下步骤以配置“数据格式”。

    显示与 Azure 事件中心具有现有连接的“连接”页的屏幕截图。

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

    显示突出显示“新建连接”链接的“连接”页的屏幕截图。

  4. 在“连接设置”部分中,执行以下步骤:

    1. 输入事件中心命名空间的名称。

    2. 输入事件中心的名称。

      显示指定了事件中心命名空间和事件中心的连接设置的屏幕截图。

  5. 在“连接凭据”部分中,执行以下步骤:

    1. 对于“连接名称”,输入到事件中心的连接的名称。

    2. 对于“身份验证种类”,确认已选择“共享访问密钥”。

    3. 对于“共享访问密钥名称”,输入共享访问密钥的名称。

    4. 对于“共享访问密钥”,输入共享访问密钥的值。

    5. 在页面底部,选择“连接”。

      显示 Azure 事件中心连接器“连接”第一页的屏幕截图。

      若要获取访问密钥名称和值,请执行以下步骤:

      1. 在 Azure 门户中导航到“Azure 事件中心命名空间”页。

      2. 在“事件中心命名空间”页中的左侧导航菜单上选择“共享访问策略”。

      3. 从列表中选择“访问秘钥”。 记下访问密钥名称。

      4. 单击“主键”旁边的复制按钮。

        显示 Azure 事件中心命名空间之访问密钥的屏幕截图。

  6. 现在,在向导的“连接”页上,对于“使用者组”,输入使用者组的名称。 默认情况下,$Default 处于选中状态,这是事件中心的默认使用者组。

  7. 对于数据格式,选择要从 Azure 事件中心获取的传入实时事件的数据格式。 可以从 JSON、Avro 和 CSV(带有标头)数据格式中进行选择。

  8. 选择页面底部的“下一步”。

    显示 Azure 事件中心连接器“连接”第二页的屏幕截图。

  9. 在“查看并创建”页上,查看设置,然后选择“添加”

    显示 Azure 事件中心连接器的“查看和创建”页的屏幕截图。

你会看到事件中心源已添加到“编辑”模式中画布上的事件流。 若要实现新添加的 Azure 事件中心,请选择功能区上的“发布”

显示编辑器的屏幕截图,其中选择了“发布”按钮。

完成这些步骤后,Azure 事件中心可用于“实时视图”中的可视化效果。 选择关系图中的“事件中心”磁贴,查看类似于以下页面的页面。

显示实时视图中编辑器的屏幕截图。

若要了解如何将其他源添加到 eventstream,请参阅以下文章:

先决条件

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

  • 获取访问具有参与者或更高级别权限的高级工作区的权限,你的事件流放置在此工作区中。
  • 需要具有适当的权限才能获取事件中心的访问密钥。 事件中心必须是可公开访问的,并且不能位于防火墙后面或在虚拟网络中受到保护。

注意

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

将 Azure 事件中心添加为源

如果你已有使用流数据创建的 Azure 事件中心,请按照以下步骤将 Azure 事件中心添加为你的事件流源:

  1. 在功能区上选择“新建源”或在主编辑器画布中选择“+”,然后选择“Azure 事件中心”。

  2. 输入新源的源名称,然后选择与 Azure 事件中心的云连接。

    显示 Azure 事件中心源配置的屏幕截图。

  3. 如果没有云连接,请选择“新建连接”来创建一个。 若要创建新连接,请填写 Azure 事件中心的“连接设置”和“连接凭据”,然后选择“创建”

    显示事件中心源中的云连接的屏幕截图。

    • 事件中心命名空间:输入 Azure 事件中心命名空间的名称。

    • 事件中心:在 Azure 门户中输入 Azure 事件中心的名称。

    • 连接名称:输入云连接的名称。

    • 共享访问密钥名称共享访问密钥:转到 Azure 事件中心,并在“共享访问策略”下创建具有 ManageListen 权限的策略。 然后,使用策略名和主密钥作为共享访问密钥名称和共享访问密钥。

      显示 Azure 事件中心策略密钥的屏幕截图。

  4. 创建云连接后,选择“刷新”按钮,然后选择所创建的云连接。

    显示云连接刷新的屏幕截图。

  5. 选择要从 Azure 事件中心获取的传入实时事件的数据格式。

    注意

    事件流功能支持从 Azure 事件中心引入 JSON、Avro 和 CSV(带标头)格式的事件。

  6. 选择可从 Azure 事件中心读取事件数据的使用者组,然后选择“添加”。

创建事件中心源后,会看到它已添加到画布上的事件流。

显示事件中心源的屏幕截图。

若要了解如何将其他源添加到 eventstream,请参阅以下文章: