管理规则引擎

本文介绍如何在数据分析平台上管理规则引擎。

管理规则引擎

1. 登录 数据分析平台。
2. 在左侧左侧导航栏中，选择 数据 > 数据分析 > 数据源，进入数据源管理页面。
   创建的规则引擎都会在这个列表页进行管理，列表中表头介绍如下：
   

   表头	说明
   规则名称	自定义的规则名称，128 位之内。这里的规则是一个链接， 蓝色字，点击的话会直接进入该规则详情中
   类型	构建规则的类型，包含 代码编辑 和 低代码编辑 。目前仅开放了 代码编辑。
   创建时间	规则的创建时间。
   更新时间	规则最近更新的时间
   处理数据源	规则引擎所处理的原始数据源
   状态	目前有四种状态： 待执行：规则创建后从未启动的状态为 待执行。 执行中：单击 启动 之后，规则状态变更为 执行中。 停止：对状态为 执行中 的规则，单击 停止 之后，状态变更为 停止。 执行失败：在规则执行过程中因为异常而停止时，状态变更为 执行失败。
   操作	编辑：单击之后进入规则编辑的首页。 删除：将该规则删除，当状态为 执行中 时，不可用。 启动/停止：单击切换规则引擎的状态。

代码化编辑创建规则引擎

前提条件

已有至少一个数据源。

操作步骤

1. 左侧导航栏中，选择 数据 > 数据分析 > 规则引擎。

2. 单击 新建规则。
   目前低代码编辑暂未开放，因此默认为代码化编辑方式。
   

3. 配置脚本。

   1. 输入规则名称，并选择数据源和数据类型（默认为上报类型）。
      页面显示该数据的表名和表结构。

   2. 按照表结构的描述，在右边的代码编辑框中编写 Flink SQL 语句。
      我们内置了一些常用模版，您可以直接通过模版导入快速然后基于模版修改快速进行代码编辑。
      

      

   注意：

   • Flink SQL 编辑框中 select 的字段必须使用 as 做重命名。
   • 暂不支持 update 和 insert 操作。
   • 公测期间只能使用汇总数据，且无法保存明细数据，SQL 中必须存在 group by 的关键词。

4. 配置数据流转。当前仅支持实时表的形式存储，暂未开放 Kafka、MQTT 等协议的消息供下游消费。

   • 数据存储表名：用户自定义。
   • 数据存储周期：数据存储的周期，目前仅 7 天、14 天、30 天可选。
   • 表字段定义：表字段是根据前面 Flink SQL 解析得到，您可以重新设置该字段的数据类型与描述，并且决定是否创建该字段的索引。
     

   说明：创建索引会将您的查询分页加速，并但是会额外消耗存储，建议按需选择。

5. 测试规则引擎。

   1. 单击页面下方的 测试。
   2. 在弹出的窗口中进行该任务的预跑，包含数据源消息订阅、实时处理、数据表写入等完整步骤。
      全部测试通过才能完成规则的最终创建。测试失败时，您可以关闭该窗口返回做修改，每次修改之后都需要重新测试通过后方可创建规则。