数据流启动器有效负载 Java答案

【问题标题】：Dataflow launcher Payload Java数据流启动器有效负载 Java
【发布时间】：2020-03-25 14:49:43
【问题描述】：

我使用 http 源和接收器数据流启动器构建了一个流，以执行名为 batchPY546Task 的 spring 批处理任务要启动此任务，我设置了 localFilePath=path-of-the-file 参数。因此，在文档中，使用 http 源可以通过有效负载传递信息。

https://github.com/spring-cloud-stream-app-starters/tasklauncher-dataflow/blob/master/spring-cloud-starter-stream-sink-task-launcher-dataflow/README.adoc

{
  "name":"foo",
  "deploymentProps": {"key1":"val1","key2":"val2"},
  "args":["--debug", "--foo", "bar"]
}

我尝试了很多语法： curl http://localhost:57110 -H"Content-Type:application/json" -d '{"name":"batchPy546Task", "args":{"localFilePath=/tmp/remote-files1/BLM-54.00.01_Multicontrat_Creation_IDCRT011-b. xml"}}'

都是错的

原因：com.fasterxml.jackson.databind.exc.MismatchedInputException：无法从 START_OBJECT 令牌中反序列化 java.util.ArrayList<java.lang.Object> 的实例在 [Source: (byte[])"{"name":"batchPy546Task", "args":{"localFilePath=/tmp/remote-files1/BLM-54.00.01_Multicontrat_Creation_IDCRT011-b.xml"}}";行：1，列：34]（通过引用链：org.springframework.cloud.stream.app.task.launcher.dataflow.sink.LaunchRequest["args"]）在 com.fasterxml.jackson.databind.exc.MismatchedInputException.from(MismatchedInputException.java:59) ~[jackson-databind-2.10.2.jar!/:2.10.2]

如何将参数 lcalFilePath 传递给我的任务？

版本：数据流服务器 14.2 船长服务器 2.3.2 datafmow auncher 是最新的并且与 dataflow server 2.4.2 兼容。

问候

【问题讨论】：

标签： spring-cloud-dataflow

【解决方案1】：

使用以下语法解决的问题： curl http://localhost:57110 -H"Content-Type:application/json" -d '{"name":"batchPy546Task", "args":["localFilePath=/tmp/remote-files1/BLM-54.00.01_Multicontrat_Creation_IDCRT011-b。 xml"]}'

【讨论】：

【解决方案2】：

args 必须是 json 列表 "args":["localFilePath=/tmp/..."]

【讨论】：