1.48. # PUT /api/machinelearning/workflowsave¶
上传工作流
## 参数
名称 |
类型 |
是否必传 |
备注 |
current_userid nodes nodes.#.id nodes.#.name nodes.#.type nodes.#.comment nodes.#.resource_id nodes.#.prepare nodes.#.prepare.#.pname nodes.#.prepare.#.pvalue nodes.#.configuration nodes.#.configuration.#.cname nodes.#.configuration.#.cvalue nodes.#.property nodes.#.property.#.proname nodes.#.property.#.provalue nodes.#.failto nodes.#.out_ports nodes.#.in_ports nodes.#.pos_x nodes.#.pos_y edges |
int array int string int string int array string string array array array array array array string array array string string array |
Y Y Y Y Y Y Y Y Y Y Y Y Y Y Y Y Y Y Y Y Y Y |
当前登录用户ID 工作流节点list 节点id,可以不用显示,用于前端回传。Integer自增,前端从100开始新增,每增加一个工作流节点,id为新节点分配自增1的ID标识,当旧的节点被删除时,新节点ID分配不受影响,仍从该工作流中的Max(action_id)开始自增;其中start、end、fail(globle)节点的id为1,2,3不可修改 节点名称,该action_name即后端存储并标识的name,不再单独设立中文名称,整个workflow中每个节点的name必须唯一,命名规范请参考备注 节点类型,1-start ; 2-end ; 3-fail ; 4-fork ; 5-join ; 6-decision ; 7-spark ; 8-mapreduce ; 9-shell ; 10-hive 待补充完善 节点描述 节点绑定的资源ID 预处理信息list 节点预处理名称,暂时可选mkdir、delete 节点预处理路径,hdfs路径字符串 配置信息list 节点配置名称,由用户输入,即使不符合规定,也可以保存workflow,在执行workflow的时候再进行报错 节点配置值,由用户输入,即使不符合规定,也可以保存workflow,在执行workflow的时候再进行报错 属性信息list 节点属性名称,由用户输入,即使不符合规定,也可以保存workflow,在执行workflow的时候再进行报错 节点属性值,由用户输入,即使不符合规定,也可以保存workflow,在执行workflow的时候再进行报错 节点失败跳转fail节点名称 节点连线out端口集合,int数组 节点连线in端口集合,int数组 工作流节点位置坐标x 工作流节点位置坐标y 工作流边集合,包含src_node_id、src_output_idx、dst_node_id、dst_input_idx、id |
## 返回
1.48.1. ## 备注 (不满足以下条件,不允许提交)¶
一个workflow必包含start,end,fail三个节点,start,end,fail为关键词,每个工作流必包含一个,且start、end有且仅有一个;
一个workflow除去start,end,fail三个节点,至少包含1个节点,最多包含50个;
工作流DAG图,不允许成环;
nodes.#.configuration中每个action按对应类型传各自参数,所有参数均非必传;
nodes.#.action_name命名规范:以字母开头,由3-20位数字,字母,下划线组成,字母不区分大小写;正则表达式参考:
reg = /[0-9a-zA-Z_]{3,20}/;