第四招数据转发至大数据平台分析

物联网解决方案中，作为数据主体的“物”可能数量会非常大，产生的数据已经无法通过传统的数据处理服务进行处理，如何分析与利用这庞大的物联网设备数据对物联网企业来说又是一个新的挑战。为此，华为云提供了大数据分析服务（MapReduce服务 MRS）。MRS是一个在华为云上部署和管理Hadoop系统的服务，一键即可部署Hadoop集群。MRS提供租户完全可控的企业级大数据集群云服务，轻松运行Hadoop、Spark、HBase、Kafka、Storm等大数据组件，并具备在后续根据业务需要进行定制开发的能力。因此，我们仅需将数据转发至MRS，然后就可以看MRS大展身手了。于是，又轮到规则引擎出场了。数据转发规则虽然不支持将数据直接转发至MRS，但支持将数据转发至DIS，DIS再将数据转发至MRS。

在上一招中，我们将数据转发到DIS后，由第三方应用直接取出。而在这一招中，我们利用了DIS的另一个能力，转储任务。DIS支持将通道内的数据通过定时任务的方式转储至其他服务，其中就包括MRS。通过规则引擎和DIS，我们就可以将设备上报的数据全自动转发至MRS，由MRS进行大数据分析。

第五招数据转发至ROMA进行集成

对一些企业来说，物联网设备上报的数据仅仅是他们业务数据的一部分，单纯的设备上报数据没有意义，他们需要将多种数据集成起来，才能发挥数据的真正价值。为了这样的企业，华为云提供了应用与数据集成平台 ROMA。ROMA是一个全栈式的应用与数据集成平台，源自华为数字化转型集成实践，聚焦应用和数据连接，适配多种企业常见的使用场景。ROMA提供轻量化消息、数据、API、设备等集成能力，简化企业上云，支持云上云下、跨区域集成，帮助企业实现数字化转型。物联网平台规则引擎支持将数据转发至ROMA的消息集成（Message Queue Service，简称MQS）组件，为企业提供安全、标准化的消息通道。

ROMA的MQS组件是基于kafka的消息中间件，所以物联网平台转发数据至ROMA，本质上来说也是讲数据转发到一个数据通道中，但ROMA作为集成平台，提供了多种应用和数据集成组件，完成数据的统一化和标准化，方便用户统一获取后进一步利用。

第六招根据上报数据自动控制设备行为

现在的很多设备都能做到自动化管理，例如照明灯根据环境光强自动开关，高发热量的设备根据自身温度自动关机等。这些自动化逻辑可以直接烧录到设备中，也可以通过云端设置和执行。若将逻辑直接烧录到设备中，优点是设备反应快，但缺点是需要每个设备单独烧录，而且如果逻辑有变化必须一个个设备重新烧录，非常难以管理。若将逻辑设置到云端，虽然设备的反应速度会有所降低，但逻辑只需云端维护，修改起来也非常方便，因此，我们建议对反应速度要求不是特别高的自动化逻辑都设置到云端。规则引擎中的设备联动服务提供图形化的操作界面，通过简单的操作即可实现设备的自动化逻辑，厂商无需再自行开发第三方应用。

以上文中的照明灯根据环境光强自动开关为例，我们可以设置两条规则，一条是当设备上报数据中的环境光强小于一个阈值（如50）时，物联网平台自动给设备下发开灯命令。另一条则是当设备上报数据中的环境光强大于一个阈值（如500）时，物联网平台自动给设备下发关灯命令。

通过这两条规则，我们可以实现当设备检测到的环境光强小于50时自动开灯，环境光强大于500时自动关灯，达到智能照明的目的。

第七招根据上报数据触发告警

物联网平台支持告警能力，设备触发告警条件后会在物联网平台上显示一条告警，用户查看告警可以得知告警级别，告警来源（指是哪个设备产生的告警），告警内容等，方便用户更快定位问题设备，及时解决问题。

而这个告警，也是通过设备联动规则产生的。设备联动规则支持设备上报的数据满足条件时，在物联网平台上显示一条告警，告警的信息（类型、级别、名称、内容）均可自定义。

通过这种方式，用户可以自定义业务所需的告警，实现设备异常及时定位，业务管理更高效。

本文转载自华为云社区博客。

原文链接：https://bbs.huaweicloud.com/blogs/134889

创作场景

8 招带你玩转规则引擎（二）