我在卡桑德拉用CQL3创建了下表:
CREATE TABLE user_log (
user_id text,
zone_id text,
freq int,
time timestamp,
PRIMARY KEY (user_id, zone_id)
)
我使用datastax
Cassandra Python驱动程序将一些值插入此表,如下所示:
fmt = '%m/%d/%Y %H:%M'
t1 = datetime.strptime("01/01/2000 22:05", fmt)
prepared = session.prepare("""
INSERT INTO user_log (user_id,zone_id,freq,time) VALUES (?,?,?,?)
""")
session.execute_async(prepared.bind((str(Uid),str(zone_id),int(freq),t1 )))
插入很好,但是当我尝试检索值时,它会在检索时间值时引发异常。检索所有其他列都可以。Select *
也抛出异常。
如果您在cassandra中插入和检索时间戳时遇到问题,您并不孤单,请参阅以下内容: How to insert a datetime into a Cassandra 1.2 timestamp column
解决方案可能是从datetime计算unix时间戳(从epoch开始经过的ms),然后插入/检索它。
一般来说,如果您准确地说明了错误消息(如果有的话),它将有助于编写一个有用的答案?另外,到底是哪一行代码导致了这个错误?
相关问题 更多 >
编程相关推荐