Wie ein Datetime in eine Cassandra 1.2 Zeitstempel Spalte

Question

WICHTIG einzufügen Wenn Sie mit diesem Problem heute zu tun haben, verwenden Sie das neue cassandra-Treiber von DataStax (dh Import cassandra), da es die meisten dieser gemeinsamen Probleme und don löst Benutze den alten cql Treiber nicht mehr, er ist veraltet! Diese Frage ist alt, bevor der neue Treiber gerade in Entwicklung war, und wir mussten eine unvollständige alte Bibliothek namens cql verwenden (import cql < - verwende das nicht mehr, gehe zum neuen Treiber).

Intro Ich benutze die Python-Bibliothek CQL, um auf eine Cassandra 1.2-Datenbank zuzugreifen. In der Datenbank habe ich eine Tabelle mit einer Timestamp-Spalte und in meinem Python-Code muss eine Datetime in die Spalte eingefügt werden. Beispiel wie folgt:

Tabelle

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

Der Code

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) 

Das Problem

Wenn ich den Code der tatsächlichen cql Anweisung ausgeführt ausführen, wie dies :

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

Dann schlägt es mit einem Fehler

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

Das Problem, dass die cql Bibliothek zu sein scheint, ist (‚‘) nicht entkommen oder die Datetime konvertieren, bevor die Abfrage ausgeführt wird.

Die Frage Was ist der richtige Weg, dies ohne manuell zu tun, das Datum zu entkommen und in der Lage sein, einen vollständigen Zeitstempel speichern mit mehr Präzision in eine cassandra Timestamp-Spalte?

Vielen Dank im Voraus!

Answer 1

Hat abhi bereits erklärt dies mit den Millisekunden seit Epoche als Long-Wert von cqlsh getan werden kann, jetzt müssen wir es in machen arbeiten der Python-Code.

Wenn Sie die cql-Bibliothek verwenden, wird diese Konvertierung (von datetime in Millisekunden seit Epoche) nicht ausgeführt, damit das Update funktioniert und Sie immer noch die erforderliche Genauigkeit haben, um die datetime in Millisekunden seit Epoche zu konvertieren.

Quelle Mit dieser nützlichen Frage: Getting millis since epoch from datetime, insbesondere diese Funktionen (die kleine Änderung stelle ich gemacht):

Die Lösung

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) 

Für dieses Beispiel der Code wäre :

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) 

Sie können die Datetime in einen Long-Wert konvertieren, der die Anzahl der Millisekunden seit der Epoche enthält, und das ist alles, die Aktualisierung wird in eine äquivalente Form transformiert, die einen Long-Wert für den Timestamp verwendet.

Hoffe, dass es jemand anderes

Answer 2

Ich kann Ihnen sagen, wie es in Cqlsh zu tun. Versuchen Sie, diesen

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

Equivalent long-Wert für Datum Zeit 2013-05-13 15:12:51 ist 1368438171000

Answer 3

gut für mich hilft es funktioniert direkt mit

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

Keine Notwendigkeit, etwas zu konvertieren. So in Python Sie es mit dem Datetime-Wert als String tun können:

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

Answer 4

Die meisten Lösungen sind gültig, ich will nur ein einfacheres vorschlagen:

from datetime import datetime 

my_date = int(float(datetime.now().strftime("%s.%f"))) * 1000 

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

Answer 5

Ich weiß es ist ein 2 Jahre alte Frage, aber wenn jemand auf der Suche nach einer Antwort ist, verwenden Sie eine datetime-Instanz anstelle des Zeitstempels. Python-Treiber sollten jedoch intelligent mit einem Integer/Float umgehen.