問題タブ [hector]

アプリケーションの運用監視のために、一般的に使用される「SQL接続検証」クエリに似たものを探しています

SELECT 1;

Cassandraで、Hectorドライバーを使用します。Cluster.getKnownPoolHosts（）や.getConnectionManager（）。getActivePools（）を見てみました。しかし、実際にクエリでCassandraにアクセスしようとした場合にのみ、ステータスが継続的に更新されないようです。

ヘルスチェックを、存在する必要のあるキースペースやユーザーCFから独立させたいので、「ダミー」クエリを実行するだけでは難しいようです（何に対して？）。そしてもちろん、それは多くのメモリを消費したり、大きな負荷を生成したりするべきではありません。

実際のクエリを実行せずに、Hectorに接続プールのステータスを更新させることはできますか？

（BTW：CQLは「SELECT1」を有効なクエリとしても受け入れません。）

以下の例のように、スーパー列と通常の列の両方を追加できる列ファミリーを探しています

出来ますか？はいの場合、plzは事前に感謝を提案します

スーパー列名に応じて、異なる行 ID 値を取得したいと考えています。その目的のために、私はこのコードを使用しました

しかし、それは機能していません。

Cassandra に保存されているデータにアクセスするための Java コードを書いています。ヘクター API を使用しています。

データを取得するために、スライス クエリを使用しています。しかし、それは5つの算術演算子しかサポートしていないようで、それもAND演算子でサポートされています。

OR 演算子を使用して述語を記述したり、文字列のように含まれている機能に基づいてクエリを実行したりする方法はありますか。???

次のコード行でクラスターを簡単に作成できます。

正常にコンパイルされ、実行すると、次のエラーが発生しました。どんな提案にも感謝します。

エラー: [java] INFO connection.CassandraHostRetryService: ダウンしたホスト再試行サービスがキュー サイズ -1 で開始され、再試行遅延 10 秒 [java] スレッド "main" で例外 java.lang.NoClassDefFoundError: org/apache/cassandra/thrift/InvalidRequestException [java ] me.prettyprint.cassandra.connection.ConcurrentHClientPool.(ConcurrentHClientPool.java:48) [java] me.prettyprint.cassandra.connection.RoundRobinBalancingPolicy.createConnection(RoundRobinBalancingPolicy.java:68) [java] me.prettyprint.cassandra .connection.HConnectionManager.(HConnectionManager.java:65) [java] at me.prettyprint.cassandra.service.AbstractCluster.(AbstractCluster.java:69) [java] at me.prettyprint.cassandra.service.AbstractCluster.(AbstractCluster. java:65) [java] at me.prettyprint.cassandra.service.ThriftCluster.(ThriftCluster.java:17) [Java] me.prettyprint.hector.api.factory.HFactory.createCluster(HFactory.java:176) [java] me.prettyprint.hector.api.factory.HFactory で.getOrCreateCluster(HFactory.java:155) [Java] me.prettyprint.hector.api.factory.HFactory.getOrCreateCluster(HFactory.java:128) で

私のデータモデルはこのようになります

ここで、startDate_mobileNo、Call_TYPE、および endDate をフィルタリングする検索結果を作成します。これは、endDate をセカンダリ インデックスとして作成することで実行できます。ただし、スーパー カラムでのセカンダリ インデックス作成はできません。だから私は続行する方法を理解することができません。はい、単純な Java コーディングを使用して結果データをフィルタリングすることにより、セカンダリ インデックス フィルタリングの部分を実行できます。しかし、大きなデータの場合、メモリが不足する可能性があるため、これは正しい考えではないと思います。そこで、私にいくつかのアイデアを提案してください。

前もって感謝します

Cassandra のある時点で OOM 例外を受け取りました。私のものは、適度なパワーのサーバーで実行されている単一のインスタンスであり、負荷テストを行っていたので、驚くことではありません。

しかし、その後インスタンスを使用できなくなりました。キースペースを一覧表示すると、「システム」のみが表示されます。しかし、私がテストしていたキースペースを再作成しようとすると、Hector は恐ろしい「すべてのホスト プールがマークダウンされました。再試行の負担がクライアントに押し出されました」と応答します。メッセージ、および Cassandra ログには次のスタック トレースがあります。

古いキースペースはまだデータディレクトリにあったので、移動しましたが、それは役に立ちませんでした。システム データにはまだ無効な参照がどこかにあるようです。これを修正する方法を知っている人はいますか？

編集: CLI から、「describe cluster;」「システム」キースペースのみを記述します。しかし、「システムを使用する」とき。次に、「schema_keyspacesをリストします。」以下が表示されます。

「mango」は​​アクセスできなくなったキースペースですが、まだある程度残っています。それを修正する方法はありますか？

完全なHadoop分散ファイルシステムをセットアップするのではなく、すでに使用しているため、cassandraにファイルを出し入れしたいと思います。完了時にコールバックを提供するアステュアナクスまたはヘクターの非同期プットはありますか？1000エントリを書き込むときに1000コールの1ミリ秒のネットワーク遅延を回避できます（いくつかの行と列に分割されてストリーミングされます）並行していくつかのサーバーに送信すると、ストリーミングが完了すると、すべての応答/コールバックが返されます）。Hectorまたはastyanaxはこれをサポートしていますか？

astyanaxはクエリコールバックをサポートしているようですので、主キーを使用してファイルをastyanaxでストリーミングできると思いますか？

ありがとう、ディーン

次のコードがあります。

それを使用していくつかの値を書き込むことができますが、cassandra を再起動すると失敗します。ログは次のとおりです。

TIOStreamTransport.write(TIOStreamTransport.java:145) ... 9 more [15:11:17] ERROR [HConnectionManager ] MARK HOST AS DOWN TRIGGERED for host >localhost(127.0.0.1):9160 [15:11:17] ERROR [HConnectionManager ] シャットダウン時のプールの状態: >:{localhost(127.0.0.1):9160}; IsActive?: 真; アクティブ: 1; ブロック: 0; アイドル: 15; NumBeforeExhausted: 49 [15:11:17] 情報 [ConcurrentHClientPool] シャットダウンがトリガーされました:{localhost(127.0.0.1):9160} [15:11:17] 情報 [ConcurrentHClientPool] シャットダウンが完了しました:{localhost(127.0.0.1) :9160} [15:11:17] INFO [CassandraHostRetryService] ダウンとして検出されたホストが再試行キューに追加されました: localhost(127.0.0.1):9160 [15:11:17] WARN [HConnectionManager] このホストで要求をフルフィルできませんでしたCassandraClient [15:11:17] WARN [HConnectionManager] 例外: 私。閉鎖。[15:11:17] INFO [HConnectionManager ] クライアント CassandraClient が非アクティブまたはデッド プールに解放されました。閉鎖。[15:11:17] 情報 [HConnectionManager] プールにホスト localhost(127.0.0.1):9160 を追加しました