Проверка работоспособности соединения Cassandra (с использованием hector)?

Question

Для мониторинга операций моего приложения, я ищу что-то подобное обычно используемую «проверку соединения SQL» запросом

ВЫБРАТЬ 1;

в Кассандре, используя драйвер Гектора. Я пробовал такие вещи, как просмотр Cluster.getKnownPoolHosts() и .getConnectionManager(). GetActivePools(). Но кажется, что их статус не постоянно обновляется, только когда я на самом деле пытаюсь получить доступ к Cassandra с запросом.

Я бы хотел, чтобы моя проверка работоспособности была независимой от любых ключей или пользовательских CF, которые должны существовать, поэтому просто запустить «фиктивный» запрос кажется трудным (против чего?). И, конечно, это не должно занимать много памяти или создавать значительную нагрузку.

Могу ли я заставить Hector каким-то образом обновить свой статус пула соединений без выполнения реального запроса?

(BTW: CQL даже не принимать «SELECT 1» в качестве действительного запроса.)

Answer 1

Решение, которое я сейчас использую, и которые, как представляется, наиболее надежным до сих пор (протестировано с Кассандрой 1.1 и 1,2) представляет собой простой запрос на «систему»:

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

это не совсем то, что я хотел, так как это «реальный» запрос, но с другой стороны, это не дает каких-либо ложных срабатываний.

Answer 2

С CQL3, я использую следующий запрос:

SELECT now() FROM system.local; 

Было бы хорошо, чтобы избавиться от ЕКА altogther сделать это родовым, в случае, если пользователь не имеет доступ к system keypace или local. Но, как и в случае с другими ответами, по крайней мере, это не должно давать ложных срабатываний.