Jak wkładać datetime do Cassandry 1,2 timestamp kolumna

Question

WAŻNE Jeśli masz do czynienia z tym problemem dzisiaj korzystać z nowej Cassandra-sterownik z datastax (tj Cassandra import), ponieważ rozwiązuje większość tych wspólnych problemów i Don nie używa już starego sterownika cql, jest przestarzały! To pytanie jest stare, zanim nowy sterownik był jeszcze w fazie rozwoju i musieliśmy użyć niekompletnej starej biblioteki o nazwie cql (import cql < - nie korzystaj już z tego, przenieś się do nowego sterownika).

Intro Używam biblioteki cql python, aby uzyskać dostęp do bazy danych Cassandra 1.2. W bazie danych mam tabelę z kolumną znacznika czasu iw moim kodzie Pythona mam datetime do wstawienia w kolumnie. Przykład następująco:

Tabela

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

Kod

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) 

Problem

Kiedy wykonać kod rzeczywisty oświadczenie CQI wykonywany jest tak :

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

Wtedy nie powiedzie się z powodu błędu

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

Problem wydaje się, że biblioteka CQI nie ucieka („”) lub konwersji datetime przed uruchomieniem kwerendy.

Pytanie Co to jest poprawny sposób to zrobić bez konieczności ręcznego ucieczce datę i być w stanie przechowywać pełną znacznik czasu z większą precyzją do kolumny Cassandra datownika?

Z góry dziękuję!

Answer 1

Has abhi już wspomniano, można to zrobić za pomocą milisekund od epoki jako długą wartość z cqlsh, teraz musimy zrobić to praca w kod Pythona.

Podczas korzystania z biblioteki cql ta konwersja (z datetime do milisekund od epoki) nie dzieje się tak, aby aktualizacja działała i nadal ma dokładność, jakiej potrzebujesz do konwersji datetime na milisekundy od epoki.

Źródło Stosując tę ​​użyteczną pytanie: Getting millis since epoch from datetime, W szczególności funkcje (zwróć uwagę na małą zmianę zrobiłem):

Rozwiązanie

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) 

W tym przykładzie kod byłby :

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) 

Można przekonwertować datetime na długą wartość zawierającą liczbę milisekund od epoki i to wszystko, aktualizacja jest przekształcana na równoważną formę przy użyciu długiej wartości znacznika czasu.

Nadzieja pomaga kogoś innego

Answer 2

Mogę ci powiedzieć, jak to zrobić w cqlsh. Spróbuj tego

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

Equivalent długą wartość dla daty czasu 2013-05-13 15:12:51 jest 1368438171000

Answer 3

No dla mnie to działa bezpośrednio z

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

ma potrzeby konwertowania coś. Więc w Pythonie można to zrobić przy użyciu wartości datetime jako wyrażenie:

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

Answer 4

Większość rozwiązań jest ważna, po prostu chcę się sugerować prostsze:

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

wiem, że jest to 2-letnie pytanie, ale jeśli ktoś szuka odpowiedzi, użyj instancji datetime zamiast używać timestamp. Sterownik Pythona powinien jednak inteligentnie obsługiwać liczbę całkowitą/zmiennoprzecinkową.