如何统计Cassandra中特定列族的行键数量（查看详细信息）

Question

我正在尝试把数据从SQL加载到No-SQL数据库，也就是Cassandra。但是有些行的数据对不上。有人能告诉我怎么计算Cassandra中某个列族的行键数量吗？

我试过使用get_count和get_multicount这两个方法，但它们需要我提供键，而我并不知道这些键是什么。其实我只想知道行键的数量。使用list column_family_name可以列出数据，但最多只能显示100行。有办法突破这个100行的限制吗？

Answer 1

你可以在不读取所有行的情况下，计算Cassandra中的行数。

可以查看Spark中的实现，里面有一个叫cassandraCount()的方法，它能很高效地完成这个任务。

Answer 2

据我所知，想要获取一个列族的行数是没有直接的方法的。你需要对整个列族进行范围查询。

如果你的列族叫做 cf，可以试试下面的代码：

num_rows = len(list(cf.get_range()))

不过，关于 get_range 的说明提到，如果你的行数太多，这样做可能会出问题。你可能需要分批进行，使用 start 和 row_count 来控制。