将 Azure Blob 存储事件源添加到事件流（预览版）

本文介绍如何将 Azure Blob 存储事件源添加到事件流。 事件是完全描述系统中所发生情况的最少量信息。 当客户端创建、替换或删除 Blob 时，将触发 Azure Blob 存储事件。 Microsoft Fabric 事件流允许将 Blob 存储事件链接到实时中心的 Fabric 事件。

将 Azure Blob 存储事件添加为事件流源时，它会自动将系统事件创建到 Blob 存储帐户，并将其链接到实时中心的 Fabric 事件。 然后可以将这些事件转换为连续数据流，并在将其路由到 Fabric 中的各种目标之前对其进行转换。

Fabric 事件流支持以下 Blob 存储事件类型：

事件名称	说明
Microsoft.Storage.BlobCreated	创建或替换 Blob 时触发。
Microsoft.Storage.BlobDeleted	删除 Blob 时触发。
Microsoft.Storage.BlobRenamed	重命名 Blob 时触发。
Microsoft.Storage.BlobTierChanged	在更改 blob 访问层后触发。
Microsoft.Storage.DirectoryCreated	创建目录时触发。
Microsoft.Storage.DirectoryRenamed	重命名目录时触发。
Microsoft.Storage.AsyncOperationInitiated	当涉及将数据从存档层移动或复制到热层或冷层的操作启动时触发。
Microsoft.Storage.DirectoryDeleted	删除目录时触发。
Microsoft.Storage.BlobInventoryPolicyCompleted	当为定义清单策略的规则完成清单运行时触发。
Microsoft.Storage.LifecyclePolicyCompleted	在执行生命周期管理策略定义的操作时触发。

有关可用事件类型的详细信息，请参阅 Azure Blob 存储作为事件网格源。

重要

Fabric 事件流的增强功能目前以预览版方式提供。

注意

工作区容量的以下区域不支持此源：德国中西部、美国中南部、美国西部 2、美国西部 3、西欧、印度西部。

未流式处理事件与流式处理事件

Azure Blob 存储事件是具有清晰起点和终点的离散事件。 Fabric 实时中心可以使用以下两种格式捕获这些事件：

• 非流式传输的事件。 这些事件以原始格式表示为离散事件。 如果 Azure Blob 存储事件未在事件流中流式传输，则它们不会直接连接到事件流，并且不会创建默认流。

  此状态表示事件已链接到实时中心的 Fabric 事件，并等待进一步操作。 操作包括使用数据激活器创建警报，用于在实时中心的“Fabric 事件”选项卡中执行 Fabric 作业项（如管道或笔记本）。

  

• 流式处理事件。 这些事件转换为连续事件，可实时转换和路由到 Fabric 中的各种目标，以便进一步分析。 在事件流中，选择未流式处理 Azure Blob 存储源上的“流事件”按钮会将事件转换为连续事件。 然后，事件流会分配一个默认流，以便添加操作并将其路由到 Fabric 中的其他目标。

  

先决条件

• 使用“参与者”或更高权限访问 Fabric 高级工作区。
• 访问 Azure Blob 存储“StorageV2（常规用途 v2）”、BlockBlobStorage 或 BlobStorage 帐户。 “存储（常规用途 v1）”存储类型不支持与 Fabric 事件流集成。

注意

一个事件流的源和目标的最大数量为 11。

将 Azure Blob 存储事件添加为源

1. 选择“事件流”以创建新的事件流。 确保已启用“增强功能（预览版）”选项。

   

2. 在下一个屏幕上，选择“添加外部源”。

   

配置并连接到 Azure Blob 存储事件

1. 在“选择数据源”屏幕上，选择“Azure Blob 存储事件”。

   

2. 在“连接”屏幕上，选择要在事件流中捕获的“订阅”和“存储帐户”。

   

3. 选择下一步。

4. 在“审阅和创建”屏幕上，查看摘要，然后选择“添加”以完成 Azure Blob 存储事件的配置。

   

创建连接后，可以看到在“编辑模式”下添加到事件流的 Azure Blob 存储事件源。 选择“发布”以发布事件流并开始捕获 Azure Blob 存储事件。

注意

编辑器中的事件流节点没有创建默认流。 这是因为 Blob 存储事件仍采用离散事件的形式，并且尚未转换为流或连接到事件流。

发布更改后，Azure Blob 存储帐户现在已链接到“实时中心”。 转到“实时中心”>“Fabric 事件”>“Azure Blob 存储事件”，可以在下拉列表中找到 Azure Blob 存储帐户，并设置触发器以对 Blob 存储事件执行操作。

转换 Azure Blob 存储事件

将 Azure Blob 存储事件链接到实时中心的 Fabric 事件后，可以将这些事件转换为流并在事件流中执行变换。

1. 在“编辑模式”中添加 Azure Blob 存储事件源后，选择源中的“流事件”以将 Blob 存储事件转换为数据流。

   

2. 对于询问是否要将 Blob 存储事件流式传输到事件流中的弹出窗口，回应“是”。

   

3. 在编辑器中，在事件流节点中创建默认流，指示 Blob 存储事件转换为流作为默认流。

   

4. 然后，需要发布事件流，并确保至少有一个事件从 Azure Blob 存储触发，以便继续转换或路由。

   

5. 事件流入事件流后，请输入“编辑模式”并添加操作以转换流式传输的 Blob 存储事件。 以下示例演示 Blob 存储事件聚合并路由到 KQL 数据库。

   

6. 发布更改后，流式传输的 Azure Blob 存储事件将转换并路由到 Fabric 中的指定目标。

   

   还可以在“实时中心”的“数据流”选项卡上查看数据流进行验证。

   

已知限制

• 目前，当在离散事件源上发生错误时，错误消息不可用。
• 目前，数据预览功能不适用于离散事件源。

相关内容

• 将 Fabric 工作区项事件添加到事件流
• 为离散事件创建事件流