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

快速入门:使用 Visual Studio 创建 Azure 流分析作业

本快速入门介绍如何使用适用于 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 的流分析工具。

对输入数据进行准备

在定义流分析作业之前,应准备数据,稍后会将其配置为作业输入。 若要准备作业所需的输入数据,请完成以下步骤:

  1. 登录到 Azure 门户

  2. 选择“ 创建资源>物联网>IoT 中心”。

  3. IoT 中心 窗格中,输入以下信息:

    设置 建议的值 说明
    Subscription <订阅> 选择要使用的 Azure 订阅。
    资源组 asaquickstart-resourcegroup 选择“ 新建 ”,然后输入帐户的新资源组名称。
    IoT 中心名称 MyASAIoTHub 选择 IoT 中心的名称。
    区域 <选择离用户最近的区域> 选择可以托管 IoT 中心的地理位置。 使用离用户最近的位置。
    免费 对于本快速启动,请选择免费(如果它在您的订阅中仍然可用)。 如果免费层不可用,请选择可用的最低层。 有关详细信息,请参阅 IoT 中心定价

    显示 Azure 门户中的“创建 IoT 中心”向导的屏幕截图。

  4. 选择“查看 + 创建”。 查看 IoT 中心信息,然后选择“ 创建”。 创建 IoT 中心可能需要几分钟时间。 可以在 “通知 ”窗格中监视进度。

  5. 部署完成后,选择“ 转到资源 ”以导航到 IoT 中心的 IoT 中心页。

  6. IoT 中心页上,在左侧导航菜单上选择“设备管理”下的“设备”。

  7. 在“ 设备 ”页上,选择工具栏上的 “+ 添加设备 ”。

    显示“设备”页的屏幕截图,其中选择了“添加设备”。

  8. 在“ 创建设备 ”页上,输入设备的名称,然后选择“ 保存”。

    显示“创建设备”页的屏幕截图。

  9. 创建设备后,从 IoT 设备 列表中打开设备。 如果尚未看到设备,请刷新页面。

    显示设备列表的屏幕截图,其中显示了你创建的设备。

  10. 复制 主连接字符串 并将其保存到记事本,以供以后使用。

创建 Blob 存储

  1. 在 Azure 门户的左上角,选择“创建资源>存储帐户>”。

  2. “创建存储帐户 ”窗格中,输入存储帐户名称、位置和资源组。 选择与创建的 IoT 中心相同的位置和资源组。 然后选择 “查看 + 创建 ”以创建帐户。

    显示 Azure 门户中的“创建存储帐户”页的屏幕截图。

  3. 创建存储帐户后,在“概述”窗格中选择“Blob 服务”磁贴。

    显示“存储帐户概述”页的屏幕截图,其中选择了“Blob 服务”。

  4. Blob 服务 页上,选择工具栏上的 + 容器

  5. “新建容器 ”页上,输入容器的名称,例如 container1。 将 公共访问级别 保留为 “专用”(无匿名访问), 然后选择“ 创建”。

    显示“新建容器”页的屏幕截图。

创建流分析项目

  1. 启动 Visual Studio。

  2. 选择 “文件 > 新建项目”。

  3. 在左侧的模板列表中,选择 “流分析”,然后选择 “Azure 流分析应用程序”。

  4. 输入项目名称位置和解决方案名称,然后选择“创建”。

    显示“创建流分析项目”对话框的屏幕截图。

  5. 请注意 Azure 流分析项目中包含的元素。

    显示 Visual Studio 中示例流分析应用程序项目的“解决方案资源管理器”窗口的屏幕截图。

选择所需的订阅

  1. 在 Visual Studio 的 “视图 ”菜单上,选择 “服务器资源管理器”。
  2. 右键单击 Azure,选择“ 连接到Microsoft Azure 订阅”,然后使用 Azure 帐户登录。

定义输入

  1. 解决方案资源管理器中,展开 “输入” 节点,然后双击 Input.json

  2. 使用以下值填写 流分析输入配置

    设置 建议的值 说明
    输入别名 Input 输入一个名称,用于标识作业的输入。
    源类型 数据流 选择适当的输入源:数据流或引用数据。
    来源 IoT 中心 选择适当的输入源。
    Resource 从当前帐户中选择数据源 选择手动输入数据或选择现有帐户。
    Subscription <订阅> 选择包含您已创建的 IoT 中心的 Azure 订阅。
    IoT 中心 MyASAIoTHub 选择或输入 IoT 中心的名称。 如果在同一订阅中创建 IoT 中心名称,则会自动检测它们。
  3. 将其他选项保留为默认值,然后选择“ 保存 ”以保存设置。

    显示“流分析输入配置”页的屏幕截图。

定义输出

  1. 解决方案资源管理器中,展开 “输出 ”节点,然后双击 Output.json

  2. 使用以下值填写 流分析输出配置

    设置 建议的值 说明
    输出别名 输出 输入名称以识别任务的输出。
    接收器 Data Lake Storage Gen 2/Blob Storage 选择适当的汇聚点。
    Resource 手动提供数据源设置 选择手动输入数据或选择现有帐户。
    Subscription <订阅> 选择具有您所创建存储帐户的 Azure 订阅。 存储帐户可以位于同一订阅中或不同订阅中。 此示例假定已在同一订阅中创建存储帐户。
    存储帐户 asa快速启动存储 选择或输入存储帐户的名称。 如果存储帐户名称在同一订阅中创建,则会自动检测它们。
    集装箱 container1 选择在存储帐户中创建的现有容器。
    路径模式 输出 输入要在容器中创建的文件路径的名称。
  3. 将其他选项保留为默认值,然后选择“ 保存 ”以保存设置。

    显示“流分析输出配置”页的屏幕截图。

定义转换查询

  1. 从 Visual Studio 中的解决方案资源管理器打开 Script.asaql

  2. 添加以下查询:

    SELECT *
    INTO Output
    FROM Input
    WHERE Temperature > 27
    

将流分析查询提交到 Azure

  1. 查询编辑器中,在脚本编辑器中选择“ 提交到 Azure ”。

  2. “提交作业 ”窗口中,选择“ 创建新的 Azure 流分析作业”。

  3. 输入 作业名称

  4. 选择 Azure 订阅

  5. 选择 资源组

  6. 保留 群集的默认值。

  7. 选择您在快速入门开头使用的位置

  8. 然后选择“ 提交”。

    显示“提交作业”对话框的屏幕截图。

运行 IoT 模拟器

  1. 在新浏览器选项卡或窗口中打开 Raspberry Pi Azure IoT Online 模拟器

  2. 将第 15 行中的占位符替换为在上一部分中保存的 Azure IoT 中心设备连接字符串。

  3. 选择 运行。 输出会显示传感器数据和发送到 IoT 中心的消息。

    显示 Raspberry Pi Azure IoT Online 模拟器的屏幕截图。

启动流分析作业并检查输出

  1. 创建作业后,作业视图会自动打开。 选择绿色箭头按钮以启动作业,

    显示从 Visual Studio 启动流分析作业的“开始”按钮的屏幕截图。

  2. 作业输出启动模式 更改为 JobStartTime ,然后选择“ 启动”。

    显示“流分析启动作业配置”对话框的屏幕截图。

  3. 请注意,作业状态已更改为 “正在运行”,并且存在输入/输出事件。 这可能需要几分钟的时间。 选择工具栏上的 “刷新 ”按钮以刷新指标。

    屏幕截图显示作业状态为正在运行,以及作业的指标。

  4. 若要查看结果,请在 “视图 ”菜单上选择 “云资源管理器”,然后导航到资源组中的存储帐户。 在 Blob 容器下,双击 container1,然后单击 输出 文件路径。

    查看结果

清理资源

若不再需要资源组、流式处理作业以及所有相关资源,请将其删除。 删除作业可避免对作业使用的流单元进行计费。 如果计划在将来使用该作业,可以先停止它,等到以后需要时再重启它。 如果不打算继续使用该作业,请按照以下步骤删除本快速入门创建的所有资源:

  1. 在 Azure 门户的左侧菜单中选择“资源组”,然后选择已创建资源的名称。
  2. 在资源组页上选择“删除”,在文本框中键入要删除的资源的名称,然后选择“删除”。

后续步骤

在本快速入门中,你已使用 Visual Studio 部署了一个简单的流分析作业。 还可以使用 Azure 门户PowerShell 部署流分析作业。

若要了解适用于 Visual Studio 的 Azure 流分析工具,请继续阅读以下文章: