简体中文
简体中文
English
联系我们
注册
登录

管理规则引擎

更新时间:2021-07-08 12:48:34下载pdf

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

管理规则引擎

  1. 登录 数据分析平台
  2. 在左侧左侧导航栏中,选择 数据 > 数据分析 > 数据源,进入数据源管理页面。
    创建的规则引擎都会在这个列表页进行管理,列表中表头介绍如下:
    管理规则引擎
    表头 说明
    规则名称 自定义的规则名称,128 位之内。这里的规则是一个链接, 蓝色字,点击的话会直接进入该规则详情中
    类型 构建规则的类型,包含 代码编辑低代码编辑 。目前仅开放了 代码编辑
    创建时间 规则的创建时间。
    更新时间 规则最近更新的时间
    处理数据源 规则引擎所处理的原始数据源
    状态 目前有四种状态:
    • 待执行:规则创建后从未启动的状态为 待执行
    • 执行中:单击 启动 之后,规则状态变更为 执行中
    • 停止:对状态为 执行中 的规则,单击 停止 之后,状态变更为 停止
    • 执行失败:在规则执行过程中因为异常而停止时,状态变更为 执行失败
    操作
    • 编辑:单击之后进入规则编辑的首页。
    • 删除:将该规则删除,当状态为 执行中 时,不可用。
    • 启动/停止:单击切换规则引擎的状态。

代码化编辑创建规则引擎

前提条件

已有至少一个数据源。

操作步骤

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

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

  3. 配置脚本。

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

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

      管理规则引擎

    注意

    • Flink SQL 编辑框中 select 的字段必须使用 as 做重命名。
    • 暂不支持 updateinsert 操作。
    • 公测期间只能使用汇总数据,且无法保存明细数据,SQL 中必须存在 group by 的关键词。
  4. 配置数据流转。当前仅支持实时表的形式存储,暂未开放 Kafka、MQTT 等协议的消息供下游消费。

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

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

  5. 测试规则引擎。

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