1

我有一个 spring 批处理启动应用程序,它以平面文件作为输入。我将应用程序转换为云任务并部署在 Spring 本地数据流服务器中。接下来,我创建了一个以 File Source -> tasklaunchrequest-transform -> task-launcher-local 开头的流,它启动了我的批处理云任务应用程序。

看起来该文件没有进入批处理应用程序。我在日志中没有看到任何表明这一点的东西。

我在https://github.com/spring-cloud-stream-app-starters/tasklaunchrequest-transform/tree/master/spring-cloud-starter-stream-processor-tasklaunchrequest-transform查看了文档

它说

任何输入类型。(有效载荷和报头被丢弃)

我的问题是如何将文件作为有效负载从文件源传递到批处理应用程序,这似乎是一个非常基本的功能。

很感谢任何形式的帮助。

4

1 回答 1

1

您需要编写自己的转换器,从源中获取数据并将其打包,以便您的任务可以使用它。

于 2018-03-01T18:35:13.450 回答