Get Flow

获取指定ID的任务流信息。

前提条件

用户必须属于目标任务流所属的OU。

请求格式

GET https://{apigw-address}/dataflow-batch-service/v2.0/flows

请求参数（URI）

名称

位置（Path/Query）

必需/可选

数据类型

描述

flowId

Query

必需

Integer

任务流ID。

userId

Query

必需

String

用户ID。如何获取userId信息>>

orgId

Query

必需

String

用户所属的组织ID。如何获取orgId信息>>

action

Query

必需

String

固定值：get

响应参数

名称

数据类型

描述

data

List<JSONObject>

包含任务流的详细信息。详见 Flow结构体

Flow结构体

示例

{
        "flowId": 3560,
        "flowName": "outuser1",
        "active": 0,
        "creator": "yourCreator",
        "createTime": "2019-12-09 07:19:52.0",
        "updateUser": "yourUpdateUser",
        "updateTime": "2019-12-09 07:19:52.0",
        "freq": "0 0 0 * * ? *",
        "cycle": "D",
        "parameters": "[]",
        "owner": "yourOwners",
        "visitor": "yourVisitors",
        "doAs": "yourDoAs",
        "alertMode": 3,
        "alertTo": "",
        "appId": "",
        "graph": {
            "creator": "yourCreator",
            "freq": "0 0 0 * * ? *",
            "owners": "yourOwners",
            "type": 1,
            "cycle": "D",
            "alertMode": 3,
            "visitors": "yourVisitors",
            "doAs": "your_bd_account",
            "flows": [],
            "appId": "",
            "name": "outuser1",
            "startTime": "2019-07-25",
            "alertTo": "",
            "syncType": 1,
            "relations": [],
            "parameters": "[]",
            "tasks": [
                {
                    "x": 0.002,
                    "y": 0.002,
                    "taskName": "tass",
                    "nodeId": "t_106089",
                    "taskId": 106089
                }
            ],
            "queue": "",
            "desc": ""
        },
        "entry": 1,
        "type": 1,
        "syncType": 1,
        "desc": "",
        "queue": "",
        "startTime": "2019-07-25",
        "locked": false,
        "virtual": false,
        "hasEditPri": true,
        "hasReadPri": true,
        "isUserLocked": false
}

参数

名称

数据类型

描述

flowId

Integer

任务流ID。

flowName

String

任务流名称。

active

Integer

任务流调度状态（0：暂停；1：运行）。

creator

String

任务流创建者名称。

createTime

String

任务流创建时间。

updateUser

String

任务流更新者。

updateTime

String

任务流更新时间。

freq

String

任务流调度周期。调度中使用的是七位的Crontab，概括而言，Crontab可以指定某个事件在其指定的时间点被触发，比如：c1 (0 1 * * * ? *) 定义了事件在每个小时的1分0秒触发，c2 (59 59 23 * * ? *) 定义了事件在每天的23时59分59秒触发。有关Crontab的更多配置，详见 http://cron.qqe2.com/

cycle

String

调度周期（M：月；W：周；D：天；H：小时；mi：分钟）。

parameters

List<Map<key,value>>

调度参数。作为统一配置的全局参数，可以在节点内使用这些参数，以使任务运行时能动态适配环境变化（参数需要以 key-value 的格式表达，例如：[{"key":"env","value":"product"},{"key":"task_id","value":"123456"}] ）。

owner

String

任务流所有者名称（负责人）。

visitor

String

可访问者名称。

doAs

String

任务流所属组织的大数据账号。

alertMode

Integer

告警模式（0：无, 1：仅邮件告警, 2：仅短信告警, 3：邮件与短信告警）。

alertTo

String

告警对象。

appId

String

N/A，通常为空字符串。

graph

List<JSONObject>

任务流中任务依赖关系描述信息，详见 FlowGraph结构体

entry

Integer

通过何种方式创建的任务流（0：portal；1：API；2：eos）。

type

Integer

任务流调度类型（0：手动调度任务；1：周期调度任务；2：临时任务）。

syncType

Integer

同步类型（0：文件同步；1：数据同步）。

desc

String

任务流描述信息。

queue

String

计算队列。

startTime

String

任务流生效日期（即开始调度日期）。

virtual

Boolean

是否为虚任务流。

locked

Boolean

任务流是否被锁定。

hasEditPri

Boolean

是否有编辑权限。

hasReadPri

Boolean

是否有读取权限。

isUserLocked

Boolean

用户是否被锁定。

FlowGraph结构体

示例

{
    "creator": "yourCreator",
    "freq": "0 0 0 * * ? *",
    "owners": "yourOwners",
    "type": 1,
    "cycle": "D",
    "alertMode": 3,
    "visitors": "yourVisitors",
    "doAs": "your_bd_account",
    "flows": [],
    "appId": "",
    "name": "outuser1",
    "startTime": "2019-07-25",
    "alertTo": "",
    "syncType": 1,
    "relations": [],
    "parameters": "[]",
    "tasks": [
       {
          "x": 0.002,
          "y": 0.002,
          "taskName": "tass",
          "nodeId": "t_106089",
          "taskId": 106089
        }
     ],
     "queue": "",
     "desc": ""
}

参数

名称

数据类型

描述

creator

String

任务流实例创建者名称。

freq

String

任务流调度周期。调度中使用的是七位的Crontab，概括而言，Crontab可以指定某个事件在其指定的时间点被触发，比如：c1 (0 1 * * * ? *) 定义了事件在每个小时的1分0秒触发，c2 (59 59 23 * * ? *) 定义了事件在每天的23时59分59秒触发。有关Crontab的更多配置，详见 http://cron.qqe2.com/

alertMode

Integer

告警模式（0：无, 1：仅邮件告警, 2：仅短信告警, 3：邮件与短信告警）。

type

Integer

任务流调度类型（0：手动调度任务；1：周期调度任务；2：临时任务）。

owners

String

任务流实例所有者（负责人）的用户名（多个owner之间以 ; 分开，例如owners=“userNameA;userNameB”）。

visitors

String

可访问者的用户名（多个visitor之间以 ; 分开，例如visitors=“userNameA;userNameB”）。

startTime

String

任务流生效日期（即开始调度日期）。

cycle

String

调度周期（M：月；W：周；D：天；H：小时；mi：分钟）。

doAs

String

任务流所属组织的大数据账号。

flows

JSONObject

与当前任务流相关联的其他任务流的集合。详见 FlowSimpleInfo结构体

alertTo

String

告警目标。

name

String

任务流名称。

syncType

Integer

同步类型（0：文件同步；1：数据同步）。

relations

List<Relation>

任务关连线集合，集合中每个元素表示任务流中两个任务具有上下游数据关系。详见 Relation结构体

parameters

List<Map<key,value>>

调度参数。作为统一配置的全局参数，可以在节点内使用这些参数，以使任务运行时能动态适配环境变化（参数需要以 key-value 的格式表达，例如：[{"key":"env","value":"product"},{"key":"task_id","value":"123456"}] ）。

appId

String

N/A，通常为空字符串。

tasks

JSONObject

任务流中包含的任务节点的集合。集合中每个元素是一个TaskSimpleInfo结构体，该结构体包含了任务节点的简要信息。详见 TaskSimpleInfo结构体

queue

String

计算队列。

desc

String

任务流描述信息。

FlowSimpleInfo结构体

示例

{
    "flowId": 2809,
    "flowName": "21",
    "nodeId": "f_2809",
    "isVirtual": false,
    "x": 0.0125,
    "y": 0.0015
}

参数

名称

数据类型

描述

flowId

Integer

任务流ID。

flowName

String

任务流名称。

nodeId

String

作为其他任务流节点的节点ID。

isVirtual

Boolean

是否为虚任务流。

x

Double

作为节点在当前任务流配置面板中的位置，x坐标。

y

Double

作为节点在当前任务流配置面板中的位置，y坐标。

TaskSimpleInfo结构体

示例

{
  "taskName": "tass",
  "x": 0.0132,
  "y": 0.008100000381469727,
  "taskId": 104575,
  "nodeId": "t_104575"
}

参数

名称

数据类型

描述

taskName

String

任务名称。

x

Double

任务在面板中的位置信息，x坐标。

y

Double

任务在面板中的位置信息，y坐标。

taskId

Integer

任务ID。

nodeId

String

节点ID（注意：不同于任务ID。任务流中既可以有任务节点，也可以有相依赖的任务流节点，都作为该任务流的一个节点，具有唯一的节点ID）。

Relation结构体

示例

{
    cycleGap: "D0",
    rerun: true,
    source: "t_105048",
    target: "t_104575"
}

参数

名称

数据类型

描述

cycleGap

String

上下游任务调度时间差（格式为：{cycle}{offset}，cycle表示时间差单位，参见`cycle`字段的描述；offset为调度时间差具体数值）。

source

String

上游任务节点ID。

target

String

下游任务节点ID。

rerun

Boolean

true和false仅在任务级联重跑时生效。true表示重跑时，下游节点会被执行；false表示重跑时，下游节点不会被执行。

错误码

参见 通用错误码。

示例

请求示例

url: https://{apigw-address}/dataflow-batch-service/v2.0/flows?action=get&flowId=2479&userId={}&orgId={}

method: GET

返回示例

{
    "status": 0,
    "msg": "SUCCESS",
    "data": {
        "flowId": 2479,
        "flowName": "test0722-1",
        "active": 0,
        "creator": "yourCreator",
        "createTime": "2019-07-22 08:56:35.0",
        "updateUser": "yourUpdateUser",
        "updateTime": "2019-07-22 08:56:58.0",
        "freq": "0 0 0 * * ? *",
        "cycle": "D",
        "parameters": "[{\"key\":\"overwrite\",\"value\":\"true\"}]",
        "owner": "yourOwner",
        "visitor": "yourVisitor",
        "doAs": "your_bd_account",
        "alertMode": 1,
        "graph": "{\"queue\":\"\",\"cycle\":\"D\",\"desc\":\"\",\"doAs\":\"yourDoAs\",\"freq\":\"0 0 0 * * ? *\",\"visitors\":\"yourVisitors\",\"tasks\":[{\"taskName\":\"MDM-Sync\",\"taskId\":104506,\"y\":0.002,\"x\":0.002,\"nodeId\":\"t_104506\"},{\"taskName\":\"MDMHive\",\"taskId\":\"104507\",\"y\":0.009,\"x\":0.002,\"nodeId\":\"t_104507\"}],\"type\":0,\"creator\":\"yourCreator\",\"flows\":[],\"alertMode\":1,\"relations\":[{\"cycleGap\":\"D0\",\"rerun\":true,\"source\":\"t_104506\",\"target\":\"t_104507\"}],\"name\":\"test0722-1\",\"startTime\":\"2019-07-22\",\"active\":0,\"parameters\":\"[{\\\"key\\\":\\\"overwrite\\\",\\\"value\\\":\\\"true\\\"}]\",\"owners\":\"yourOwners\"}",
        "entry": 0,
        "type": 0,
        "syncType": 1,
        "desc": "",
        "startTime": "2019-07-22",
        "virtual": false,
        "locked": false,
        "hasEditPri": false,
        "hasReadPri": true,
        "isUserLocked": false
    }
}

Java SDK调用示例

import com.alibaba.fastjson.JSONObject;
import com.envision.apim.poseidon.config.PConfig;
import com.envision.apim.poseidon.core.Poseidon;
import com.envision.apim.poseidon.request.PoseidonRequest;
import org.junit.Test;

import java.util.HashMap;
import java.util.Map;

public class SampleCode{
    public static class Request extends PoseidonRequest {
        public void setQueryParam(String key, Object value){
            queryParams().put(key, value);
        }
        public void setHeaderParam(String key, String value){
            headerParams().put(key, value);
        }

        public void setBodyParam(Map<String, Object> bodyPara){
            bodyParams().putAll(bodyPara);
        }
        public void setMethod(String method) {
            this.method = method;
        }
        private String method;
        public String baseUri() {
            return "";
        }
        public String method() {
            return method;
        }
    }

    @Test
    public void getFlowTest(){
        //1.在EnOS Console的左边导航栏中点击应用注册。
        //2.点击需调用API的应用，查看基本信息中的AccessKey即为accessKey、SecretKey即为secretKey
        String accessKey = "AccessKey of your APP";
        String secretKey = "SecretKey of your APP";

        //新建一个request 然后把需要的参数传进去存在Query的map中，key是参数名字，value是参数值
        Request request = new Request();
        request.setMethod("GET");

        try {
            JSONObject response = Poseidon.config(PConfig.init().appKey(accessKey).appSecret(secretKey).debug())
                    .url("https://{apigw-address}/dataflow-batch-service/v2.0/flows")
                    .queryParam("orgId", "yourOrgId")
                    .queryParam("userId", "yourUserId")
                    .queryParam("flowId", "2479")
                    .queryParam("action", "get")
                    .getResponse(request, JSONObject.class);

            System.out.println(response);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}