cassandra - 如何在 cassandra 中进行轮询？

Question

我正在尝试找到一种对 cassandra 数据库进行轮询的方法，但我对此很陌生，而且不知道如何操作。

假设我有一个像这样的“用户”表

-> users
    -> user_name
    -> gender
    -> state

我想不断进行轮询，以便我知道是否有新用户添加到表中。我怎样才能做到这一点？

Answer 1

关系数据库中的标准方法将涉及执行 SELECT，按一些与时间相关的 ID 降序排序，以便始终首先返回最新行，这样您就可以查看它是否与您的最后一个“最新行”匹配，并且识别更改 - 在 cassandra 中，这是行不通的，因为如果没有 WHERE 子句，结果将按分区的标记排序，这(几乎肯定)是随机的。

解决方案是创建一个具有分区的表，其中用户在给定分区内排序。例如:

CREATE TABLE user_buckets (
    bucket text,
    user_timestamp timeuuid,
    user_username text,
    PRIMARY KEY(bucket, user_timestamp)
) WITH CLUSTERING ORDER BY (user_timestamp DESC);

在这种情况下，您可以写入 users 表和 user_buckets 表，其中“bucket”是合理的(例如 date(YYYY) - 其中每个分区包含该年注册的所有用户，或 date (YYYYMMDD) - 其中每个分区包含当天注册的所有用户)，然后使用 SELECT ... FROM user_buckets WHERE bucket=(current-bucket) AND user_timestamp > (您看到的最后一个时间戳)。