数据流启动器Payload Java

Question

我用http源和sink数据流启动器构建了一个流，以执行名为batchPY546Task的spring批处理任务为了启动这个任务，我设置了localFilePath=文件参数的路径。因此，在文档中，使用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"]
}

我尝试了许多语法：卷曲http://localhost:57110-H"内容类型：application/json"-d'｛"name"："batchPy546Task"，"args"：｛"localFilePath=/tmp/remote-files1/BLM-54.00.01_Multicontrt_Creation_IDCRT011-b.xml"｝'

所有这些都是错误的

由以下原因引起：com.fasterxml.jackson.databind.exc.MismatchedInputException：无法从START_OBECT令牌中反序列化java.util.ArrayList<java.lang.Object>的实例在[Source:(byte[]("｛"name"："batchPy546Task"，"args"：｛"localFilePath=/tmp/remote-files1/BLM-54.00.01_Multicontrt_Creation_IDCRT011-b.xml"｝｝"；行：1，列：34](通过引用链：org.springframework.cloud.stream.app.task.elauncher.dataflow.ssink.LaunchRequest["args"](来自(MismatchedInputException.java:59(~[jackson-databind-2.10.2.jar！/：2.10.2]

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

版本：数据流服务器14.2队长服务器2.3.2datamow-auncher是最新的，与数据流服务器2.4.2兼容。

问候

Answer 1

使用此语法解决的问题：卷曲http://localhost:57110-H"内容类型：application/json"-d'｛"name"："batchPy546Task"，"args"：["localFilePath=/tmp/remote-files1/BLM-54.00.01_Multicontrt_Creation_IDCRT011-b.xml"]}'

Answer 2

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