手动创建资源以实现事件网格引入
Azure 数据资源管理器使用事件网格引入管道提供了从 Azure 存储（Azure Blob 存储和 Azure Data Lake Storage Gen2）的持续引入。 在事件网格引入管道中，Azure 事件网格服务通过 Azure 事件中心将 blob 创建或重命名的事件从存储帐户路由到 Azure 数据资源管理器。
本文介绍了如何手动创建事件网格引入所需的资源：事件网格订阅、事件中心命名空间和事件中心。 先决条件中介绍了事件中心命名空间和事件中心创建。 若要在定义事件网格引入时使用这些资源的自动创建，请参阅在 Azure 数据资源管理器中创建事件网格数据连接。
必备条件
- Azure 订阅。 创建 Azure 帐户。
- Azure 数据资源管理器群集和数据库。 创建群集和数据库。
- 一个存储帐户。 可以在
BlobStorage、StorageV2或 Data Lake Storage Gen2 的 Azure 存储帐户上设置事件网格通知订阅。 - 一个事件中心命名空间和事件中心。
注意
为了获得最佳性能，请在 Azure 数据资源管理器群集所在的区域中创建所有资源。
创建事件网格订阅
在 Azure 门户中转到自己的存储帐户。
在左侧菜单中，选择“事件”>“+事件订阅”。
在“创建事件订阅”窗口中的“基本”选项卡内，提供以下值：
设置 建议的值 字段说明 名称 test-grid-connection 要创建的事件网格订阅的名称。 事件架构 事件网格架构 事件网格要使用的架构。 主题类型 存储帐户 事件网格主题的类型。 自动填充。 源资源 gridteststorage1 存储帐户的名称。 自动填充。 系统主题名称 gridteststorage1... Azure 存储发布事件的系统主题。 然后，该系统主题将事件转发给接收并处理事件的订阅服务器。 自动填充。 筛选事件类型 已创建 Blob 要获取其通知的特定事件。 创建订阅时，请选择受支持的类型之一：Microsoft.Storage.BlobCreated 或 Microsoft.Storage.BlobRenamed。 仅 ADLSv2 存储支持 Blob 重命名。 在“终结点详细信息”下，选择“事件中心”。
单击“选择终结点”，并填写所创建的事件中心，例如“测试中心”。
在“用于传递的托管标识”下，可以根据下表中的信息选择托管标识类型（可选操作）。
类型 描述 无(默认) 事件不会使用托管标识传递。 系统分配 事件是使用系统分配的托管标识传递的。
重要信息：使用此选项之前，请确保在事件网格系统主题上启用了系统分配的标识，并在事件中心上为其授予了 Azure 事件中心数据发送方角色。 有关详细信息，请参阅为系统主题启用托管标识。重要
如果在事件中心命名空间（包含用于流式处理通知的事件中心）上禁用本地身份验证，则必须在使用此事件订阅时使用托管标识传递事件。
若要筛选事件，请选择“筛选器”选项卡。
使用主题筛选器跟踪特定主题事件。 按如下所述设置通知筛选器：
- 选择“启用主题筛选”
- “主题开头为”字段是主题的文本前缀。 由于应用的模式是“startswith”，因此可以跨越多个容器、文件夹或 blob。 不允许通配符。
- 若要在 blob 容器上定义筛选器，请按照如下所示设置字段：
/blobServices/default/containers/[container prefix]。 - 若要在 blob 前缀（或 Azure Data Lake Gen2 中的文件夹）上定义筛选器，请按照如下所示设置字段：
/blobServices/default/containers/[container name]/blobs/[folder/blob prefix]。
- 若要在 blob 容器上定义筛选器，请按照如下所示设置字段：
- “主题末尾为”字段是 Blob 的文本后缀。 不允许通配符。
- “区分大小写主题匹配”字段指示前缀和后缀筛选器是否区分大小写。
有关筛选事件的详细信息，请参阅 blob 存储事件。
使用“高级筛选器”添加满足你要求的自定义筛选器。
例如，使用 Azure Data Lake SDK 上传文件时，文件创建过程将触发一个大小为 0 的事件网格事件。 Azure 数据资源管理器将放弃此事件。 如果 Close 参数设置为“true”，文件刷新会触发另一个事件 。 此事件表示这是最后一次更新，且文件流已关闭。 若要避免不必要的处理和空文件引入错误，请使用以下筛选器筛选出 CreateFile 事件：
设置 建议的值 字段说明 密钥 data.api 事件架构中用于筛选的字段。 运算符 字符串不位于 要对所选键进行评估的运算符。 “值” CreateFile 用于计算键的值。 选择“创建”