Apache Camel | FTP |只使用单个文件

Question

我正在尝试读取ftp目录中的所有文本文件，解析它们。如果解析成功，则将它们移动到不同的目录（不是默认目录，即。完成目录），如果解析失败，则文件应保留在ftp目录中。这个概念看起来很简单，但我的路由只从ftp读取单个文件，并且在获取一个文件后路由自行结束。

代码如下：

@Override
    public void configure() throws Exception {

         from(EndPointConstants.DIRECT + GetDriverProductInfo.class.getSimpleName())  
        .pollEnrich(ftp://ingestion_user@10.207.6.42/fantics?password=******&recursive=true)
        .to("file://test/readFile")

它只能够获取一个文件，而这个过程不是递归发生的，这与PollRich有关吗？

Answer 1

如果解析成功，则将它们移动到不同的目录（而不是默认目录，即。完成目录）

使用如下示例：

.to("file://test/readFile?autoCreate=true&moveFailed=.failed/${date:now:yyyyMMdd}/${file:name}&move=.processed/${date:now:dd-MM-yyyy}/${file:name}")

来自Camel文档（FTP/SFTP/FTPS组件）：

默认情况下，FTP使用者将保留远程FTP服务器上未触及的已使用文件。如果要删除文件或将其移动到其他位置，必须显式配置它。例如，可以使用delete=true删除文件，或者使用move=。完成，将文件移动到隐藏的完成子目录中。常规文件使用者则不同，因为默认情况下，它会将文件移动到一个文件夹中。骆驼子目录。Camel默认情况下不会为FTP使用者执行此操作的原因是，默认情况下，它可能没有移动或删除文件的权限。

因此，您可以使用以下示例：

&noop=false

&move

&delete=false

编辑：

我认为你应该想出这样的东西（下面的代码），因为pollRich（）不适合这种情况。

（强烈建议不要使用以下代码，因为它不是一个使用示例）

from("direct:scan")
    .process(new Processor()
    {
        public void process(Exchange exchange) throws Exception
        {
            ConsumerTemplate consumerTemplate = exchange.getContext().createConsumerTemplate();
            ProducerTemplate producerTemplate = exchange.getContext().createProducerTemplate();
            producerTemplate.setDefaultEndpointUri("file:..");
            producerTemplate.send(consumerTemplate.receive("ftp:.."));
        }
    });

干杯