创建默认和派生事件流(预览版)
本文介绍如何创建默认和派生的 Microsoft Fabric 事件流。 数据流是一种动态且连续的数据流,提供一系列用于即时操作和分析的功能。 使用数据流,可以设置实时警报、馈送不同类型的数据存储,并启用可由多个客户订阅的发布/订阅模型。
Fabric 事件流中实时中心功能的集成进一步增强了这些功能。 通过此集成,可以使用不同的处理操作创建和管理多个数据流,然后可以在实时中心显示这些数据流。
重要
Fabric 事件流的增强功能目前以预览版方式提供。
概念
“事件流”是 Fabric 工作区中的项,可用于引入、转换数据流和将其路由到 Fabric 中的各种目标。
“流”是一个连续且未绑定的数据事件流。 当数据事件汇入 Fabric 事件流时,于 Fabric 事件流中形成数据流,以表示数据事件。 Fabric 事件流中有两种类型的流:
默认流。 每个 Fabric 事件流项都附带一个默认流,该流会在将流式处理源添加到事件流后自动生成。 它表示来自流式处理源的原始事件。 可以在 Fabric 中转换默认流并将其路由到多个目标。 可以从实时中心查看默认流。
派生流是在添加一系列流操作(如“筛选器”或“管理字段”)后创建的 Fabric 事件流中的专用目标类型。 派生流表示流处理后转换的默认流。 还可以将派生流中的流式处理数据路由到 Fabric 中的多个目标。 创建后,数据即可随时由组织中的其他用户通过实时中心进一步使用或分析。
创建默认流
创建新的事件流后,可以向事件流添加源,并自动生成默认流。 以下示例演示将自行车示例数据源添加到 Fabric 事件流项时,自动生成默认流 es-5-stream。
创建派生流
若要创建新的派生流,请将“聚合”等操作添加到事件流。 然后选择“流”选项。
为新流命名,然后选择“发布”以提交更改。
完成后,可以在实时中心访问默认流和派生流以供进一步使用,例如预览流或添加流要传输到的目标。