快速入门：使用 Azure 门户创建流分析作业

在本快速入门中，请通过 Azure 门户创建流分析作业。请定义一项流分析作业，以读取实时流数据并筛选温度大于 27 摄氏度的消息。该流分析作业会从 IoT 中心读取数据，对数据进行转换，然后将输出数据写入到 Azure blob 存储中的容器。本快速入门中使用的输入数据是使用 Raspberry Pi 联机模拟器生成的。

先决条件

如果没有 Azure 订阅，请创建一个试用帐户。

对输入数据进行准备

在定义流分析作业之前，请准备输入数据。该解决方案将实时传感器数据引入 IoT 中心，稍后将其配置为作业输入。若要对作业所需的输入数据进行准备，请完成以下步骤：

登录 Azure 门户。
选择“创建资源”。在“创建资源”页中，选择“物联网”“IoT 中心”。
在“IoT 中心”页中，执行以下步骤：
1. 在“订阅”中，选择你的 Azure 订阅。
2. 对于“资源组”，选择现有资源组或创建新的资源组。
3. 对于“IoT 中心名称”，输入你的 IoT 中心的名称。
4. 对于“区域”，选择离你最近的区域。
5. 对于套餐，请选择免费（如果您的订阅中仍然可用）。有关详细信息，请参阅 IoT 中心定价。
6. 对于“每日消息数量限制”，保留默认值。
7. 在页面底部点击“下一步：网络设置”。
选择“查看 + 创建”。查看 IoT 中心信息，然后选择“创建”。创建 IoT 中心可能需要数分钟的时间。可在“通知”窗格中监视进度。
创建资源（IoT 中心）后，选择“转到资源”以导航到“IoT 中心”页。
在“IoT 中心”页中，选择左侧菜单中的“设备”，然后选择“+ 添加设备”。
输入设备 ID，然后选择“保存”。
创建设备后，可在 IoT 设备 列表中看到设备。如果未看到，请选择页面上的“刷新”按钮。
从列表中选择自己的设备。
在“设备”页面上，选择“主连接字符串”旁边的复制按钮，并将其保存到记事本以供稍后使用。

运行 IoT 模拟器

打开 Raspberry Pi Azure IoT 联机模拟器。
将第 15 行中的占位符替换为在上一部分中保存的 Azure IoT 中心设备连接字符串。
选择“运行”。输出显示发送到 IoT 中心的传感器数据和消息。

创建 Blob 存储

从 Azure 门户的左上角选择“创建资源”。在左侧菜单的“类别”下选择“存储”，然后选择“存储帐户”。
在 “存储帐户 ”页上，选择“ 创建 ”开始创建存储帐户。
在 “创建存储帐户 ”页中，执行以下步骤：
1. 输入存储帐户名称、位置和资源组。选择与创建的 IoT 中心相同的位置和资源组。然后，在页面底部选择“查看”。
2. 对于 首选存储类型，请选择 Azure Blob 存储或 Azure Data Lake Storage Gen2。此选项允许将存储帐户用于流分析作业输出。
3. 在页面底部选择“查看 + 创建”。复查你的设置。
在 “审阅 + 创建 ”页上，查看设置，然后选择“ 创建 ”以创建帐户。
创建资源后，选择“转到资源”以导航到“存储帐户”页。
在 “存储帐户 ”页上，选择左侧菜单中的 “容器 ”，然后选择“ + 添加容器”。
在“新建容器”页中，为容器提供名称（例如 container1），然后选择“创建”。

创建流分析作业

在同一浏览器窗口的单独选项卡上或在单独的浏览器窗口中，登录到 Azure 门户。
在左侧菜单中，选择所有服务。在类别下选择分析。将鼠标悬停在 流分析作业上，然后选择 + 或者在弹出窗口中选择 + 创建。
在新 流分析作业上，执行以下步骤：
1. 在“订阅”中，选择你的 Azure 订阅。
2. 对于“资源组”，请选择之前在本快速入门中使用的同一资源。
3. 在“名称”中，为作业输入一个名称。流分析作业名称只能包含字母数字字符、连字符和下划线，其长度必须介于 3 到 63 个字符之间。
4. 对于“托管环境”，确认选中“云”。流分析作业可以部署到云或边缘设备。云功能允许你部署到 Azure 云，Edge 功能支持部署到 IoT Edge 设备。
5. 对于“流单位”，请选择“1”。流处理单元表示执行作业所需的计算资源。若要了解如何缩放流单元，请参阅了解和调整流单元一文。
6. 在页面底部选择“查看 + 创建”。
在 “查看 + 创建”、“查看设置”并选择“ 创建 ”以创建流分析页面。
在“部署”页中选择“转到资源”，以导航到“流分析作业”页。

配置作业输入

在此部分，您将配置 IoT 中心的设备输入以与流分析任务配合使用。使用在快速入门的上一节中创建的 IoT 中心。

在流分析作业页上，在左侧菜单中的“作业拓扑”下选择“输入”。
在“输入”页面上，选择添加输入>IoT 中心。
在“IoT 中心”页中，执行以下步骤：
1. 对于“输入别名”，请输入“IoTHubInput”。
2. 对于“订阅”，选择包含之前创建的 IoT 中心的订阅。本快速入门假定在同一订阅中创建 IoT 中心。
3. 对于“IoT 中心”，请选择你的 IoT 中心。
4. 选择“保存”以保存流分析作业的输入设置。

配置作业输出

在左侧菜单中的“作业拓扑”下选择“输出”。
在输出页面上，选择添加输出>Blob 存储/ADLS Gen2。
在“Blob 存储/ADLS Gen2”的“新建输出”页中，执行以下步骤：
1. 对于“输出别名”，输入“BlobOutput”。
2. 对于“订阅”，选择包含之前创建的 Azure 存储帐户的订阅。本快速入门假定在同一订阅中创建存储帐户。
3. 对于 存储帐户，请选择存储帐户。
4. 对于“容器”，如果尚未选择，请选择你的 Blob 容器。
5. 对于身份验证模式，请选择连接字符串。
6. 选择页面底部的“保存”以保存输出设置。

定义转换查询

在左侧菜单中的“作业拓扑”下选择“查询”。
将以下查询输入到查询窗口中。在此示例中，查询从 IoT 中心读取数据，然后将其复制到 Blob 中的新文件。
```
SELECT *
INTO BlobOutput
FROM IoTHubInput
WHERE Temperature > 27
```
在工具栏上选择“保存查询”。