Update And Trigger Flow

使用新的参数触发一次任务流调度（不改变原任务流的信息，仅使用新的参数生成一个任务流实例）。

前提条件

  1. 用户必须为任务流的负责人

  2. 用户和任务流都没有被锁定

请求格式

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

固定值：updateAndTrigger

请求参数（Body）

名称

必需/可选

数据类型

描述

flowId

必需

Integer

任务流ID。

triggerTime

必需

Long

任务流计划运行时刻，时间戳格式，单位为毫秒。规则如下：

  • 若触发时间选择当前时间之前，则立即触发实例，且实例运行时，该时间将会被传入时间参数中用于计算。

  • 任务流同一时间只允许一个实例运行，若预跑实例与正在运行实例冲突，则依次执行。

parameters

必需

List<Map<key,value>>

调度参数。作为统一配置的全局参数，可以在节点内使用这些参数，以使任务运行时能动态适配环境变化（参数需要以key=value的格式表达）。有关使用参数的详细信息，参见 设置任务流或SHELL类型任务的参数>>

响应参数

名称

数据类型

描述

data

JSONObject

包含返回的任务流实例ID。详见 FlowInstanceId结构体

错误码

代码

错误信息

描述

62104

This workflow has no task, you cannot trigger it!

任务流中没有创建任务

62109

Server internal exception

服务器内部异常

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

示例

请求示例

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

method: POST

requestBody:
{
    "flowId": 3377,
    "triggerTime": 1574385824000,
  "parameters": [{"key":"REPLACE","value":"ddee"}]
}

返回示例

{
  "status": 0,
  "msg": " Success",
  "data": {
    "flowInstanceId": "2791-19700101000000"
  }
}