Kontrola stanu połączenia Cassandry (przy użyciu hektora)?

Question

Do monitorowania operacji mojej aplikacji, szukam czegoś podobnego do „walidacji połączenie SQL” powszechnie stosowanych zapytań

wybierz 1;

w Cassandra, przy użyciu sterownika Hector. Próbowałem takich rzeczy jak spojrzenie na Cluster.getKnownPoolHosts() i .getConnectionManager(). GetActivePools(). Wygląda jednak na to, że ich status nie jest stale aktualizowany, tylko gdy faktycznie próbuję uzyskać dostęp do Cassandry za pomocą zapytania.

Chciałbym, aby moja kontrola stanu była niezależna od jakichkolwiek kluczowych obszarów lub systemów CF użytkowników, które muszą istnieć, więc po prostu "fikcyjne" zapytanie wydaje się trudne (wbrew czemu?). I oczywiście nie powinno to zająć dużo pamięci ani generować żadnego znaczącego obciążenia.

Czy mogę zmusić Hectora w jakiś sposób do zaktualizowania statusu puli połączeń bez uruchamiania prawdziwego zapytania?

(BTW: CQL nawet nie akceptują „SELECT 1” jako ważnego zapytania.)

Answer 1

Rozwiązanie obecnie używam, a co wydaje się być najbardziej wytrzymałe tak daleko (testowane z Cassandrą 1.1 i 1.2) jest proste zapytanie na „system”:

Query<String> query = Query.selectQuery("*", "system", null, 1, consistencyLevel, StringSerializer.get());

to nie jest dokładnie to, co chciałem, ponieważ jest to „prawdziwy” kwerendy, ale z drugiej strony nie daje żadnych fałszywych alarmów.

Answer 2

Z CQL3 używam następujące zapytanie:

SELECT now() FROM system.local; 

Byłoby miło, aby pozbyć klauzuli FROM altogther aby ten ogólny, w przypadku, gdy użytkownik nie ma dostępu do system keyspace lub local rodzina kolumn z jakiegoś powodu. Ale tak jak w przypadku innych odpowiedzi, przynajmniej nie powinno to dawać fałszywych trafień.