Kiểm tra sức khỏe cho kết nối Cassandra (sử dụng hector)?

Question

Đối với giám sát hoạt động của ứng dụng của tôi, tôi đang tìm kiếm một cái gì đó tương tự như sử dụng phổ biến "kết nối xác nhận SQL" truy vấn

SELECT 1;

trong Cassandra, sử dụng trình điều khiển Hector. Tôi đã thử những thứ như nhìn vào Cluster.getKnownPoolHosts() và .getConnectionManager(). GetActivePools(). Nhưng có vẻ như tình trạng của họ không được cập nhật liên tục, chỉ khi tôi thực sự cố gắng truy cập Cassandra bằng một truy vấn.

Tôi muốn kiểm tra sức khỏe của mình độc lập với bất kỳ không gian khóa hoặc CF người dùng nào cần tồn tại, vì vậy chỉ cần chạy truy vấn "giả" có vẻ khó khăn (chống lại cái gì?). Và tất nhiên nó không nên mất nhiều bộ nhớ hoặc tạo ra bất kỳ tải trọng đáng kể nào.

Tôi có thể buộc Hector bằng cách nào đó để cập nhật trạng thái kết nối của hồ bơi mà không cần chạy truy vấn thực không?

(BTW: CQL thậm chí không chấp nhận "SELECT 1" như một truy vấn hợp lệ.)

Answer 1

Giải pháp Tôi hiện đang sử dụng, và đó dường như là mạnh mẽ nhất cho đến nay (thử nghiệm với Cassandra 1.1 và 1.2) là một truy vấn đơn giản trên "hệ thống":

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

đó không phải là chính xác những gì tôi muốn vì nó là một "thực" truy vấn, nhưng mặt khác nó không đưa ra bất cứ dương tính giả.

Answer 2

Với CQL3, Tôi đang sử dụng các truy vấn sau đây:

SELECT now() FROM system.local; 

Nó sẽ được tốt đẹp để thoát khỏi mệnh đề FROM altogther để làm điều này chung chung, trong trường hợp người dùng không có quyền truy cập vào các system keyspace hoặc local gia đình cột vì một số lý do. Nhưng như với các câu trả lời khác, ít nhất điều này không nên đưa ra những kết quả dương tính giả.