Akka-Streamによるパーティション分割の使用

Question

Akka Stream Partition機能を使用する方法の例を探しています。私はストアを書くことを最適化しようとしています。そのためには、私が選択したバッチでアイテムをグループ化して一度に書きたいと思いますが、並行性を利用するために並行して実行したいと考えています。したがって、バッチを実行してからデータベースに書き込むと、同時に8つのスレッドが実行されます。

8つの並列スレッドに1つの更新として30レコードを書き込むことができます。

グループ化またはGroupedWithinは十分に文書化されており、私はそれらを成功させて試しました。しかし、私が並行してやりたいことをするために見る唯一のことは、実際にはパーティショニングです。私はランダムにパーティションを分割したいですが、パーティションの仕方は気にしません。ラウンドロビンパーティショナーが好きな施設があれば、私も知りたいのですが。

しかし、どうやってパーティションを使うのですか？私はGraphBuilderを構築する必要がありますか？

Partitionの

Answer 1

使用例がhereを見つけることができます助けてください。

ランダムパーティショニングをお探しの場合は、Balanceステージが必要です。ドキュメントには、hereという例があります。

どちらの場合も、GraphDSLを使用する必要があります（文書番号here）。