Wenn ich eine große Ergebnismenge von einer Cassandra-Abfrage habe.Akka Stream Quelle - Cassandra Resultset
Gibt es eine Möglichkeit, dieses Ergebnis als Quelle eines Akka-Streams festzulegen, damit ich jede Zeile verarbeiten kann?
Dank
Wenn ich eine große Ergebnismenge von einer Cassandra-Abfrage habe.Akka Stream Quelle - Cassandra Resultset
Gibt es eine Möglichkeit, dieses Ergebnis als Quelle eines Akka-Streams festzulegen, damit ich jede Zeile verarbeiten kann?
Dank
Wahrscheinlich eine späte Antwort, aber ja, gibt es ein neues Projekt alpakka. Die Cassandra-Abfrage kann als Zeilenstrom bereitgestellt werden. Werfen Sie einen Blick auf this documentation.
I endete diese Bibliothek nach oben mit Cassandra https://github.com/timcharper/cassandra-talks-scala
https://github.com/outworkers/phantom –
@GiovanniCaporaletti spricht, ist es ein Beispiel dafür, wie es mit phanthom zu tun? – Ciaran0
Es gibt Beispiele in einigen GitHub-Repos, wie folgt: https://github.com/Tecsisa/reactive-cassand-phaphom (Tipp: Sie können einen reaktiven Streams-Publisher in eine Quelle einbinden). Tut mir leid, ich kann kein richtiges Beispiel machen, aber ich bin ziemlich beschäftigt –