问题标签 [camel-ftp]

我正在使用 Apache Camel 从 FTP 服务器读取文件。它必须在几天内不重新启动的情况下监听新文件。有些日子有文件要下载，有些日子没有。

我遇到的第一个问题是，当我在长时间不活动（例如一天）后将文件放入 FTP 文件夹时，Apache Camel 没有选择这些文件，我必须重新启动它才能使其工作。

所以我认为该disconnect标志可能对这种情况有用。但是，当我使用断开连接标志时，出现以下错误：

文件已下载并保留在preMove文件夹中，但不会移动到move. 所以我的猜测是，在文件被读取并移动到 preMove 文件夹后连接关闭，但是当它试图移动到存档文件夹时它失败了。但是我尝试删除该preMove选项，但它仍然失败，这让我认为move标志是导致问题的原因。

有没有办法解决这个问题？

我是骆驼的新手。我正在尝试从安全的 ftp 服务器消费到我的本地文件夹，但消费速度真的很慢。

请建议可能有助于调整性能的参数。

我的路线如下——</p>

到端点 -file://target/toFolder

消耗 200 个大小为 200KB 的文件大约需要 16 分钟。

我也尝试过使用流缓存——</p>

从端点->

到端点 ->file://target/toFolder 消耗 200 个大小为 100kB 的文件也需要将近 15 分钟……。

当我使用相同的路线来消耗 20 个大小为 1 MB 的文件时，只需要 1 分 30 秒。

我无法理解为什么当批量增加时骆驼会变慢。

请建议，我缺少哪些参数可以提高 FTPS 的性能。

我正在使用骆驼 2.15.2，Commons net API 3.3。

谢谢，

在 Apache camel 中，如果我在输入目录中删除一个文件，同时在输出目录中也应该自动删除相同的文件？我是 Apache camel 的新手，请给我一些想法。

谢谢你，

我正在尝试使用相当简单的路由通过 SFTP 将文件从远程服务器下载到本地目录。

我面临的问题是该路由能够下载小文件（200 字节），但对于较大的文件（200 KB），它恰好卡在 98265 字节。大约 30 秒后，我收到管道关闭错误。

我正在使用 Apache Camel 版本：2.15.3

来自：sftp://xxx.xxx.xxx.xxx:xx//User/User01?delay=30s&include=File.*.csv&initialDelay=1m&password=xxxxxx&stepwise=false&streamDownload=true&username=User01

收件人：file:///var/opt/myfolder/incoming?doneFileName=${file:name}.done

出现此错误后，不会下载此文件和其余文件。我也尝试使用 localWorkDirectory 但看到下载到 tmp 目录中的文件也停留在 98265 字节。

+ 更新：

经过进一步调查，Apache Camel 内部使用的 JSCH 库似乎存在问题。等待时间后出现以下错误。我使用 JSCH 创建了一个用于下载的独立代码，该代码也挂在下载之间。我还使用另一个能够成功下载文件的 sftp api（不是 JSCH）创建了一个独立代码。

问题1：可能出了什么问题？如何解决这个问题？

问题 2：有没有办法将任何其他库与 Apache Camel 一起用于 SFTP？

任何建议，将不胜感激。

提前致谢。

如果我想在 apache-camel 中有一个 ftp 自定义组件，如何将 ftp uri 参数设置为 ftpConfiguration ？我尝试使用 Uri 参数注释来获取 uri 参数但失败了。有人知道吗？下面是我的示例代码：

在处理文件和删除文件时从 Camel 配置中获取一些问题。在下面添加了 3 个用例

目的：使用SFTP读取文件并将其复制到本地目录。完成后，将其从 SFTP 位置删除。下面是配置

用例 1：当 SFTP 位置只有一个文件时。

属性：<from uri="sftp://xxxx@xxxxxx:xxxx/testFolder/ToClient/?password=xxx& delete=true& scheduler=spring& scheduler.cron=0/15+*+*+?+*+MON-SAT& antInclude=*OECExport *.txt"/> 处理：一切都好

UseCase2 :有多个文件的地方

特性 ：<from uri="sftp://xxxx@xxxxxx:xxxx/testFolder/ToClient/?password=xxx& delete=true& scheduler=spring& scheduler.cron=0/15+*+*+?+*+MON-SAT& antInclude=*OECExport *.txt"/>

处理：它没有按预期工作。警告：

UseCase3 :有多个文件的地方

新属性：disconnect=true

特性 ：<from uri="sftp://xxxx@xxxxxx:xxxx/testFolder/ToClient/?password=xxx& disconnect=true&delete=true& scheduler=spring& scheduler.cron=0/15+*+*+?+*+MON-SAT& antInclude=*OECExport *.txt"/>

处理：它没有按预期工作。警告：

当我尝试通过camel FTP组件将文件放到远程服务器时，我想自定义PUT行为以满足我的要求，就像我从远程服务器获取文件一样。

但是，我找不到哪种方法实际上是通过 FTP 组件将文件执行到远程。

I need to implement a custom PollingConsumerPollStrategy implementation on a route inside a RouteBuilder. The examples I found use spring to create a bean, but i am not using Spring in my project.

How do i add MyPollStrategy to registry and use it as pollStrategy=#myPoll ?

我正在创建一个文件传输路径，move用于设置文件传输成功后移动文件的动态路径。我还设置了一个通知程序来跟踪文件传输事件。

由于移动路径是动态的，我需要获取文件传输后文件移动的评估路径。这个路径怎么能在notifier里面呢？

我想将所有文件和子文件夹从本地计算机复制到 sftp 服务器，虽然我能够传输文件夹内的文件，但我无法传输嵌套文件夹。我的自定义路由构建器的配置方法如下