你当前正在访问 Microsoft Azure Global Edition 技术文档网站。 如果需要访问由世纪互联运营的 Microsoft Azure 中国技术文档网站,请访问 https://docs.azure.cn

手动创建资源以实现事件网格引入

Azure 数据资源管理器使用事件网格引入管道提供了从 Azure 存储(Azure Blob 存储和 Azure Data Lake Storage Gen2)的持续引入。 在事件网格引入管道中,Azure 事件网格服务通过 Azure 事件中心将 blob 创建或重命名的事件从存储帐户路由到 Azure 数据资源管理器。

本文介绍了如何手动创建事件网格引入所需的资源:事件网格订阅、事件中心命名空间和事件中心。 先决条件中介绍了事件中心命名空间和事件中心创建。 若要在定义事件网格引入时使用这些资源的自动创建,请参阅在 Azure 数据资源管理器中创建事件网格数据连接

必备条件

注意

为了获得最佳性能,请在 Azure 数据资源管理器群集所在的区域中创建所有资源。

创建事件网格订阅

  1. 在 Azure 门户中转到自己的存储帐户。

  2. 在左侧菜单中,选择“ 事件>+ 事件订阅”。

    “创建事件网格”页的屏幕截图。

  3. 在“创建事件订阅”窗口中的“基本”选项卡内,提供以下值:

    “创建事件网格订阅”页的屏幕截图,其中显示了包含订阅详细信息的基本选项卡。

    设置 建议的值 字段说明
    名称 test-grid-connection 要创建的事件网格订阅的名称。
    事件架构 事件网格架构 事件网格要使用的架构。
    主题类型 存储帐户 事件网格主题的类型。 自动填充。
    源资源 gridteststorage1 存储帐户的名称。 自动填充。
    系统主题名称 gridteststorage1... Azure 存储发布事件的系统主题。 然后,该系统主题将事件转发给接收并处理事件的订阅服务器。 自动填充。
    筛选事件类型 已创建 Blob 要获取其通知的特定事件。 创建订阅时,请选择受支持的类型之一:Microsoft.Storage.BlobCreated 或 Microsoft.Storage.BlobRenamed。 仅 ADLSv2 存储支持 Blob 重命名。
  4. 在“终结点详细信息”下,选择“事件中心”。

    选择用于接收事件的事件处理程序 - 事件中心 - Azure 数据资源管理器。

  5. 选择 一个终结点 并填写你创建的事件中心,例如 test-hub

  6. 在“托管标识 FOR DELIVERY”下,可以选择使用下表中的信息选择托管标识类型。

    传递的托管标识部分的屏幕截图,其中显示了“选择托管标识类型”选项。

    类型 描述
    无(默认) 事件不会使用托管标识传递。
    系统分配 事件是使用系统分配的托管标识传递的。
    重要说明:在使用此选项之前,请确保在事件网格系统主题上启用系统分配的标识,并在事件中心上为其提供Azure 事件中心数据发送者角色。 有关详细信息,请参阅 为系统主题启用托管标识。

    重要

    如果在 事件中心命名空间上禁用本地身份验证 ,该命名空间包含用于流式处理通知的事件中心,则必须使用此事件订阅时使用托管标识来传递事件。

  7. 若要筛选事件,请选择“筛选器”选项卡。

    使用主题筛选器跟踪特定主题事件。 按如下所述设置通知筛选器:

    筛选器选项卡的屏幕截图,其中显示了筛选器事件选项。

    1. 选择“启用主题筛选”
    2. “主题开头为”字段是主题的文本前缀。 由于应用的模式是“startswith”,因此可以跨越多个容器、文件夹或 blob。 不允许通配符。
      • 若要在 blob 容器上定义筛选器,请按照如下所示设置字段: /blobServices/default/containers/[container prefix]
      • 若要在 blob 前缀(或 Azure Data Lake Gen2 中的文件夹)上定义筛选器,请按照如下所示设置字段: /blobServices/default/containers/[container name]/blobs/[folder/blob prefix]
    3. “主题末尾为”字段是 Blob 的文本后缀。 不允许通配符。
    4. “区分大小写主题匹配”字段指示前缀和后缀筛选器是否区分大小写。

    有关筛选事件的详细信息,请参阅 blob 存储事件

    使用“高级筛选器”添加满足你要求的自定义筛选器。

    例如,使用 Azure Data Lake SDK 上传文件时,文件创建过程将触发一个大小为 0 的事件网格事件。 Azure 数据资源管理器将放弃此事件。 如果 Close 参数设置为“true”,文件刷新会触发另一个事件 。 此事件表示这是最后一次更新,且文件流已关闭。 若要避免不必要的处理和空文件引入错误,请使用以下筛选器筛选出 CreateFile 事件:

    显示如何筛选创建文件事件的屏幕截图。

    设置 建议的值 字段说明
    密钥 data.api 事件架构中用于筛选的字段。
    运算符 字符串不位于 要对所选键进行评估的运算符。
    “值” CreateFile 用于计算键的值。
  8. 选择“创建”

下一步