在Alpakka Cassandra保存DTO

Question

嗨，我使用datastax驱动程序创建了自己的Cassandra连接器。但是我正面临着一些内存泄漏问题，所以我开始考虑另一个解决方案，比如Alpakka de like弯曲，它有一个Cassandra连接器。

但是在查看了糟糕的文档之后，我改变了主意，因为它只是使用带有CQLSH查询的连接器，在我的例子中，我管理DTO对象。

有人知道任何文件，我可以看到，如果阿尔帕卡卡桑德拉管理保存DTO的一致性水平？

此代码来自我当前的连接器。我也想取得类似的成就。

private void updateCreateEntry(DTO originalDto, Mapper cassandraMapper) {
    ConsistencyLevel consistencyLevel = ((DTOCassandra) originalDto).getConsistencyLevel();
    //.- For writing we set the consistency level to quorum
    cassandraMapper.save(originalDto, Option.consistencyLevel(consistencyLevel != null ? consistencyLevel : DEFAULT_CONSISTENCY_LEVEL));
}

Answer 1

正如您注意到的，目前Alpakka内部的Cassandra连接器非常薄。如果您需要对DTO提供更丰富的支持，您可以选择像幻影这样更丰富的客户端。

例如，关于如何使用幻影-检查这一个，有很好的例子。一旦创建了模型，幻影将为您提供一个def store[T](t: T): Future[ResultSet]函数来插入数据。

您可以将对这些函数的调用提供给mapAsync(n)组合器，以便在您的Akka中使用它们。