Streaming Analytics 和 Internet of Things 服务入门

look_w

最常见用例概述在最常见的场景中，您拥有一组可实时生成分析所需信息的设备以及这两种服务。这两种服务是：IoT 服务：IoT 服务用于从设备中收集数据：

• 使用您的 IoT 服务注册的设备将向您的 IoT 服务发布 MQTT 消息
• 这些消息中包含您需分析的设备相关信息

Streaming Analytics 服务：Streaming Analytics 服务用于分析设备信息

• 您的 Streaming Analytics 应用将订阅发布至您的 IoT 服务上的设备消息
• 根据您在 Streaming Analytics 应用中定义的逻辑对设备消息进行分析

由于 IoT 和 Streaming Analytics 技术具有低延迟性，设备数据的分析实时完成，且这两种技术都可进行扩展，可以支持对来自数百万单独设备的信息进行分析。本用例场景可能有很多变异，但无论具体场景如何，上述信息应该可以帮助您开始一起使用这两种服务。
应用组件及其相互作用在端对端 Bluemix 应用中，下图显示了可作为部分解决方案的典型组件和实体：
图 1.    服务组成图Bluemix 应用由 Node.js 运行时、IoT 服务和 Streaming Analytics 服务组成。除了本文中所讨论的两种服务外，上图还显示了另外两种组件：i) 供应待分析数据的物理设备；以及 ii) 使用 Node.js 运行时编写的 Bluemix 应用。总体应用流程如下所述：

• 设备使用 IoT 服务注册，通过 MQTT 消息向 IoT 发布数据。
• 部署至 Streaming Analytics 服务的 Streams 应用订阅 IoT 中的设备信息。数据随 MQTT 消息流入 Streaming Analytics 服务。
• Streams 应用对设备数据流进行实时分析。根据 Streams 应用中所用的逻辑和分析执行分析。分析示例可能包括异常检测、故障预测、聚集等。
• Streams 应用以 MQTT 消息的形式将结果发回 IoT。这些消息可能被认为是通知、警报、事件等。请注意，由于分析结果的数量通常没有作为其来源的数据量大，结果 MQTT 流的量会比输入 MQTT 流的小。
• Bluemix (Node.js) 应用可以订阅发回 IoT 的结果，并根据解决方案的需要执行适当的操作。

Streaming Analytics 集成示例的实际操作本节说明了如何获得 Internet of Things 服务和 Streaming Analytics 服务的实例，以相互交换 MQTT 消息。建立这种集成后，您应该可以在这个示例的基础上进行构建，创建一个符合您具体要求的 Bluemix 应用。
创建和配置您的 Internet of Things 实例

• 登录到 Bluemix。在仪表盘中，单击 USE SERVICES（使用服务）或 APIS。从服务目录中选择 Internet of Things。选择选定的 Free 计划并单击 CREATE（创建）来创建服务。
• 将会出现欢迎页面。单击 Launch（启动）仪表盘按钮。将会出现 Internet of Things 仪表盘。
• IoT 仪表盘在页面顶部附近显示 Organization ID（组织 ID）。复制您的组织 ID 并保存，供以后使用。
• 接下来，在 IoT 仪表盘中，选择 Access（访问）和 API Keys（API 密钥）选项卡。然后单击 Generate API Key（生成 API 密钥）按钮。复制 API Key（API 密钥）和 Authentication Token（身份验证标记）值并保存，供以后使用。

创建您的 Streaming Analytics 实例在 Bluemix 仪表盘中，单击 USE SERVICES（使用服务）或 APIS。从目录中选择 Streaming Analytics。选择默认计划并单击 CREATE（创建）来创建服务。将会出现 Streaming Analytics 仪表盘。使用 Launch（启动）按钮来启动 Streaming Analytics 控制台。
下载并提交 Streams 样本应用

• 从 Bluemix DevOps Services 中的 Streams Integration Samples 项目下载 zip 文件。该 zip 文件包含您将部署的预构建 Streams 应用以及该应用的源代码。
• 将 zip 文件解压至您的本地文件系统。
• 进入之前启动的 Streaming Analytics 控制台并选择 Submit Job（提交作业）。
• 将会出现 Submit Job（提交作业）视图。单击 Browse（浏览）并导航至您解压的 zip 文件的根目录，然后进入 InternetOfThings 目录。选择 Main.sab 文件。然后单击 Submit Job（提交作业）对话框中的 Next（下一步）。
• 在下一个视图中，将提示您填写应用所需的提交时间参数。填入您在前面的步骤中保存的 Authentication_Token、Org_ID 和 API_Key 值。
• 按下 Submit（提交），然后 Streams 样本应用将会部署至您的 Streaming Analytics 实例。使用 Streaming Analytics 控制台验证作业已提交并正在运行。

图 2.Streaming Analytics Console（Streaming    Analytics 控制台）的三个视图如果成功完成上述操作步骤，您的 Streaming Analytics 现在将正在运行中。此外，您的应用将：

• 向您的 Internet of Things 实例发布 MQTT 消息
• 订阅与 IoT 中出现的消息完全相同的消息并将其发回 Streams 应用

您可以使用 Streaming Analytics 控制台验证消息是否流至 IoT 并发回 Streams 应用。从 Streams 应用发出消息并将相同的消息再发回相同的 Streams 应用并不是典型的模式，但却是说明 Streaming Analytics 和 IoT 相互交换消息机制的良好示例。