我正在使用datastax python-driver从表中检索时间戳.我要做的是将先前检索的时间戳存储在var中,并在下一个查询中使用它来检索大于前一个时间戳的时间戳.该查询基本上是这样的:
cqlsh> SELECT insert_time, message FROM cf WHERE message_key='q1' AND insert_time>'2013-10-30 10:32:44+0530' ORDER BY insert_time ASC LIMIT 1;
insert_time | message
--------------------------+----------------------------------
2013-10-30 10:32:45+0530 | 83500612412011e3ab6c1c3e84abd9db
Run Code Online (Sandbox Code Playgroud)
正如您所看到的,CQL的时间戳是2013-10-30 10:32:45+0530.但是当我通过python-driver检索它时结果是不同的(我在不同的系统上执行python查询,而不是在任何cass节点上执行):
>>> from cassandra.cluster import Cluster
>>> c = Cluster( [10.60.60.2] )
>>> session = c.connect()
>>> q = "SELECT insert_time, message FROM cf WHERE message_key='q1' AND insert_time>'2013-10-30 10:32:44+0530' ORDER BY insert_time ASC LIMIT 1"
>>> rows = session.execute(q)
>>> print rows …Run Code Online (Sandbox Code Playgroud)