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

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

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

必备条件

• Azure 订阅。 创建 Azure 帐户。
• Azure 数据资源管理器群集和数据库。 创建群集和数据库。
• 一个存储帐户。 可以在 BlobStorage、StorageV2 或 Data Lake Storage Gen2 的 Azure 存储帐户上设置事件网格通知订阅。
• 一个事件中心命名空间和事件中心。

创建事件网格订阅

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

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

   

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

   

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

4. 在“终结点详细信息”中，选择“事件中心” 。

   

5. 单击“选择终结点”，并填写所创建的事件中心，例如“test-hub”。

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

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

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

   

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

7. 选择“创建”

下一步