Get My Flow¶

模糊查询满足指定条件的所有任务流信息。

前提条件¶

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

请求格式¶

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

请求参数（URI）¶

名称	位置（Path/Query）	必需/可选	数据类型	描述
userId	Query	必需	String	用户 ID。如何获取userId信息>>
orgId	Query	必需	String	用户所属的组织 ID。如何获取orgId信息>>
searchValue	Query	可选	String	指定在 flowInstanceId 和 flowName 字段中模糊匹配查询条件（若不指定，则返回当前用户相关的所有任务流）。
action	Query	必需	String	固定值：getMyFlow

响应参数¶

名称	数据类型	描述
data	JSONObject	FlowSimpInfo结构体的集合，每个FlowSimpInfo包含查询到的一个任务流的基本信息。详见 FlowSimpleInfo结构体

FlowSimpleInfo结构体¶

示例¶

{
    "flowId": "2526",
    "editable": true,
    "flowName": "testIns",
    "cycle": "mi"
}

参数¶

名称	数据类型	描述
flowId	Integer	任务流ID。
editable	Boolean	任务流是否可编辑。
flowName	String	任务流名称。
cycle	String	调度周期（M：月；W：周；D：天；H：小时；mi：分钟）。

错误码¶

参见通用错误码。

示例¶

请求示例¶

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

method: GET

返回示例¶

{
    "status": 0,
    "msg": "Success",
    "data": [
        {
            "flowId": "3318",
            "editable": true,
            "flowName": "reduce_entity",
            "cycle": "D"
        },
        {
            "flowId": "2809",
            "editable": true,
            "flowName": "map",
            "cycle": "D"
        },
        {
            "flowId": "3257",
            "editable": true,
            "flowName": "shell",
            "cycle": "D"
        },
        {
            "flowId": "2515",
            "editable": true,
            "flowName": "testWorkflow122",
            "cycle": "D"
        },
        {
            "flowId": "2980",
            "editable": true,
            "flowName": "8",
            "cycle": "D"
        },
        {
            "flowId": "2979",
            "editable": true,
            "flowName": "integrattt",
            "cycle": "D"
        }
    ]
}

SDK 示例¶

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

Java
Python