通过骆驼将 sftp 移动到 AWS 后连接 sftp 时出现问题

Question

我在通过 springboot camel 应用程序连接 sftp 时遇到问题。这在我们将 sftp 移至 AWS 后开始发生。现在，我有一个临时服务器主机，看起来像这样s-add03ac9b.server.transfer.eu-west-1.amazonaws.com，我可以使用例如 FileZilla 进行连接，但如果我尝试使用该应用程序连接，这是我得到的错误：

Caused by: org.apache.camel.NoSuchEndpointException: No endpoint could be found for: s-add03ac9b.server.transfer.eu-west-1.amazonaws.com/testFolder?username=myUser&password=myPassword&disconnect=true&maxMessagesPerPoll=50&initialDelay=1s&delay=1s&timeout=3000&move=done&moveFailed=failed, please check your classpath contains the needed Camel component jar.

，这是路线本身，我将其更改为更具可读性

        from("s-add03ac9b.server.transfer.eu-west-1.amazonaws.com/testFolder?username=myUser&password=myPassword&disconnect=true&maxMessagesPerPoll=50&initialDelay=1s&delay=1s&timeout=3000&move=done&moveFailed=failed")
            .setHeader(Headers.CONFIGURATION.name(), constant(routeConfiguration))
            .setHeader("filenameModify").constant(modifyFileNames).setHeader("fileExtension")
            .constant(fileExtension).choice().when(PredicateBuilder.and(header("filenameModify").isEqualTo(true), header("fileExtension").isNotNull()))
            .setHeader(Exchange.FILE_NAME,
                    simple("${file:name.noext}-${date:in.header.CamelFileLastModified:ddMMyyyy-HHmmss}-${file:length}.${in.header.fileExtension}"))
            .end().idempotentConsumer(simple("${file:name}-${file:length}"), MemoryIdempotentRepository.memoryIdempotentRepository(1000))
            .log("Processing ${file:name}")
            .process(rawDataProcessor)
            .to((String) routeConfiguration.get(ConfigKey.END)).otherwise().log("File ${file:name} processed.").stop().end();

我是否需要添加其他内容，可能是一些依赖项或...？

Answer 1

如果有人遇到同样的问题，我通过在 from 部分添加 sftp:// 作为前缀来修复它。