如何使用python-cassandra-driver插入具有自定义时间戳的数据

Question

幸运的是，我发现了一个‘使用时间戳’的操作，时间戳较大的cql会覆盖较小的时间戳，否则不会。因此，使用“使用时间戳”，我可以使用自定义时间戳来确定是否覆盖。它在CQLSH中工作得很好。

但是它在python-cassandra-driver中失败了，如何使“使用时间戳”在python-cassandra-driver中起作用？我的代码如下：

insert_sql = ("INSERT INTO activate (rowkey, qualifier, info, act_date, log_time) "
              "VALUES(%s, %s, %s, %s, %s) "
              "USING TIMESTAMP %s")
insert_data = (a_string, a_string, a_string, a_string, a_string, a_custom_timestamp)
session.execute(insert_sql, insert_data)

Answer 1

对于设置自定义时间戳来说，这是一个不正确的用例。重要的是不要滥用这个特性，因为它可能会产生许多意想不到的副作用，并最终导致不可靠的数据。

改用轻量级事务(LWT)（也用PreparedStatements代替原始字符串！）

stmt = session.prepare("
           INSERT INTO activate (rowkey, qualifier, info, act_date, log_time)
           VALUES (?, ?, ?, ?, ?)
           IF NOT EXISTS
           ")
results = session.execute(stmt, [arg1, arg2, ...])

在这里和这里读更多。LWT由于必须触发paxos共识检查而受到性能打击，但它比“先读后写”的方法要好。

CREATE TABLE activate (
     rowkey text,
     insert_time timestamp,
     qualifier text,
     info text,
     act_date timestamp,
     log_time timestamp, 
   PRIMARY KEY (rowkey, insert_time));