你当前正在访问 Microsoft Azure Global Edition 技术文档网站。 如果需要访问由世纪互联运营的 Microsoft Azure 中国技术文档网站,请访问 https://docs.azure.cn。
本快速入门介绍如何使用适用于 Visual Studio 的 Azure 流分析工具创建和运行流分析作业。 示例作业从 IoT 中心设备读取流数据。 定义一个作业,该作业在 27° 以上时计算平均温度,并将生成的输出事件写入 Blob 存储中的新文件。
注释
- 强烈建议将 流分析工具用于 Visual Studio Code, 以获得最佳本地开发体验。 Visual Studio 2019(版本 2.6.3000.0)的流分析工具中存在已知的功能差距,并且不会进一步改进。
- Visual Studio 和 Visual Studio Code 工具不支持中国东部、中国北部、德国中部和德国东北部区域的作业。
在您开始之前
- 如果没有 Azure 订阅,可以创建一个免费帐户。 
- 登录到 Azure 门户。 
- 安装 Visual Studio 2019、Visual Studio 2015 或 Visual Studio 2013 Update 4。 支持企业版(Ultimate/Premium)、Professional 版和社区版。 不支持 Express 版本。 
- 按照 安装说明 安装适用于 Visual Studio 的流分析工具。 
对输入数据进行准备
在定义流分析作业之前,应准备数据,稍后会将其配置为作业输入。 若要准备作业所需的输入数据,请完成以下步骤:
- 登录到 Azure 门户。 
- 选择“ 创建资源>物联网>IoT 中心”。 
- 在 IoT 中心 窗格中,输入以下信息: - 设置 - 建议的值 - 说明 - Subscription - <订阅> - 选择要使用的 Azure 订阅。 - 资源组 - asaquickstart-resourcegroup - 选择“ 新建 ”,然后输入帐户的新资源组名称。 - IoT 中心名称 - MyASAIoTHub - 选择 IoT 中心的名称。 - 区域 - <选择离用户最近的区域> - 选择可以托管 IoT 中心的地理位置。 使用离用户最近的位置。 - 层 - 免费 - 对于本快速启动,请选择免费(如果它在您的订阅中仍然可用)。 如果免费层不可用,请选择可用的最低层。 有关详细信息,请参阅 IoT 中心定价。   
- 选择“查看 + 创建”。 查看 IoT 中心信息,然后选择“ 创建”。 创建 IoT 中心可能需要几分钟时间。 可以在 “通知 ”窗格中监视进度。 
- 部署完成后,选择“ 转到资源 ”以导航到 IoT 中心的 IoT 中心页。 
- 在 IoT 中心页上,在左侧导航菜单上选择“设备管理”下的“设备”。 
- 在“ 设备 ”页上,选择工具栏上的 “+ 添加设备 ”。   
- 在“ 创建设备 ”页上,输入设备的名称,然后选择“ 保存”。   
- 创建设备后,从 IoT 设备 列表中打开设备。 如果尚未看到设备,请刷新页面。 
- 复制 主连接字符串 并将其保存到记事本,以供以后使用。 
创建 Blob 存储
- 在 Azure 门户的左上角,选择“创建资源>存储帐户>”。 
- 在 “创建存储帐户 ”窗格中,输入存储帐户名称、位置和资源组。 选择与创建的 IoT 中心相同的位置和资源组。 然后选择 “查看 + 创建 ”以创建帐户。   
- 创建存储帐户后,在“概述”窗格中选择“Blob 服务”磁贴。   
- 在 Blob 服务 页上,选择工具栏上的 + 容器。 
- 在 “新建容器 ”页上,输入容器的名称,例如 container1。 将 公共访问级别 保留为 “专用”(无匿名访问), 然后选择“ 创建”。   
创建流分析项目
- 启动 Visual Studio。 
- 选择 “文件 > 新建项目”。 
- 在左侧的模板列表中,选择 “流分析”,然后选择 “Azure 流分析应用程序”。 
- 输入项目名称、位置和解决方案名称,然后选择“创建”。   
- 请注意 Azure 流分析项目中包含的元素。   
选择所需的订阅
- 在 Visual Studio 的 “视图 ”菜单上,选择 “服务器资源管理器”。
- 右键单击 Azure,选择“ 连接到Microsoft Azure 订阅”,然后使用 Azure 帐户登录。
定义输入
- 在 解决方案资源管理器中,展开 “输入” 节点,然后双击 Input.json。 
- 使用以下值填写 流分析输入配置 : - 设置 - 建议的值 - 说明 - 输入别名 - Input - 输入一个名称,用于标识作业的输入。 - 源类型 - 数据流 - 选择适当的输入源:数据流或引用数据。 - 来源 - IoT 中心 - 选择适当的输入源。 - Resource - 从当前帐户中选择数据源 - 选择手动输入数据或选择现有帐户。 - Subscription - <订阅> - 选择包含您已创建的 IoT 中心的 Azure 订阅。 - IoT 中心 - MyASAIoTHub - 选择或输入 IoT 中心的名称。 如果在同一订阅中创建 IoT 中心名称,则会自动检测它们。 
- 将其他选项保留为默认值,然后选择“ 保存 ”以保存设置。   
定义输出
- 在 解决方案资源管理器中,展开 “输出 ”节点,然后双击 Output.json。 
- 使用以下值填写 流分析输出配置 : - 设置 - 建议的值 - 说明 - 输出别名 - 输出 - 输入名称以识别任务的输出。 - 接收器 - Data Lake Storage Gen 2/Blob Storage - 选择适当的汇聚点。 - Resource - 手动提供数据源设置 - 选择手动输入数据或选择现有帐户。 - Subscription - <订阅> - 选择具有您所创建存储帐户的 Azure 订阅。 存储帐户可以位于同一订阅中或不同订阅中。 此示例假定已在同一订阅中创建存储帐户。 - 存储帐户 - asa快速启动存储 - 选择或输入存储帐户的名称。 如果存储帐户名称在同一订阅中创建,则会自动检测它们。 - 集装箱 - container1 - 选择在存储帐户中创建的现有容器。 - 路径模式 - 输出 - 输入要在容器中创建的文件路径的名称。 
- 将其他选项保留为默认值,然后选择“ 保存 ”以保存设置。   
定义转换查询
- 从 Visual Studio 中的解决方案资源管理器打开 Script.asaql。 
- 添加以下查询: - SELECT * INTO Output FROM Input WHERE Temperature > 27
将流分析查询提交到 Azure
- 在 查询编辑器中,在脚本编辑器中选择“ 提交到 Azure ”。 
- 在 “提交作业 ”窗口中,选择“ 创建新的 Azure 流分析作业”。 
- 输入 作业名称。 
- 选择 Azure 订阅。 
- 选择 资源组。 
- 保留 群集的默认值。 
- 选择您在快速入门开头使用的位置。 
- 然后选择“ 提交”。   
运行 IoT 模拟器
- 在新浏览器选项卡或窗口中打开 Raspberry Pi Azure IoT Online 模拟器 。 
- 将第 15 行中的占位符替换为在上一部分中保存的 Azure IoT 中心设备连接字符串。 
- 选择 运行。 输出会显示传感器数据和发送到 IoT 中心的消息。   
启动流分析作业并检查输出
- 创建作业后,作业视图会自动打开。 选择绿色箭头按钮以启动作业,   
- 将 作业输出启动模式 更改为 JobStartTime ,然后选择“ 启动”。   
- 请注意,作业状态已更改为 “正在运行”,并且存在输入/输出事件。 这可能需要几分钟的时间。 选择工具栏上的 “刷新 ”按钮以刷新指标。 
- 若要查看结果,请在 “视图 ”菜单上选择 “云资源管理器”,然后导航到资源组中的存储帐户。 在 Blob 容器下,双击 container1,然后单击 输出 文件路径。   
清理资源
若不再需要资源组、流式处理作业以及所有相关资源,请将其删除。 删除作业可避免对作业使用的流单元进行计费。 如果计划在将来使用该作业,可以先停止它,等到以后需要时再重启它。 如果不打算继续使用该作业,请按照以下步骤删除本快速入门创建的所有资源:
- 在 Azure 门户的左侧菜单中选择“资源组”,然后选择已创建资源的名称。
- 在资源组页上选择“删除”,在文本框中键入要删除的资源的名称,然后选择“删除”。
后续步骤
在本快速入门中,你已使用 Visual Studio 部署了一个简单的流分析作业。 还可以使用 Azure 门户 和 PowerShell 部署流分析作业。
若要了解适用于 Visual Studio 的 Azure 流分析工具,请继续阅读以下文章:
 
              
              