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

Azure 数据资源管理器使用事件网格引入管道提供了从 Azure 存储(Azure Blob 存储和 Azure Data Lake Storage Gen2)的持续引入。 在事件网格引入管道中,Azure 事件网格服务通过 Azure 事件中心将“已创建 Blob”或“已重命名 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. 单击“选择终结点”,并填写所创建的事件中心,例如“测试中心”。

  6. 如果要跟踪特定主题,请选择“筛选器”。 按如下所述设置通知筛选器:

    筛选器选项卡事件网格

    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 存储事件

  7. 选择“创建”

后续步骤