akka-stream - Alpakka Cassandra 流量用法

Question

我在这里阅读 Alpakka Cassandra 的文档

它使使用 Cassandra 作为源和接收器变得非常容易。但是流量使用情况如何。

通过流使用，我的意思是我没有将 Cassandra 用作源或接收器。但要查找数据。

使用Alpakka有可能吗？还是我必须自己编写 Cassandra jdbc 代码？

Answer 1

1) 下沉。如果你查看Alpakka的源码，你会发现Sink的构造如下

Flow[T]
      .mapAsyncUnordered(parallelism)(t ⇒ session.executeAsync(statementBinder(t, statement)).asScala())
      .toMat(Sink.ignore)(Keep.right)

如果你只需要一个经过的流程，你可以随时修剪掉Sink.ignore部分，你就会有

Flow[T]
          .mapAsyncUnordered(parallelism)(t ⇒ session.executeAsync(statementBinder(t, statement)).asScala())

您只需要公开 Guava 期货转换器，该转换器目前在 Alpakka 中是私有的。

2）来源。你总是可以通过做aFlow从 a获得）Source.flatMapConcat(x => CassandraSource(...)