0

我在 cassandra 中有一个列族，它记录特定用户在指定时间段内发出的所有事件。

我正在使用由 UUID1 和 UTF8 字符串组成的复合列。我想在特定时间后选择所有列。

// Code to create the column family.
use phpcassa\SystemManager;

$sys = new SystemManager('127.0.0.1');

$sys->create_column_family($keyspace, 'UserActivity', array(
    "comparator_type" => "CompositeType(LexicalUUIDType, UTF8Type)",
    "key_validation_class" => "UTF8Type"
));

在下面的代码中，我尝试读取数据。最初我尝试创建一个仅在 1 索引处设置事件类型的数组，但是尽管这似乎可行，但我在日志中遇到了很多错误。现在，我试图在过去设置一个时间戳，并以此为基础创建一个 UUID1。没有错误 - 但也没有数据。

// Code to read data
$activityFam = new ColumnFamily($this->pool, 'UserActivity');
$activityFam->insert_format = ColumnFamily::ARRAY_FORMAT;
$activityFam->return_format = ColumnFamily::ARRAY_FORMAT;


$fiveMinPrev = $this->dateFactory->getDateTime();
$fiveMinPrev->sub(new \DateInterval("PT5M"));

$uuid = \phpcassa\UUID::uuid1(null, $fiveMinPrev->getTimestamp());
// Get the most recent SESSION event from the users activity log.
$slice = new ColumnSlice(array(0 => $uuid, 1=>self::EVENT_SESSION));

$columns = $activityFam->get($someUserId, $slice);

如何从指定时间开始选择列？

谢谢，

4

1 回答 1

0

呸!

我意识到这正是正确的方法，但似乎我没有使用我的“DateFactory”生成的时间戳（它允许我在测试期间冻结和操纵时间）来基于我实际插入记录的时间戳。

从而产生不正确的结果！

于 2013-06-24T15:10:30.743 回答