更新时间:2022-07-01 GMT+08:00
Flink模板管理
Flink模板包括样例模板和自定义模板。用户可以在已有的样例模板中进行修改,来实现实际的作业逻辑需求,节约编辑SQL语句的时间。也可以根据自己的习惯和方法自定义作业模板,方便后续可以直接调用或修改。
Flink模板管理主要包括如下功能:
样例模板
样例模板列表显示已有的样例作业模板,样例模板列表参数说明如表 1所示。
参数 |
参数说明 |
---|---|
名称 |
模板名称,只能由英文、中文、数字、中划线和下划线组成,并且长度为1~64个字符。 |
描述 |
模板的相关描述,且长度为0~512个字符。 |
操作 |
“创建作业”:直接在该模板下创建作业,创建完后,系统跳转到 下的作业编辑页面。 |
当前已有的样例模板包括如下场景:
- NGINX访问日志实时ETL入库
- 套牌车辆检测
- 电子围栏告警
- 车辆偏航告警
- 车辆超速告警
- 流式随机森林异常检测
- CloudTable-DLI Flink-CloudTable
- DIS-DLI Flink-CSS(Elasticsearch)
- DIS-DLI Flink-CloudTable(OpenTSDB)
- DIS-DLI Flink-CloudTable
- DIS-DLI Flink-DCS
- DIS-DLI Flink-DDS(MongoDB)
- DIS-DLI Flink-DIS
- DIS-DLI Flink-OBS-DWS
- DIS-DLI Flink-SMN
- Kafka-DLI Flink-Kafka
- OBS-DLI Flink-RDS
- Stream-Join-Table(DCS)
- Stream-Join-Table(RDS)
新建模板
创建作业模板,有以下四种方法。
- 进入
- 在DLI管理控制台的左侧导航栏中,单击 > 。
- 单击页面右上角“创建模板”,弹出 页面。
- 输入“名称”和“描述”。
表3 模板配置信息 参数
参数说明
名称
模板名称,只能由字母、中文、数字、中划线和下划线组成,并且长度为1~64个字符。
说明:模板名称必须是唯一的。
描述
模板的相关描述,且长度为0~512字符。
- 单击“确认”,进入 页面。
按照从左到右,从上到下的顺序说明如下:
表4 界面介绍 功能
描述
名称
可以修改模板名称。
描述
可以修改模板描述。
保存方式
- 修改:将修改保存至当前的模板中。
- 新增:将修改另存为新的模板。
SQL语句编辑区域
输入详细的SQL语句,实现业务逻辑功能。SQL语句的编写请参考《数据湖探索SQL语法参考》。
保存
保存修改。
创建作业
使用当前模板创建作业。
格式化
对SQL语句进行格式化,将SQL语句格式化后,需要重新编辑SQL语句。
更改页面风格(黑色底或白色底)。
- 在SQL语句编辑区域,输入SQL语句,实现业务逻辑功能。SQL语句的编写请参考《数据湖探索SQL语法参考》。
- SQL编辑完成后,单击右上角的“保存”,完成创建模板。
- (可选)如果不需要进行修改,也可以单击右上角的“创建作业”基于当前模板创建作业。创建作业请参考创建Flink SQL作业和创建Flink自定义作业。
页面新建模板。
- 基于现有作业模板新建模板
- 在DLI管理控制台的左侧导航栏中,单击“自定义模板”页签。 > ,单击
- 在自定义模板列表中,单击所需作业模板“操作”列中的“编辑”,进入 页面。
- 修改完成后,“保存方式”选择“新增”。
- 单击右上角“保存”,完成另存一个新模板。
- 基于新建作业新建模板
- 在DLI管理控制台的左侧导航栏中,单击“Flink作业”页面。 > ,进入
- 单击右上角“创建作业”,弹出“创建作业”页面。
- 配置作业信息,输入“名称”和“描述”,选择“模板”。
- 单击“确认”,进入 页面。
- SQL编辑完成后,单击“设为模板”,弹出“设为模板”窗口。
- 输入“名称”和“描述”,单击“确认”,完成另存一个新模板。
- 基于现有作业新建模板
- 在DLI管理控制台的左侧导航栏中,单击“Flink作业”页面。 > ,进入
- 在作业列表中,选择一个需要设置为模板的作业,在“操作”列单击“编辑”,进入 页面。
- SQL编辑完成后,单击“设为模板”窗口。 ,弹出
- 输入“名称”和“描述”,单击“确认”,完成另存一个新模板。
基于模板新建作业
用户可以基于样例模板或者自定义模板新建作业。
- 在DLI管理控制台的左侧导航栏中,单击 > 。
- 在样例模板列表中,单击对应模板“操作”列中的“创建作业”。创建作业请参考创建Flink SQL作业和创建Flink自定义作业。
父主题: 作业模板