List Flow Instances¶

查询满足条件的所有任务流实例。

前提条件¶

用户必须为EnOS用户。

请求格式¶

POST https://{apigw-address}/dataflow-batch-service/v2.0/flowInstances

请求参数（URI）¶

名称	位置（Path/Query）	必需/可选	数据类型	描述
userId	Query	必需	String	用户ID。如何获取userId信息>>
orgId	Query	必需	String	用户所属的组织ID。如何获取orgId信息>>
action	Query	必需	String	固定值：search

请求参数（Body）¶

名称	必需/可选	数据类型	描述
type	必需	Integer	任务流实例调度类型（0：手动调度任务；1：周期调度任务；2：临时任务）。
expression	可选	String	指定在 flowInstanceId 和 flowName 字段中模糊匹配查询条件（若不指定，则返回当前用户相关的所有任务流实例）。
owner	必需	String	任务所有者的用户名（若该字段为空字符串，则不对 owner 字段进行过滤）。
fromTriggerTime	必需	Long	与 toTriggerTime`参数配合使用，查询调度时间（ `triggerTime ）在 [fromTriggerTime,toTriggerTime) 范围内的任务流实例（单位为毫秒）。
toTriggerTime	必需	Long	与 fromTriggerTime`参数配合使用，查询调度时间（ `triggerTime ）在 [fromTriggerTime,toTriggerTime) 范围内的任务流实例（单位为毫秒）。
status	必需	String	任务流实例的状态，状态描述参见 FlowInstanceStatus （同时搜索多种状态，用英文逗号隔开，如status=”1,2,3”；若该字段为空字符串，则不对 status 字段进行过滤）。
pagination	必需	Pagination请求结构体	分页信息结构体。详见 Pagination请求结构体

FlowInstanceStatus¶

Status	描述
-1	FAIL
0	INIT
1	SUCCESS
2	RUNNING
3	SUSPEND
4	INTERNAL_ERROR
5	WAIT
6	READY
7	TIMEOUT
8	CANCEL
9	RERUN
10	SKIP

Pagination请求结构体¶

示例¶

{
    "pagination": {
        "pageNo": 0,
        "pageSize": 10,
        "sorters": [{
            "field": "start_time",
            "order": "ASC"
        }]
    }
}

参数¶

名称	必需/可选	数据类型	描述
pageNo	必需	Integer	请求页数，从 0 开始。
pageSize	必需	Integer	每页记录数，必须大于 0 。
sorters	可选	jsonArray	分页排序方式（sorters结构体包含两个字段：sorter.field 和 sorter.order，具体见下方 sorters 参数展开）

sorters¶

名称	必需/可选	数据类型	描述
field	必需	String	分页字段名称。支持字段：create_time，update_time，start_time ，trigger_time, end_time。
order	可选	String	ASC 表示正序排序，DESC 表示倒序排序，默认为正序排序。

响应参数¶

名称	数据类型	描述
data	List<JSONObject>	包含获取到的所有任务流实例信息和数量。详见 FlowInstances结构体

FlowInstances结构体¶

示例¶

{
    "flowInsts":[],
    "count":0
}

参数¶

名称	数据类型	描述
flowInsts	JSONObject	任务流实例集合。详见 FlowInstance结构体
count	Integer	获取的任务流实例数量，即flowInsts中元素个数。

错误码¶

代码

错误信息

描述

62102

illegal sorted by field

输入参数 sorters 不正确。参数 field 应为以下字段之一：

create_time
update_time
start_time
trigger_time
end_time

有关其他错误码的描述，参见通用错误码。

示例¶

请求示例¶

url: https://{apigw-address}/dataflow-batch-service/v2.0/flowInstances?action=search&userId={}&orgId={}

method: POST

requestBody:
{
    "type": 1,
    "fromTriggerTime": 1573648355000,
    "toTriggerTime": 1573698120000,
    "status": 1,
    "owner": "",
    "expression": "",
    "pagination":{
        "pageNo": 0,
        "pageSize": 10,
        "sorters": [{
            "field": "update_time",
            "order": "ASC"
        }]
    }
}

返回示例¶

{
  "status": 0,
  "msg": "SUCCESS",
  "data": {
    "flowInsts": [{
                "instanceId": "2809-20190812080700",
                "flowId": 2809,
                "flowName": "21",
                "freq": "0 0 0 * * ? *",
                "cycle": "D",
                "parameters": "[]",
                "doAs": "your_bd_account",
                "graph": "{\"creator\":\"yourCreator\",\"freq\":\"0 0 0 * * ? *\",\"alertMode\":3,\"owners\":\"yourOwners\",\"cycle\":\"D\",\"doAs\":\"yourDoAs\",\"flows\":[],\"alertTo\":\"\",\"name\":\"21\",\"instId\":\"2809-20190812080700\",\"id\":2809,\"relations\":[],\"parameters\":\"[]\",\"appId\":\"\",\"tasks\":[{\"taskName\":\"tass\",\"taskInstId\":\"104890-20190812080700\",\"x\":0.002,\"y\":0.002,\"taskId\":104890,\"nodeId\":\"t_104890\"}]}",
                "status": 1,
                "statusDesc": "SUCCESS",
                "triggerTime": "2019-08-12 08:07:22",
                "startTime": "2019-08-12 08:07:30",
                "endTime": "2019-08-12 08:07:32",
                "timestamp": "2019-08-12 08:09:48.0",
                "virtual": false,
                "owner": "yourOwners",
                "hasEditPri": true,
                "hasReadPri": true,
                "isCancelled": false
            },
            {
                "instanceId": "2957-20190812075600",
                "flowId": 2957,
                "flowName": "fdd",
                "freq": "0 0 0 * * ? *",
                "cycle": "D",
                "parameters": "[]",
                "doAs": "your_bd_account",
                "graph": "{\"creator\":\"yourCreator\",\"freq\":\"0 0 0 * * ? *\",\"alertMode\":3,\"owners\":\"yourOwners\",\"cycle\":\"D\",\"doAs\":\"yourDoAs\",\"flows\":[],\"alertTo\":\"\",\"name\":\"fdd\",\"instId\":\"2957-20190812075600\",\"id\":2957,\"relations\":[],\"parameters\":\"[]\",\"appId\":\"\",\"tasks\":[{\"taskName\":\"gg\",\"taskInstId\":\"105040-20190812075600\",\"x\":0.0068,\"y\":0.0071,\"taskId\":105040,\"nodeId\":\"t_105040\"}]}",
                "status": 1,
                "statusDesc": "SUCCESS",
                "triggerTime": "2019-08-12 07:56:56",
                "startTime": "2019-08-12 07:57:00",
                "endTime": "2019-08-12 07:57:02",
                "timestamp": "2019-08-12 08:00:09.0",
                "virtual": false,
                "owner": "yourOwners",
                "hasEditPri": true,
                "hasReadPri": true,
                "isCancelled": false
            }],
    "count": 2
  }
}

SDK 示例¶

你可以在 Github 上获取批数据处理的 SDK 示例：

Java
Python