Akka-Stream mit Partition-Stufe

Question

Ich versuche, ein Beispiel zu finden, das zeigt, wie Akka Stream Partition-Fähigkeit zu verwenden. Ich versuche, den Store zu optimieren. Dafür möchte ich Artikel in einer Reihe meiner Wahl gruppieren und sie auf einmal schreiben, aber um Parallelität zu verwenden, würde ich es gerne parallel machen. Somit würde der Batch und dann das Schreiben in der Datenbank geschehen, sagen wir mal auf 8 simultane Threads.

Ich könnte 30 Datensätze als ein Update auf 8 parallele Threads schreiben.

Grouped oder GroupedWithin sind gut dokumentiert und ich habe sie mit Erfolg versucht. Das einzige, was ich sehe, was ich parallel machen möchte, ist eine Partitionierung. Ich würde nach dem Zufallsprinzip partitionieren, es ist mir egal, wie es Partition ist. Wenn es Möglichkeiten gibt, einen Round-Robin-Partitionierer zu verwenden, würde ich es gerne wissen.

Aber in erster Linie, wie verwende ich Partition. Muss ich einen GraphBuilder erstellen?

Bitte helfen

Answer 1

Anwendungsbeispiel von Partitionhere gefunden werden kann.

Wenn Sie nach zufälliger Partitionierung suchen, ist die Balance Bühne, was Sie brauchen. Die Dokumentation enthält ein Beispiel here.

In beiden Fällen müssen Sie die GraphDSL verwenden, dokumentiert here.