如何使用cassandra查询与时间戳列比较获取过去6个月的数据？

Question

如何使用cassandra查询获取与时间戳列比较的过去6个月数据？我需要获取与updatedTime（TimeStamp列）和MONtTime比较属于过去3/6个月的所有帐户声明。例如在SQL中，我们使用DateAdd（）函数tor this来获取。我不知道如何在cassandra中进行此操作。如果有人知道，请回复。提前感谢。

Answer 1

在cassandra中，您必须预先构建查询。

还要注意的是，您可能需要根据您在一段时间内拥有的帐户数量来存储数据。

如果您的整个数据库不包含超过100k条目，您可以只定义一个通用分区，例如使用名称“all”。但是通常人们有很多数据只是进入带有月、周、小时名称的存储桶。这取决于您获得的插入次数。

创建存储桶的原因是每个节点都可以通过它的分区键找到一个分区。这是主键定义的第一部分。然后在每个节点上，数据都按照您传递给主键的第二个信息进行排序。对数据进行排序使您能够“扫描”它们，即您将能够通过提供时间戳参数来检索它们。

假设您想要检索过去6个月的帐户，并且您正在将一个月内的所有帐户保存在同一个存储桶中。

架构可能是以下内容：

create table accounts {
    month text,
    created_time timestamp,
    account text,
    PRIMARY KEY (month, created_time)
}

通常，您会在应用程序级别执行此操作，合并查询是一种反模式，但对于少量查询也可以：

select account  
from accounts 
where month = '201701';

输出：

'201702'
'201703'

等等。

如果你有一些非常简单的东西，比如说预期的100 000个条目，那么你可以使用上面的模式，然后做一些类似的事情：

create table accounts {
    bucket text,
    created_time timestamp,
    account text,
    PRIMARY KEY (bucket, created_time)
}

select account 
from accounts 
where bucket = 'some_predefined_name' 
  and created_time > '2016-10-04 00:00:00'

再次总结一下，对于cassandra，您必须始终为要使用的访问模式准备结构。

Answer 2

Cassandra 2.2及更高版本允许用户定义函数（UDT），这些函数可以作为查询结果的一部分应用于存储在表中的数据。

如果您使用Cassandra 2.2及更高版本的UDF，您可以创建自己的方法

CREATE FUNCTION monthadd(date timestamp, month int)
    CALLED ON NULL INPUT
    RETURNS timestamp
    LANGUAGE java
    AS $$java.util.Calendar c = java.util.Calendar.getInstance();c.setTime(date);c.add(java.util.Calendar.MONTH, month);return c.getTime();$$

此方法接收两个参数

• 日期时间戳：您想要添加或减去月份数的日期
• 月int：您想要或加（）从日期中减去（-）的月数

返回日期时间戳

以下是如何使用此功能：

SELECT * FROM ttest WHERE id = 1 AND updated_time >= monthAdd(dateof(now()), -6) ;

这里monthAdd方法从当前时间戳中减去1 mont，因此此查询将上个月的数据

注意：默认情况下，在cassandra中禁用用户定义函数。yaml-如果您意识到安全风险，请将enable\u user\u defined\u functions=true设置为启用