问题标签 [camel-ftp]

当我尝试连接到 FTP 服务器并下载文件时，我收到 501 错误代码。我可以使用相同的用户使用 winscp 下载 csv 文件。我正在使用 Apache camel 2.17 版本。

在 Windows 命令提示符下：

服务器日志：

你能告诉我如何解决这个问题吗

我有 dsl 路线：

我想限制文件大小以供使用。例如，我想忽略大小超过 100Mb 的文件。如果骆驼遇到的文件超过100mb，我可以选择进行回调

我读过了：

http://camel.apache.org/ftp2.html

但我找不到任何相关的东西

我正在尝试使用 camel ftp 组件从 SFTP 服务器获取文件并以自定义方式处理它。我能够成功连接到 sftp 服务器并获取文件，但交换正文包含远程文件对象并且文件包含 com.jcraft。 jsch.ChannelSftp$LsEntry 对象，当我在调试模式下检查文件对象时，它只包含有关文件的元数据信息。我在将其转换为文件时遇到类型转换异常。如何从交换对象中获取文件以进行进一步的自定义处理。

当我使用文件而不是 SFTP 时，一切正常。

骆驼路线：

用于自定义处理 csv 的 Java 方法。

例外：

我想为我的骆驼文件消费者设置延迟。我正在使用蓝图 DSL。不知道如何动态设置它。

<from id="_from1" uri="file:<filepath>?delay=1000&amp;delete=true"/>

我希望从属性文件中获取值“1000”。

我正在使用骆驼 2.17 和 Fuse 6.3。我有一个场景，我需要将我的消息发送到多个端点，每个端点都进行一些 dB 记录。

我正在使用“recipientList”将我的消息发送到这些端点，但在这里我面临一个问题，我的数据库条目不是按照端点调用的顺序排列的。

假设，我有 3 个端点 A、B、C，并且在处理 MessageA、MessageB 和 MessageC 之后，它们在 DB 中分别记录 1 条消息，但是当我运行我的路由 RL(a，b，c) 时，我看不到相同的 DB 消息尽管这些是直接端点。

有没有办法让我的路线等待第一个端点完成然后处理第二个端点？

这是我的路线示例

在这里，我正在更新我的数据库中未遵循执行顺序的“ stepName ”属性。

它应该是：

1. 收到文件
2. 数据源文件记录
3. 文件验证
4. 数据转换
5. 数据目标文件记录
6. 文件已交付

但我在数据库条目中看不到这个顺序。

是否有任何理智的方法来处理 sftp 端点的身份验证失败？

我有一个带有 sftp 端点的骆驼路线，特别是将文件移动到 sftp。当 sftp 位置不可用时，我想：

• 如果是身份验证失败，请记录并不要重试。将原始文件移动到故障文件夹。
• 如果主机未知，请登录并不要重试。将原始文件移动到故障文件夹。
• 否则：在失败前重试几次。

不幸的是，SftpOperations 总是不断重试。在身份验证失败的情况下（如果部署应用程序的人在属性文件中输入错误，这很容易发生），这意味着使用错误的凭据重复尝试。如果只是密码错误，可能会导致用户被屏蔽。

我一直在努力弄清楚为什么某些文件没有正确下载。即使在本地测试并重新启动我的应用程序时，似乎某些文件也不会完全下载。使事情变得更加困难的是，它并不总是一致的。

信息：

• 阿帕奇骆驼版本：2.20.0
• 使用 camel-spring-boot-starter 集成到 Spring-Boot 应用程序中
• 文件大约190M
• 使用独立的 Jsch 和 Linux sftp 客户端可以正常下载文件
• 堆大小设置为 1G，内存使用量甚至没有接近最大值
• 骆驼不会检测到下载有任何问题，即使写入的字节数比骆驼头文件的长度少几十兆（骆驼头文件长度正确）
• 我观察到 org.apache.camel 日志记录设置为 TRACE 的问题，而在日志中没有看到任何奇怪的东西。
• Idemoptent repo 被更新，就像文件被正确处理一样
• 我在 Linux 和 Windows 上看到了同样的问题

任何有关问题可能是什么的建议或有关如何进行故障排除的建议都很棒！

路由配置（有点人为创建，因为值来自 spring-boot 配置）：

更新1

添加后的观察binary=true。

前两个文件已正确下载，但服务器上的第三个和最后一个文件未正确下载。

Data_FIle_16.csv 文件的正确文件大小为 192867682 字节，在CamelFileLength标头中正确捕获。

更新 2

删除了上面所有的 log 和 seda email 组件，然后重新运行。第三个文件仍未完全写入。

添加相关的 DEBUG 级别的日志输出，希望它能阐明正在发生的事情或排除某些事情。

据我所知，日志没有显示任何可疑内容，也没有暗示 _16 文件未完全写入。

是否有人知道 SFTP 服务器上可能发生的任何事情值得与提供商核实？

在我们的 sftp 路由中，我们设置了delete=true，但是文件处理大约需要 40 分钟才能完成。现在当路由完成后尝试删除文件时，我们得到org.apache.camel.component.file.GenericFileOperationFailedException: Cannot delete file:了由于管道关闭IOException。我假设远程 sftp 服务器已关闭连接。

现在，如果我添加disconnect=true，它会在文件传输完成后立即断开连接吗？如果是这样，它会在路由完成时重新连接以进行删除操作，还是我必须使用其他一些配置来保持连接状态？

因此，一个文件会被多次处理。（我可以move为此添加参数，但我们仍然会看到删除操作失败异常）

v2.12.2

我使用 Camel DSL 路由定义：

当我将文件放入 sftp 文件夹时，我看到以下日志：

我想禁用主机验证。

看起来添加&useUserKnownHostsFile=false到路径可以解决我的错误。但是我有很多路由定义，我不喜欢给每个 URL 添加这个后缀。我可以全局禁用此验证吗？

我正在使用 apache camel 制作一个 ftp 客户端，用于将一些文件下载到某个本地目录。该程序读取一个 xml 文件以获取将从 ftp 获取的文件的名称。该程序似乎可以工作，只是下载的文件已损坏。现在我正在尝试下载一些图像文件，但我得到的是 14.9Kb 并且已损坏，没有显示错误消息。

这是我的代码：

主要的

骆驼路线：

我尝试使用 streamDownload 参数，但阻止文件被下载（我不知道为什么）

控制台日志：

信息 | Apache Camel 2.15.1.redhat-621084 (CamelContext: camel-1) is started 0 [main] INFO org.apache.camel.impl.DefaultCamelContext - Apache Camel 2.15.1.redhat-621084 (CamelContext: camel-1) 是出发信息 | JMX 已启用 10 [main] INFO org.apache.camel.management.ManagedManagementStrategy - JMX 已启用 INFO | 已加载 185 个类型转换器 208 [main] INFO org.apache.camel.impl.converter.DefaultTypeConverter - 已加载 185 个类型转换器 INFO | AllowUseOriginalMessage 已启用。如果不需要访问原始消息，则建议关闭此选项，因为它可能会提高性能。395 [main] INFO org.apache.camel.impl.DefaultCamelContext - AllowUseOriginalMessage 已启用。如果不需要访问原始消息，然后建议关闭此选项，因为它可能会提高性能。信息 | 未使用 StreamCaching。如果使用流，则建议启用流缓存。查看更多详情 http://camel.apache.org/stream-caching.html 395 [main] INFO org.apache.camel.impl.DefaultCamelContext - StreamCaching 未使用。如果使用流，则建议启用流缓存。在http://camel.apache.org/stream-caching.html查看更多细节 信息 | 端点配置为 noop=true，因此强制端点也是幂等的 395 [main] INFO org.apache.camel.component.file.FileEndpoint - 端点配置为 noop=true，因此强制端点也是幂等的 INFO | 使用基于默认内存的幂等存储库，缓存最大大小：1000 395 [main] INFO org.apache.camel.component.file.FileEndpoint - 使用基于默认内存的幂等存储库，缓存最大大小：1000 路线：route1 开始并使用：端点 [file://./?fileName=Datos.xml&noop=true] 502 [main] INFO org.apache.camel.impl.DefaultCamelContext - 路线：route1 开始并使用：端点 [ file://./?fileName=Datos.xml&noop=true] 信息 | 路由：route2 从 Endpoint[direct://ftp] 504 [main] INFO org.apache.camel.impl 开始并使用。DefaultCamelContext - 路由：route2 开始并使用：端点 [direct://ftp] INFO | 共有 2 条路线，其中 2 条已启动。504 [main] INFO org.apache.camel.impl.DefaultCamelContext - 总共 2 条路由，其中​​ 2 条已启动。信息 | Apache Camel 2.15.1.redhat-621084 (CamelContext: camel-1) 开始时间为 0.504 秒 507 [main] INFO org.apache.camel.impl.DefaultCamelContext - Apache Camel 2.15.1.redhat-621084 (CamelContext: camel-1 ) 开始于 0.504 秒 创建了默认 XPathFactory com.sun.org.apache.xpath.internal.jaxp.XPathFactoryImpl@5434283f 1533 [Camel (camel-1) thread #0 - file://./] INFO org.apache.camel.builder.xml。 XPathBuilder - 创建默认 XPathFactory com.sun.org.apache.xpath.internal.jaxp.XPathFactoryImpl@5434283f 信息 | 图片：route2 开始并使用：Endpoint[direct://ftp] INFO | 共有 2 条路线，其中 2 条已启动。504 [main] INFO org.apache.camel.impl.DefaultCamelContext - 总共 2 条路由，其中​​ 2 条已启动。信息 | Apache Camel 2.15.1.redhat-621084 (CamelContext: camel-1) 开始时间为 0.504 秒 507 [main] INFO org.apache.camel.impl.DefaultCamelContext - Apache Camel 2.15.1.redhat-621084 (CamelContext: camel-1 ) 开始于 0.504 秒 创建了默认 XPathFactory com.sun.org.apache.xpath.internal.jaxp.XPathFactoryImpl@5434283f 1533 [Camel (camel-1) thread #0 - file://./] INFO org.apache.camel.builder.xml。 XPathBuilder - 创建默认 XPathFactory com.sun.org.apache.xpath.internal.jaxp.XPathFactoryImpl@5434283f 信息 | 图片：route2 开始并使用：Endpoint[direct://ftp] INFO | 共有 2 条路线，其中 2 条已启动。504 [main] INFO org.apache.camel.impl.DefaultCamelContext - 总共 2 条路由，其中​​ 2 条已启动。信息 | Apache Camel 2.15.1.redhat-621084 (CamelContext: camel-1) 开始时间为 0.504 秒 507 [main] INFO org.apache.camel.impl.DefaultCamelContext - Apache Camel 2.15.1.redhat-621084 (CamelContext: camel-1 ) 开始于 0.504 秒 创建了默认 XPathFactory com.sun.org.apache.xpath.internal.jaxp.XPathFactoryImpl@5434283f 1533 [Camel (camel-1) thread #0 - file://./] INFO org.apache.camel.builder.xml。 XPathBuilder - 创建默认 XPathFactory com.sun.org.apache.xpath.internal.jaxp.XPathFactoryImpl@5434283f 信息 | 图片：504 [main] INFO org.apache.camel.impl.DefaultCamelContext - 总共 2 条路由，其中​​ 2 条已启动。信息 | Apache Camel 2.15.1.redhat-621084 (CamelContext: camel-1) 开始时间为 0.504 秒 507 [main] INFO org.apache.camel.impl.DefaultCamelContext - Apache Camel 2.15.1.redhat-621084 (CamelContext: camel-1 ) 开始于 0.504 秒 创建了默认 XPathFactory com.sun.org.apache.xpath.internal.jaxp.XPathFactoryImpl@5434283f 1533 [Camel (camel-1) thread #0 - file://./] INFO org.apache.camel.builder.xml。 XPathBuilder - 创建默认 XPathFactory com.sun.org.apache.xpath.internal.jaxp.XPathFactoryImpl@5434283f 信息 | 图片：504 [main] INFO org.apache.camel.impl.DefaultCamelContext - 总共 2 条路由，其中​​ 2 条已启动。信息 | Apache Camel 2.15.1.redhat-621084 (CamelContext: camel-1) 开始时间为 0.504 秒 507 [main] INFO org.apache.camel.impl.DefaultCamelContext - Apache Camel 2.15.1.redhat-621084 (CamelContext: camel-1 ) 开始于 0.504 秒 创建了默认 XPathFactory com.sun.org.apache.xpath.internal.jaxp.XPathFactoryImpl@5434283f 1533 [Camel (camel-1) thread #0 - file://./] INFO org.apache.camel.builder.xml。 XPathBuilder - 创建默认 XPathFactory com.sun.org.apache.xpath.internal.jaxp.XPathFactoryImpl@5434283f 信息 | 图片：504 秒 507 [main] INFO org.apache.camel.impl.DefaultCamelContext - Apache Camel 2.15.1.redhat-621084 (CamelContext: camel-1) 在 0.504 秒内开始 创建了默认 XPathFactory com.sun.org.apache.xpath.internal.jaxp.XPathFactoryImpl@5434283f 1533 [Camel (camel-1) thread #0 - file://./] INFO org.apache.camel.builder.xml。 XPathBuilder - 创建默认 XPathFactory com.sun.org.apache.xpath.internal.jaxp.XPathFactoryImpl@5434283f 信息 | 图片：504 秒 507 [main] INFO org.apache.camel.impl.DefaultCamelContext - Apache Camel 2.15.1.redhat-621084 (CamelContext: camel-1) 在 0.504 秒内开始 创建了默认 XPathFactory com.sun.org.apache.xpath.internal.jaxp.XPathFactoryImpl@5434283f 1533 [Camel (camel-1) thread #0 - file://./] INFO org.apache.camel.builder.xml。 XPathBuilder - 创建默认 XPathFactory com.sun.org.apache.xpath.internal.jaxp.XPathFactoryImpl@5434283f 信息 | 图片：XPathBuilder - 创建默认 XPathFactory com.sun.org.apache.xpath.internal.jaxp.XPathFactoryImpl@5434283f 信息 | 图片：XPathBuilder - 创建默认 XPathFactory com.sun.org.apache.xpath.internal.jaxp.XPathFactoryImpl@5434283f 信息 | 图片：ftp://190.0.56.190:8021/pruebasumman/conductor/71708375.jpg 1635 [骆驼 (camel-1) 线程 #0 - file://./] 信息 route1 - imagen: ftp://190.0.56.190:8021 /pruebasumman/导体/71708375.jpg 信息 | Apache Camel 2.15.1.redhat-621084 (CamelContext: camel-1) 正在关闭 10521 [main] INFO org.apache.camel.impl.DefaultCamelContext - Apache Camel 2.15.1.redhat-621084 (CamelContext: camel-1)正在关闭 INFO | 开始正常关闭 2 条路由（超时 300 秒） 10524 [main] INFO org.apache.camel.impl.DefaultShutdownStrategy - 开始正常关闭 2 条路由（超时 300 秒）等待，因为仍有 3 次正在进行的和待处理的交换要完成，在 300 秒内超时。10524 [Camel (camel-1) thread #2 - ShutdownTask] INFO org.apache.camel.impl.DefaultShutdownStrategy - 等待，因为仍有 3 个正在进行的和未决的交换完成，在 300 秒内超时。信息 | 等待，因为仍有 3 个正在进行和未决的交换完成，在 299 秒内超时。11525 [Camel (camel-1) thread #2 - ShutdownTask] INFO org.apache.camel.impl.DefaultShutdownStrategy - 等待，因为仍有 3 个正在进行和未决的交换完成，在 299 秒内超时。信息 | 等待，因为仍有 3 个正在进行和未决的交换完成，在 298 秒内超时。12528 [Camel (camel-1) thread #2 - ShutdownTask] INFO org.apache.camel.impl.DefaultShutdownStrategy - 等待，因为仍有 3 个正在进行和未决的交换完成，在 298 秒内超时。信息 | 等待，因为仍有 3 次正在进行和待处理的交换要完成，在 297 秒内超时。13529 [Camel (camel-1) thread #2 - ShutdownTask] INFO org.apache.camel.impl.DefaultShutdownStrategy - 等待，因为仍有 3 个正在进行的和待处理的交换完成，在 297 秒内超时。信息 | 等待，因为仍有 3 次正在进行和待处理的交换要完成，在 296 秒内超时。14540 [Camel (camel-1) thread #2 - ShutdownTask] INFO org.apache.camel.impl.DefaultShutdownStrategy - 等待，因为仍有 3 个正在进行的和未决的交换完成，在 296 秒内超时。信息 | 等待，因为仍有 3 次正在进行的和未决的交换要完成，在 295 秒后超时。15555 [Camel (camel-1) thread #2 - ShutdownTask] INFO org.apache.camel.impl.DefaultShutdownStrategy - 等待，因为仍有 3 个正在进行的和待处理的交换完成，在 295 秒内超时。信息 | 等待，因为仍有 3 个正在进行和待处理的交换要完成，在 294 秒内超时。16568 [骆驼（camel-1）线程＃2 - ShutdownTask] INFO org.apache.camel.impl。DefaultShutdownStrategy - 等待，因为仍有 3 个正在进行的和未决的交换要完成，在 294 秒内超时。信息 | 等待，因为仍有 3 次正在进行和待处理的交换要完成，在 293 秒后超时。17569 [Camel (camel-1) thread #2 - ShutdownTask] INFO org.apache.camel.impl.DefaultShutdownStrategy - 等待，因为仍有 3 个正在进行和未决的交换完成，在 293 秒内超时。信息 | 等待，因为仍有 3 次正在进行的和未决的交换要完成，在 292 秒内超时。18574 [Camel (camel-1) thread #2 - ShutdownTask] INFO org.apache.camel.impl.DefaultShutdownStrategy - 等待，因为仍有 3 个正在进行的和待处理的交换完成，在 292 秒内超时。信息 | 等待，因为仍有 3 次正在进行和待处理的交换要完成，在 293 秒后超时。17569 [Camel (camel-1) thread #2 - ShutdownTask] INFO org.apache.camel.impl.DefaultShutdownStrategy - 等待，因为仍有 3 个正在进行和未决的交换完成，在 293 秒内超时。信息 | 等待，因为仍有 3 次正在进行的和未决的交换要完成，在 292 秒内超时。18574 [Camel (camel-1) thread #2 - ShutdownTask] INFO org.apache.camel.impl.DefaultShutdownStrategy - 等待，因为仍有 3 个正在进行的和待处理的交换完成，在 292 秒内超时。信息 | 等待，因为仍有 3 次正在进行和待处理的交换要完成，在 293 秒后超时。17569 [Camel (camel-1) thread #2 - ShutdownTask] INFO org.apache.camel.impl.DefaultShutdownStrategy - 等待，因为仍有 3 个正在进行和未决的交换完成，在 293 秒内超时。信息 | 等待，因为仍有 3 次正在进行的和未决的交换要完成，在 292 秒内超时。18574 [Camel (camel-1) thread #2 - ShutdownTask] INFO org.apache.camel.impl.DefaultShutdownStrategy - 等待，因为仍有 3 个正在进行的和待处理的交换完成，在 292 秒内超时。DefaultShutdownStrategy - 等待，因为仍有 3 个正在进行的和待处理的交换要完成，在 293 秒后超时。信息 | 等待，因为仍有 3 次正在进行的和未决的交换要完成，在 292 秒内超时。18574 [Camel (camel-1) thread #2 - ShutdownTask] INFO org.apache.camel.impl.DefaultShutdownStrategy - 等待，因为仍有 3 个正在进行的和待处理的交换完成，在 292 秒内超时。DefaultShutdownStrategy - 等待，因为仍有 3 个正在进行的和待处理的交换要完成，在 293 秒后超时。信息 | 等待，因为仍有 3 次正在进行的和未决的交换要完成，在 292 秒内超时。18574 [Camel (camel-1) thread #2 - ShutdownTask] INFO org.apache.camel.impl.DefaultShutdownStrategy - 等待，因为仍有 3 个正在进行的和待处理的交换完成，在 292 秒内超时。

提前致谢。