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

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

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

1574731010100350.png

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

1574731046611134.png

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

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

1574731068523565.png

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

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

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

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

1574731098292351.png

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

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

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

1574731192868014.png

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

1574731250497524.png

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

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

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