关于#dolphinschedulerapi#的问题，如何解决？(标签-java|关键词-传参数)

Question

求解答，解决问题有偿支付！
需求：在java中调dolphinscheduler 接口并传递参数，在海豚node中能够接收到参数
dolphinscheduler api
在java程序中调用projects/{projectCode}/executors/start-process-instance这个接口传参数

startParams传了参数

但是在海豚任务重接收不到

Answer 1

可以这么做:

1. 在DolphinScheduler的API文档中找到projects/{projectCode}/executors/start-process-instance接口,这是启动一个任务实例的接口。
2. 准备参数:

• projectCode: 项目编码
• executorId: 执行者ID
• commandType: 命令类型,这里填RUN_PROCESS_INSTANCE
• processInstance: 进程实例对象,需要构造如下:

json
{
  "processDefinitionCode": "process_code",   // 流程定义code
  "commandType": "START_PROCESS",           // 命令类型
  "scheduleTime": "",                       // 任务调度时间
  "source": "",                             // 来源
  "processInstanceName": "实例名称",        // 实例名称
  "globalParams": [                         // 全局参数
      {
         "prop": "param1",
         "direct": "IN",    
         "value": "value1"
      }
  ],
  "tasks": [                                // 任务参数
      {  
         "taskCode": "task1",                      
         "taskParams": [
            {
               "prop": "param2",
               "direct": "IN",    
               "value": "value2"
            }
         ]
      }
   ]   
}
3. 使用任意Java HTTP客户端(如OkHttp),调用DolphinScheduler的API,传递上述参数:
java
String url = "http://dolphinscheduler-server/projects/project1/executors/start-process-instance";

MediaType JSON = MediaType.get("application/json; charset=utf-8");
OkHttpClient client = new OkHttpClient();

RequestBody body = RequestBody.create(JSON, processInstanceJson);
Request request = new Request.Builder()
                         .url(url)
                         .post(body)
                         .build();

Response response = client.newCall(request).execute();

1. DolphinScheduler的node会接收到这些参数,并启动一个新的任务实例。