Я создаю поток с источником http и приемником потока данных приемника для выполнения весенней пакетной задачи с именем batchPY546Task. Для запуска этой задачи я устанавливаю параметр 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.faster xml .jackson.databind.ex c .MismatchedInputException : Невозможно десериализовать экземпляр java.util.ArrayList<java.lang.Object> из токена START_OBJECT в [Source: (byte []) "{" name ":" batchPy546Task "," args ": {" localFilePath = / tmp / remote-files1 / BLM-54.00. . 01_Multicontrat_Creation_IDCRT011-Ь xml "}}"; строка: 1, столбец: 34] (через цепочку ссылок: org.springframework.cloud.stream.app.task.launcher.dataflow.sink.LaunchRequest ["args"]) на com.faster xml .jackson.databind. ex c .MismatchedInputException.from (MismatchedInputException. java: 59) ~ [jackson-databind-2.10.2.jar! /: 2.10.2]
Как передать параметр lcalFilePath моему task?
Версии: сервер потока данных 14.2 сервер шкипера 2.3.2 программа запуска datafmow обновлена и совместима с сервером потока данных 2.4.2.
С уважением