問題タブ [fluentcassandra]

現在、Windows Cassandraの展開を評価しており、非常に簡単なストレステストを作成することができました。このテストでは、さまざまなデータを含む100万行を単一のローカルノードに挿入しようとします（ローカルホストとの間、レプリケーションなし、クラスター上の1つのノードのみ）。

このテストは、最初の100k行で正常に機能します（つまり、まったく同じ行で常にブロックされるとは限りません）。挿入された行はデータベースから正しく読み取ることができ、すべてが正常に機能します。次に、テストはマシン上で使用可能なすべてのソケット/バッファ/一部のネットワークリソースを消費しているように見え、テストはCassandraへの接続に失敗し、行の挿入を停止します。ブラウザから完全に独立したWebページを更新しても、しばらくの間失敗します。

私は最初にテストを非難しましたが、それを強制終了して再起動しても機能しません。新しい接続が利用可能になるまで約1分待つ必要があります（タイムアウト？）。その後、テストを再開してデータをポンピングし続けることができます。Fluent CassandraクライアントとCassandra-Sharpクライアントの両方を使用してテストを作成し、同じ結果が得られました。

同時接続の最大数など、CassandraまたはC＃クライアントで設定する必要のある設定はありますか？

または、C＃から数百万行を挿入する作業ストレステストのソースへのリンクを誰かが持っているので、それを私のテストと比較して私の間違いを理解することができますか？

このアプリの出力は

FluentCassandra と C# 経由で Cassandra 1.2 にアクセスしています。DataStax インストール パッケージを使用しました。私が抱えている問題は、以下に示す範囲クエリを実行できないことです。

次のテーブル作成方法を試しました：

クエリは次のとおりです。

エラーは次のとおりです。

「Equal 演算子を使用した by-columns 句にインデックス付きの列が存在しません」/「PRIMARY KEY 部分 p2 を制限できません (前の部分 p1 は制限されていないか、非 EQ 関係によるものです)」

私の ConnectionBuilder:

どうすればいいですか？

次のスキーマを持つ複合列ファミリーがあります

これは、CQLから実行すると正常に機能します。

ただし、Ruby Clinetを使用して挿入しようとすると、これは失敗します。

エラーは次のとおりです。

私が間違っているのは何ですか？それともバグですか？

よろしく、マドゥ

次の CQL クエリが機能するように、Guid を UUID または同じ文字列バージョンに変換したいと考えています。

変数「orderGroupId」は Guid です。明らかに、これは C#/.NET 環境で FluentCassandra を使用しています。ヒントはありますか？

ありがとうございました。

こんにちは、FluentCassandra を初めて使用します。100 万個のデータを追加する際に「CassandraOperationException」というエラーが発生しました。「すべてのサーバーに障害が発生したため、接続できませんでした」と表示されます。この問題を解決する方法を教えてください。

これは、百万のデータを追加するための私のコードです

前もって感謝します！

私は Cassandra と FluentCassandra (C#.NET) も初めてです。私は、Microsoft SQL のような RDBMS (リレーショナル データベース) の重い概念を持っています。

うーん...単純なコードをいくつか実行できましたが、RDBMS で ADO.NET を使用するときに行うことにはほど遠いものです。

私がしたこと：

さて、キー「joao」を持つ行は CompositeColumn ですが、結果は foreach ステートメントでわかるように、列の線形シーケンスとして表示されました。

さて、これですべてがわかったので、私の疑問を明らかにすることができます。

次のようなフィルターを適用するにはどうすればよいですか:

FluentCassandra を使用してそれを行う方法がわかりません。.Get() メソッドを使用してそれを行うことはできますか? はいの場合、どのように？複合列があることを思い出してください。FluentCassandra で複合列を操作する方法もわかりません...

たとえば、ADO.NETを使用していた場合、次のようなことをするだけです:

この後、「ユーザー」DataSetオブジェクトにすべての情報がありました。

FluentCassandraを使用してCassandraデータベースで同じ操作を実行したいのですが、少し（まあ、かなり）迷っています。これを探すのに多くの時間を費やしましたが、成功しませんでした。ドキュメントと例は貧弱です...

誰か助けてください。

ありがとう。

さて、私はしました：

そして、私はリターンを持っていますが、返されるのはキー列だけで、他の列はそうではありません。

選択を行う他の方法を試しましたが、すべて同じ結果になりました。行のキーのみを持つ行だけです。

何か案が？

ありがとう。

Cassandra と FluentCassandra は初めてです。

実際の環境では、すべてのノード (複数のサーバー) に Cassandra をインストールします。

この状況では、サーバー名として何を言及する必要がありますか?

CQLを使用して新しい列を行に挿入する方法を知りたい...

出来ますか？そうでない場合、Fluent Cassandra を使用して簡単に行うにはどうすればよいですか?

ありがとう。