响应 Blob 存储事件

Azure 存储事件允许应用程序响应事件，例如 Blob 的创建和删除。 为此，它无需复杂的代码或高价低效的轮询服务。 最大好处是，使用多少就付多少费用。

通过 Azure 事件网格向订阅者（如 Azure Functions 或 Azure 逻辑应用，甚至是你自己的 HTTP 侦听器）推送 Blob 存储事件。 事件网格通过丰富的重试策略和死信向应用程序提供可靠的事件传递。

若要查看 Blob 存储支持的事件的完整列表，请参阅 Blob 存储事件架构一文。

常见的 Blob 存储事件方案包括图像或视频处理、搜索索引或任何面向文件的工作流。 异步文件上传十分适合事件。 基于事件的体系结构对于鲜少更改，但要求立即响应的情况尤为有效。

若要尝试 blob 存储事件，请参阅以下任意快速入门文章：

若要深入了解使用 Azure Functions 对 Blob 存储事件做出反应的示例，请参阅以下文章：

• 教程：使用 Azure Data Lake Storage 事件更新 Databricks Delta 表。
• 教程：使用事件网格自动调整已上传图像的大小

事件模型

事件网格使用事件订阅将事件消息路由到订阅方。 此图展示了事件发布者、事件订阅和事件处理程序之间的关系。

首先，将终结点订阅到事件。 然后，在触发某个事件时，事件网格服务会将有关该事件的数据发送到终结点。

请参阅 Blob 存储事件架构一文，以便查看：

• Blob 存储事件的完整列表，以及如何触发每个事件。

• 事件网格会针对每个此类事件发送的数据的示例。

• 显示在数据中的每个键值对的用途。

筛选事件

可以按事件类型、容器名称或已创建/删除的对象的名称来筛选 Blob 事件。 事件网格中的筛选器与主题的开头或结尾匹配，因此具有匹配的主题的事件会转到订阅服务器。

若要详细了解如何应用筛选器，请参阅筛选事件网格的事件。

Blob 存储事件使用者使用的格式：

/blobServices/default/containers/<containername>/blobs/<blobname>

要匹配存储帐户的所有事件，可将主题筛选器留空。

要匹配在一组共享前缀的容器中创建的 blob 的事件，请使用 subjectBeginsWith 筛选器，如下所示：

/blobServices/default/containers/containerprefix

要匹配在特定容器中创建的 blob 的事件，请使用 subjectBeginsWith 筛选器，如下所示：

/blobServices/default/containers/containername/

要匹配在共享 blob 名称前缀的特定容器中创建的 blob 的事件，请使用 subjectBeginsWith 筛选器，如下所示：

/blobServices/default/containers/containername/blobs/blobprefix

要匹配在共享 blob 后缀的特定容器中创建的 blob 事件，请使用 subjectEndsWith 筛选器，例如“.log”或“.jpg”。 有关详细信息，请参阅 事件网格概念。

使用事件的做法

处理 Blob 存储事件的应用程序应遵循以下建议的做法：

• 由于可将多个订阅配置为将事件路由至相同的事件处理程序，因此请勿假定事件来自特定的源，而是应检查消息的主题，确保它来自所期望的存储帐户。

• 同样，检查 eventType 是否为准备处理的项，并且不假定所接收的全部事件都是期望的类型。

• 虽然大多数消息几乎实时到达，但没有规定消息到达时间的服务级别协议。 在某些情况下，消息可能需要几分钟才能到达。 由于消息可能在一段延迟后到达，请使用 etag 字段了解对象的相关信息是否仍然是最新的。 若要了解如何使用 etag 字段，请参阅在 Blob 存储中管理并发。

• 由于消息可能无序到达，请使用 sequencer 字段来了解任何特定对象的事件顺序。 sequencer 字段是一个字符串值，表示任何特定 blob 名称的事件逻辑顺序。 你可以使用标准字符串比较，了解同一个 blob 名称上两个事件的相对顺序。

• 存储事件保证至少向订阅服务器传递一次，以确保输出所有消息。 但是，由于后端节点和服务之间的重试或订阅的可用性，可能会出现重复消息。 若要详细了解消息传递和重试，请参阅事件网格消息传递和重试。

• 使用 blobType 字段可了解 blob 中允许何种类型的操作，以及应当使用哪种客户端库类型来访问该 blob。 有效值为 BlockBlob 或 PageBlob。

• 将 URL 字段与 CloudBlockBlob 和 CloudAppendBlob 构造函数配合使用，以访问 blob。

• 忽略不了解的字段。 此做法有助于适应将来可能添加的新功能。

• 若要确保 Microsoft.Storage.BlobCreated 事件仅在块 Blob 完全提交后触发，请针对 CopyBlob、PutBlob、PutBlockList 或 FlushWithClose REST API 调用筛选此事件。 这些 API 调用仅在数据已完全提交到块 Blob 后才触发 Microsoft.Storage.BlobCreated 事件。 若要了解如何创建筛选器，请参阅筛选事件网格的事件。

功能支持

启用 Data Lake Storage Gen2、网络文件系统 (NFS) 3.0 协议或 SSH 文件传输协议 (SFTP) 可能会影响对此功能的支持。 如果已启用这些功能中的某一项，请参阅 Azure 存储帐户中的 Blob 存储功能支持，以评估对此功能的支持。

后续步骤

了解关于事件网格的详细信息，尝试一下 Blob 存储事件：

• 关于事件网格
• Blob 存储事件架构
• 将 Blob 存储事件路由到自定义 Web 终结点