我们可以使用apache camel端点将文件从FTP服务器移动到本地目录吗?

66bbxpm5  于 2023-11-18  发布在  Apache
关注(0)|答案(2)|浏览(196)

我想知道是否可以使用Apache Camel端点属性将文件从FTP服务器移动或下载到本地目录?
我已经搜索过这个主题了,没有找到任何对我有帮助的东西,而且我也不确定它的可行性。
端点URI=
第一个月
我使用“&move=C:\folder”作为属性,但它不工作,我得到以下错误

WARN - [SftpConsumer:213] Consumer Consumer[sftp://[email protected]/outgoingFolder?consumer.delay=300000&disconnect=true&fastExistsCheck=true&maximumReconnectAttempts=0&move=C%3A%5C%5Cfolders&passiveMode=true&password=xxxxxx&stepwise=false&throwExceptionOnConnectFailed=true] failed polling endpoint: Endpoint[sftp://[email protected]/outgoingFolder?consumer.delay=300000&disconnect=true&fastExistsCheck=true&maximumReconnectAttempts=0&move=C%3A%5C%5Cfolder&passiveMode=true&password=xxxxxx&stepwise=false&throwExceptionOnConnectFailed=true]. Will try again at next poll. Caused by: [org.apache.camel.component.file.GenericFileOperationFailedException - Cannot list directory:outgoingFolder]org.apache.camel.component.file.GenericFileOperationFailedException: Cannot list directory: outgoingFolder        at org.apache.camel.component.file.remote.SftpOperations.listFiles(SftpOperations.java:617)        at org.apache.camel.component.file.remote.SftpConsumer.doPollDirectory(SftpConsumer.java:117)        at org.apache.camel.component.file.remote.SftpConsumer.pollDirectory(SftpConsumer.java:79)        at org.apache.camel.component.file.GenericFileConsumer.poll(GenericFileConsumer.java:131)        at org.apache.camel.impl.ScheduledPollConsumer.doRun(ScheduledPollConsumer.java:175)        at org.apache.camel.impl.ScheduledPollConsumer.run(ScheduledPollConsumer.java:102)        at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
    at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308)        at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180)        at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294)        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)        at java.lang.Thread.run(Thread.java:745)Caused by: 4:        at com.jcraft.jsch.ChannelSftp._stat(ChannelSftp.java:2208)        at com.jcraft.jsch.ChannelSftp._stat(ChannelSftp.java:2215)        at com.jcraft.jsch.ChannelSftp.ls(ChannelSftp.java:1565)        at com.jcraft.jsch.ChannelSftp.ls(ChannelSftp.java:1526)        at org.apache.camel.component.file.remote.SftpOperations.listFiles(SftpOperations.java:608)        ... 12 more Caused by: java.io.IOException: inputstream is losed        at com.jcraft.jsch.ChannelSftp.fill(ChannelSftp.java:2884)        at com.jcraft.jsch.ChannelSftp.header(ChannelSftp.java:2908)        at com.jcraft.jsch.ChannelSftp._stat(ChannelSftp.java:2189)        ... 16 more

字符串

olhwl3o2

olhwl3o21#

否,&move选项用于在远程文件系统范围内移动文件。
用这个代替:

from("sftp://[email protected]/outgoingFolder?password=*****&throwExceptionOnConnectFailed=true&maximumReconnectAttempts=0&stepwise=false&fastExistsCheck=true&disconnect=true&consumer.delay=300000&passiveMode=true")
.to("file:C:\\folder");

字符串

wixjitnu

wixjitnu2#

您需要先将文件下载到本地目录,然后将其移动。

from("sftp://[email protected]/outgoingFolder?password=*****")
.to("file:D:\\folder");

字符串

相关问题