工作流开发
Blink开发平台,集成了工作流的开发和运维界面,为用户提供了一站式批/流/工作流的开发和运维平台。
基本概念
- 流程:一个流程就是一个工作流
- BatchSQL/Shell/Python:流程支持的节点类型,BatchSQL为Blink Batch作业,Shell/Python为脚本类节点类型。
开发
新建流程
进入流计算开发工作台,点击新建流程
在流程中新建节点
将需要的节点类型拖入画布。
编辑各个节点
双击画布中的某个节点,即进入节点编辑界面。用户可试运行单个节点的脚本/作业。注意:节点编辑完成后必须可上线
。整个流程才能上线并运行。
配置流程调度信息
流程画板的右侧,有调度信息编辑界面,目前支持最小5分钟粒度的定时调度,调度规则跟Airflow相同。
流程上线
流程开发完后,需要上线才能在运维界面启动。注意:流程内所有节点必须上线,整个流程才能上线。如果流程上线
按钮灰掉,请检查各个节点的上线状态。
本文转自实时计算——工作流开发