cassandra获取时间范围内的所有记录

Question

CREATE TABLE userlog (
  user_id text,
  ts timestamp,
  action text,
  app_type text,
  channel_name text,
  channel_session_id text,
  pid text,
  region_id text,
  PRIMARY KEY (user_id, ts)
)

SELECT * FROM userlog  WHERE ts >= '2013-01-01 00:00:00+0200' AND  ts <= '2013-08-13 23:59:00+0200' ALLOW FILTERING;

Request did not complete within rpc_timeout.

在包含所有数据的生产性系统上。

是否有一个（最好是cql）查询可以与给定的列族或de一起平稳运行，我们必须更改设计？

Answer 1

超时是因为Cassandra返回数据的时间超过了超时时间（默认为10秒）。对于您的查询，Cassandra将尝试在返回之前获取整个数据集。对于多个记录，这很容易比超时时间更长。

对于产生大量数据的查询，您需要分页。

SELECT * FROM userlog WHERE ts >= '2013-01-01 00:00:00+0200' AND  ts <= '2013-08-13 23:59:00+0200' AND token(user_id) > previous_token LIMIT 100 ALLOW FILTERING;

其中user_id是返回的前一个user_id。您还需要在ts上分页，以确保您获得返回的最后一个user_id的所有记录。