如何将日期时间插入到Cassandra 1.2时间戳列中

Question

重要说明:如果您现在正在处理这个问题，请使用datastax的新cassandra-driver(即导入cassandra ),因为它解决了大多数常见问题，不要再使用旧的cql驱动程序，它已经过时了！这个问题在新驱动开发之前就存在了，我们不得不使用一个不完整的旧库，叫做cql(导入cql

简介我正在使用python库cql访问Cassandra 1.2数据库。在数据库中，我有一个带有时间戳列的表，在我的Python代码中，我在该列中插入了一个日期时间。示例如下：

桌子

CREATE TABLE test (
     id text PRIMARY KEY,
     last_sent timestamp
);

代码

import cql
import datetime
...
cql_statement = "update test set last_sent = :last_sent where id =:id"
rename_dict = {}
rename_dict['id'] = 'someid'
rename_dict['last_sent'] = datetime.datetime.now()
cursor.execute (cql_statement, rename_dict)

问题

当我执行代码时，实际执行的cql语句是这样的:

update test set last_sent =2013-05-13 15:12:51 where id = 'someid'

那么它会失败并出现错误

 Bad Request: line 1:XX missing EOF at '-05'

问题似乎是cql库没有在运行查询之前转义（“”）或转换日期时间。

问题是，在不手动转义日期的情况下，如何正确地将完整的时间戳更精确地存储到cassandra时间戳列中？

提前致谢！

Answer 1

对我来说，它直接与

update test set last_sent = '2013-05-13 15:12:51' where id = 'someid'

无需转换某些内容。因此，在Python中，您可以使用日期时间值作为字符串来执行此操作：

cursor.execute("UPDATE test SET ts=:ts WHERE id=:id;",
    dict(ts=your_datetime.isoformat(), id=id))

Answer 2

abhi已经说过这可以通过使用来自cqlsh的毫秒作为长值来实现，现在我们需要让它在Python代码中工作。

使用cql库时，此转换（从日期时间到自纪元以来的毫秒）不会发生，因此为了使更新工作并且仍然具有将日期时间转换为自纪元以来的毫秒所需的精度。

使用这个有用问题的源:从datetime获取自epoch以来的毫秒数，特别是这个函数(注意我做的小改动):

解决方案

import datetime

def unix_time(dt):
    epoch = datetime.datetime.utcfromtimestamp(0)
    delta = dt - epoch
    return delta.total_seconds()

def unix_time_millis(dt):
    return long(unix_time(dt) * 1000.0)

对于这个例子，代码应该是:

cql_statement = "update test set last_sent = :last_sent where id =:id"
rename_dict = {}
rename_dict['id'] = 'someid'
rename_dict['last_sent'] = unix_time_millis(datetime.datetime.now())
cursor.execute (cql_statement, rename_dict)

您可以将日期时间转换为包含自 epoch 以来的毫秒数的长整型值，仅此而已，更新将使用时间戳的长整型转换为等效形式。

希望它能帮助别人

Answer 3

我可以告诉你怎么用cqlsh做。试试这个

update test set last_sent =1368438171000 where id = 'someid'

日期时间 2013-05-13 15：12：51 的等效长值1368438171000