通过骆驼将 sftp 移动到 AWS 后在 sftp 上连接时出现问题
Having problem to connect on sftp after moving sftp to AWS through camel
我在通过 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();
我是否需要添加其他东西,也许是一些依赖项或...?
如果有人遇到同样的问题,我通过在 from 部分添加 sftp:// 作为前缀来修复它。
我在通过 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();
我是否需要添加其他东西,也许是一些依赖项或...?
如果有人遇到同样的问题,我通过在 from 部分添加 sftp:// 作为前缀来修复它。