Chequeo de salud para la conexión de Cassandra (usando hector)?

Question

Para la supervisión de las operaciones de mi solicitud, yo estoy buscando algo similar a la "validación de conexión de SQL" que se utiliza comúnmente consulta

seleccione 1;

en Cassandra, con el controlador Hector. He intentado cosas como mirar Cluster.getKnownPoolHosts() y .getConnectionManager(). GetActivePools(). Pero parece que su estado no se actualiza continuamente, solo cuando intento acceder a Cassandra con una consulta.

Me gustaría que mi chequeo de salud sea independiente de cualquier espacio de claves o CF de usuario que necesiten existir, por lo que simplemente ejecutar una consulta "ficticia" parece difícil (¿contra qué?). Y, por supuesto, no debería llevar mucha memoria o generar una carga significativa.

¿Puedo forzar a Hector a actualizar el estado de su grupo de conexiones sin ejecutar una consulta real?

(Por cierto: CQL ni siquiera aceptar "SELECT 1" como una consulta válida.)

Answer 1

La solución actualmente estoy usando, y que parece ser el más robusto hasta el momento (probado con Cassandra 1.1 y 1.2) es una simple consulta en "sistema":

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

no es exactamente lo que quería, ya que es una consulta "real", pero por otro lado no da ningún falso positivo.

Answer 2

Con CQL3, estoy usando la siguiente consulta:

SELECT now() FROM system.local; 

que sería bueno para deshacerse de la cláusula FROM altogther para hacer de este genérico, en caso de que el usuario no tiene acceso a la system keyspace o familia de columnas local por algún motivo. Pero al igual que con las otras respuestas, al menos esto no debería dar falsos positivos.