Загрузка CSV с FTP-сервера с использованием Apache Camel - PullRequest
Новая
       14

Загрузка CSV с FTP-сервера с использованием Apache Camel

0 голосов
/ 03 мая 2018

Я пытаюсь загрузить CSV-файл с FTP-сервера, используя Apache Camel, я пробовал несколько подходов, но пока не увенчался успехом. 

1) Approach 1 - Trying to just download a csv and store in local.

from("direct://start").

from("ftp://user@ftpserver/Directory?password=secret&download=true&fileName=a-b-c-2018-04-
16.csv")
   .to("file://dir")

Исключение: нет доступных преобразователей типов для преобразования: java.lang.Integer к необходимому типу: java.io.InputStream со значением -1 

2) Approach 2 - Trying to unmarshal and save in a arrayBuffer 

 var result = mutable.ArrayBuffer.empty[String]

from("direct://start")
.from("ftp://user@ftpserver/Directory?password=secret&fileName=a-b-c-2018-
04-16.csv").unmarshal().csv().process(new Processor {
  override def process(exchange: Exchange): Unit = {
    val csvContent = exchange.getIn().getBody(classOf[String])
    result+=csvContent
   }
 })
  .to("file://dir")

Я не думаю, что здесь работает сам процессор ... выдает ту же ошибку, что и выше ..

...