Search Flow¶
分页查询符合条件的所有任务流的基本信息(包括其他用户的任务流)。
前提条件¶
用户必须属于待搜索任务流所属的OU。
请求格式¶
POST https://{apigw-address}/dataflow-batch-service/v2.0/flows
请求参数(URI)¶
名称 |
位置(Path/Query) |
必需/可选 |
数据类型 |
描述 |
---|---|---|---|---|
userId |
Query |
必需 |
String |
用户ID。如何获取userId信息>> |
orgId |
Query |
必需 |
String |
用户所属的组织ID。如何获取orgId信息>> |
action |
Query |
必需 |
String |
固定值:search |
请求参数(Body)¶
名称 |
必需/可选 |
数据类型 |
描述 |
---|---|---|---|
expression |
可选 |
String |
指定在 flowId 和 flowName 字段中模糊匹配查询条件(若不指定,则返回相关的所有任务流)。 |
pagination |
可选 |
Pagination请求结构体 |
分页信息结构体。详见 Pagination请求结构体 |
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。 |
order |
可选 |
String |
ASC 表示正序排序,DESC 表示倒序排序,默认为正序排序。 |
响应参数¶
名称 |
数据类型 |
描述 |
---|---|---|
data |
JSONObject |
PageFlow结构体的集合,集合中每一项表示查询到的一个任务流的基本信息。详见 PageFlow结构体 |
PageFlow结构体¶
示例¶
{
"flowId": "21",
"flowName": "dim_wtg_full"
}
参数¶
名称 |
数据类型 |
描述 |
---|---|---|
flowId |
Integer |
任务流ID。 |
flowName |
String |
任务流名称。 |
错误码¶
代码 |
错误信息 |
描述 |
---|---|---|
62102 |
Illegal field, should be one of [create_time, update_time, start_time]. |
参数 sorters.field 的值不正确,必须为 create_time、update_time、或 start_time。 |
有关其他错误码的描述,参见 通用错误码。
示例¶
请求示例¶
url: https://{apigw-address}/dataflow-batch-service/v2.0/flows?action=search&userId={}&orgId={}
method: POST
requestBody:
{
"expression": "",
"pagination":{
"pageNo": 0,
"pageSize": 10,
"sorters": [{
"field": "update_time",
"order": "ASC"
}]
}
}
返回示例¶
{
"status": 0,
"msg": " Success",
"data": [
{
"flowId": "20",
"flowName": "vd_text"
},
{
"flowId": "21",
"flowName": "dim_wtg_full"
},
{
"flowId": "22",
"flowName": "wenl_dim_fact_downtime"
}
]
}