重要提示:如果您现在正在处理此问题,请使用datastax的新cassandra驱动程序(即导入cassandra),因为它解决了大多数常见问题,不再使用旧的cql驱动程序,它已过时!这个问题在新驱动程序开发之前就已经存在了,我们不得不使用一个不完整的旧库cql(import cql<--不要再使用这个了,转到新驱动程序)。
简介我正在使用python库cql访问cassandra1.2数据库。在数据库中,我有一个带有timestamp列的表,在python代码中,我有一个要插入该列的datetime。示例如下:
table
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库在运行查询之前没有转义(“”)或转换datetime。
问题是,在不手动转义日期并能够更精确地将完整时间戳存储到cassandra timestamp列的情况下,正确的方法是什么?
提前谢谢!
5条答案
按热度按时间sg24os4d1#
大多数解决方案都是有效的,我只想建议一个更简单的方案:
mfuanj7w2#
对我来说,它直接与
不需要转换一些东西。因此,在python中,可以使用datetime值作为字符串:
0md85ypi3#
我可以告诉你怎么用cqlsh。试试这个
日期时间的等效长值
2013-05-13 15:12:51
是1368438171000
tjrkku2a4#
如果abhi已经声明可以使用microsellessinepoch作为cqlsh的长值,现在我们需要在python代码中使用它。
当使用cql库时,这种转换(从datetime到epoch后的毫秒数)不会发生,因此为了使更新工作并且仍然具有将datetime转换为epoch后的毫秒数所需的精度。
源代码使用了这个有用的问题:从datetime获取millis-since-epoch,特别是这个函数(注意我做的小改动):
解决方案
对于本例,代码为:
您可以将datetime转换为一个长值,其中包含自epoch以来的毫秒数,仅此而已,使用一个长值作为时间戳将更新转换为等效形式。
希望它能帮助别人
b1zrtrql5#
我知道这是一个2年前的问题,但如果有人来寻找答案,请使用datetime示例,而不是使用timestamp。不过,python驱动程序应该巧妙地处理整数/浮点。