Akka 스트림 각 요소를 ftp 싱크

Question

Akka 스트림의 각 요소를 (다른) FTP 파일에 쓰려합니다. Alpakka를 사용하면 각 요소를 FTP 싱크를 사용하여 같은 파일에 쓸 수 있습니다. 그러나 각 요소를 다른 파일에 쓰는 방법을 알아낼 수 없습니다.

source.map(el -> /* to byte string */).to(Ftp.toPath("/file.xml", settings)); 

따라서 모든 el은 다른 파일로 끝나야합니다. 당신이 Alpakka FTP 싱크를 사용하려면

Answer 1

, 당신은 당신이 FTP 연결을 설정하고 데이터를 기록 자신의 싱크를 만들어야합니다, 그렇지 않으면

def sink(n: String): Sink[String, NotUsed] = Ftp.toPath(s"$n.txt", settings) 

    source.runForeach(s ⇒ Source.single(s).runWith(sink(s))) 

의 라인을 따라 뭔가를해야 입력 핸들러의 일부로. 자신 만의 그래프 스테이지를 만들어야합니다. 자세한 내용은 docs에서 확인할 수 있습니다.