使用 apache camel ftp 组件将文件移动到存档目录

Question

我在数据库中存储的文件很少，这些文件是从 FTP 服务器获取并处理的。

我正在尝试将这些文件移动到 FTP 服务器上的存档目录，为此我正在使用 producerTemplate.

这是我目前所做的。

try {
    DefaultCamelContext camelContext = new DefaultCamelContext();
    ProducerTemplate template = camelContext.createProducerTemplate();
    template.request("ftp://xxxxx/include=fileFromDb.xml&move=archive/fileFromDb.xml", outExchange -> {
        String body = outExchange.getIn().getBody(String.class);                    
    });
} catch (Exception ex) {
    // update the status in database to indicate archive failed
}

但这失败并出现以下错误，无法解决。

WARN  o.a.c.c.f.remote.RemoteFileProducer - Writing file failed with: Cannot write null body to file: archive/ID-192-168-1-113-tpgi-com-au-1627667653835-1-2

我尝试过从其他答案中实施解决方案，但它们都没有用。

如果我像下面这样编写自定义路由，它可以正常工作，但因为我需要执行 post 移动操作，所以我更喜欢使用生产者模板。

from("ftp://xxxxx/include=fileFromDb.xml&move=archive/fileFromDb.xml")
    .log("file moved successfully").

Answer 1

If I write a custom route like below, it works fine but because I need perform post move actions I prefere using producer template.

您可以使用 onCompletion 调用另一个路由来处理 post 移动操作。

String sftpURI = "sftp:localhost:2222/upload" +
"?username="+username+"&password="+password
+ "&move=done";

String sftpPostMoveURI = "sftp:localhost:2222/upload/done" +
"?username="+username+"&password="+password
+ "&fileName=${headers.CamelFileName}";

from(sftpURI)
    .routeId("ReadFileUsingSFTPRoute")
    .onCompletion().onCompleteOnly()
        .setBody().constant("")
        .to("direct:postMoveActions")
    .end()
    .log("file ${headers.CamelFileName} moved");

from("direct:postMoveActions")
    .routeId("PostMoveActionsRoute")
    .log("doing post move actions!")
    .pollEnrich().simple(sftpPostMoveURI).timeout(5000)
    .log("File: ${body}");

使用 apache camel ftp 组件将文件移动到存档目录

Moving files to archive directory using apache camel ftp component

spring

apache-camel

camel-ftp