Возникли проблемы с подключением по sftp после перемещения sftp на AWS через верблюда - PullRequest
Новая
       55

Возникли проблемы с подключением по sftp после перемещения sftp на AWS через верблюда

1 голос
/ 24 апреля 2020

У меня проблемы с подключением по sftp через верблюжье приложение springboot. Это начало происходить после того, как мы переместили наш 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();

Нужно ли добавить что-то еще, может быть, некоторую зависимость или ...?

1 Ответ

1 голос
/ 24 апреля 2020

Если у кого-то возникла такая же проблема, я исправил ее, добавив sftp: // в качестве префикса в из part.

...