Akka stream各要素をftpにシンクします

Question

Akkaストリームの各要素を（別の）FTPファイルに書きたいと思います。 Alpakkaを使って、各要素をFTPシンクを使用して同じファイルに書き込むことができます。しかし、私はどのように別のファイルに各要素を書くかを把握していないようです。

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

したがって、elはすべて別のファイルになります。

Answer 1

あなたはAlpakka FTPシンクを使用する場合は、

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

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

の線に沿って何かをしなければならないそうでなければ、あなたはFTP接続を確立し、データを書き込み、独自のシンクを作成する必要があります入力ハンドラの一部としてそれを行うには、独自のグラフステージを作成する必要があります。これに関する詳細はdocsにあります。