代码之家  ›  专栏  ›  技术社区  ›  paul

在Alpakka Cassandra中保存DTO

  •  1
  • paul  · 技术社区  · 7 年前

    有谁知道我在哪里可以看到Alpakka cassandra是否以一致性级别管理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));
    }
    
    1 回复  |  直到 7 年前
        1
  •  1
  •   Stefano Bonetti    7 年前

    正如您所注意到的,目前Alpakka中的Cassandra连接器相当薄。如果您的DTO需要更丰富的支持,您可以选择更丰富的客户端,如 Phantom .

    关于如何使用幻影检查,有很多很好的例子 this one def store[T](t: T): Future[ResultSet] 函数插入数据。

    mapAsync(n) combinator在您的Akka流中使用它们。