你当前正在访问 Microsoft Azure Global Edition 技术文档网站。如果需要访问由世纪互联运营的 Microsoft Azure 中国技术文档网站，请访问 https://docs.azure.cn。

使用流分析无代码编辑器筛选和引入到 Azure 数据资源管理器

项目
08/12/2024

本文介绍如何使用无代码编辑器轻松创建流分析作业。它不断从事件中心读取数据，筛选传入数据，然后将结果持续写入到 Azure 数据资源管理器。

先决条件

Azure 事件中心和 Azure 数据资源管理器资源必须可公开访问，并且不能位于防火墙之后或在 Azure 虚拟网络安全保护之中
事件中心中的数据必须以 JSON、CSV 或 Avro 格式进行序列化。

开发流分析作业以筛选和引入实时数据

在 Azure 门户中，找到并选择 Azure 事件中心实例。
选择“功能”>“处理数据”，然后在“筛选数据并将其存储到 Azure 数据资源管理器”卡上选择“开始”。
输入流分析作业的名称，然后选择“创建”。
指定事件中心窗口中数据的“序列化类型”和作业将用于连接到事件中心的“身份验证方法”。然后选择“连接” 。
成功建立连接并且数据流流入事件中心实例后，你将立即看到两项内容：
- 输入数据中存在的字段。可以选择“添加字段”，也可以选择字段旁边的三个点符号来删除、重命名或更改其类型。
- 图表视图下的“数据预览”表中的传入数据的实时示例。它会定期自动刷新。可以选择“暂停流式预览”以查看示例输入数据的静态视图。
选择“筛选”磁贴以聚合数据。在“筛选器”区域中，选择一个字段来按条件筛选传入数据。
选择“管理”磁贴。在“管理字段”配置面板中，选择要输出到事件中心的字段。如果要添加所有字段，请选择“添加所有字段”。
选择“Azure 数据资源管理器”磁贴。在配置面板中，填写所需的参数并进行连接。

注意

表必须存在于所选数据库中，表架构必须与数据预览生成的字段数及其类型完全匹配。
也可以选择“获取静态预览/刷新静态预览”，以查看将在事件中心中引入的数据预览。
选择“保存”，然后选择“启动”以启动流分析作业。
要开始作业，请指定以下内容：
- 作业运行时使用的“流单元 (SU)”数量。 SU 表示分配给作业的计算和内存量。建议先选用 3，然后根据需要进行调整。
- 输出数据错误处理 - 它允许指定作业因数据错误而无法输出到目标时所需的行为。默认情况下，作业会重试，直到写入操作成功。你也可以选择删除此类输出事件。
选择“开始”后，作业将在两分钟内开始运行，指标将在下面的选项卡部分打开。

还可以在“流分析作业”选项卡的“处理数据”部分下查看作业。根据需要选择“打开指标”来监控它，或者停止并重新启动它。