我计划使用 S3Streaming 消息源来处理 S3 中收到的导入文件 (xml(。我不确定如何将 MessageSource 转换为作业启动请求,因为作业参数不支持基元类型以外的参数,请阐明如何继续此操作 -谢谢
如果你的意思是你想将 InputStream 有效负载传递给ItemReader
,不,这不能用JobLauncher
来完成。
相反,ItemReader
本身需要打开输入流(可能使用 Spring 集成SftpRemoteFileTemplate
(。
只需在JobParameters
中传递信息(文件名、服务器、凭据等(,然后关闭 SI 输入流有效负载而无需读取。