問題タブ [datastax]

毎日何百万ものレコードを Cassandra にロードし、データを検索可能にする必要があります。sstableloader を使用してレコードを Cassandra にロードすると、solr のインデックスが作成されますか? solr api がレコードをロードする唯一の方法ですか?

Datastax Cassandra C# ドライバーの timeuuid に相当する C# 型はどれですか?

私は単純なユーザー追跡サービスを作成しており、最新のユーザー履歴にアクセスしたいと考えています。この create ステートメントと同等のテーブルを作成しようとしています。

次のクラスを作成しました。

そして、このステートメントを使用して、Cassandra でテーブルを作成しています。

しかし、これにより次の表が得られます。

ご覧のとおり、 の型create_dateはtimestampではなく is ですtimeuuid。

Guidの代わりに試してみましたが、呼び出しDateTimeているuuidときに が表示されます.CreateIfNotExists()。

for のGuid代わりに使用し、未加工の CQL3 を使用して明示的にテーブルを作成する必要がありますか? これにより、Cassandraとの間で読み書きできるようになると思います( FluentCassandra プロジェクトで見つかったものを使用)。(リコール: Datastax ドライバーを使用しています)DateTimeCreateDatetimeuuidGuidGenerator

サービス提供に使用する DSE に書き込む、Pig を実行する EMR ジョブを作成しようとしています。残念ながら、Pig から DSE に書き込むことができないため、問題を分解して DSE ノードに接続し、それに書き込もうとしました。これが私がやっていることです

Cassandra ノード:

ローカル マシンから

これを行うと、次のエラーが発生します。

新しいdatastax 4.0でシングルノードクラスターを稼働させました。よく働く。ハイブを使用して、データを構築およびクエリします。サーバー上ではそれ自体。hive $>dse hive を開始して、テーブルを問題なくクエリできます。最新の Hive ODBC ドライバーを使用して同じクエリを実行しようとすると、このエラーが表示されます。それは問題なく接続します。キースペースを照会してテーブルを表示できます。しかし、クエリを実行しようとすると。map/red がキューに入っているように見えますが、次のエラーが発生します。

何を試すべきかについて何か考えはありますか？あなたが提供できる考えや提案/支援を前もって感謝します. 乾杯、エリック

DataStax から Pig の例を実行しています: http://www.datastax.com/docs/datastax_enterprise3.1/solutions/about_pig#pig-read-write。DataStax Enterprise 3.1.2 を使用しています。しかし、次のようにしてデータを Cassandra に保存したい場合:

次の出力が得られます。

ログファイルは次のとおりです。

私が間違っていることは何ですか？テーブルの作成中にCQLで整数の代わりに文字列を使用すると、例がうまく機能するため、私にとってはバグのように見えます。

ありがとうございました

DB 書き込みsession.executeAsync()の代わりに呼び出すことで、コードを高速化しようとしています。session.execute()

DB 接続がダウンしている可能性があるユースケースがあります。現在、execute()接続が失われた場合 (クラスター内で到達可能なホストがない場合) に、前の例では例外がスローされます。これらの例外をキャッチして、再試行するか、データを別の場所に保存することができます...

ではexecuteAsync()、このユースケースを満たす方法がないように見えます-返されたResultSetFutureオブジェクトにアクセスして結果を確認する必要があり、executeAsync()そもそも を使用する目的が無効になります...

DB 書き込みが失敗したことを他のコードに非同期的に通知する executeAsync() 呼び出しのどこかにリスナー (または類似のもの) を追加する方法はありますか?

これは適切ですか？データスタックス 1.0.2 Java 1.7.40

Cassandra Python ドライバーの問題は、返される「将来の」オブジェクトが副作用によってコールバックを追加することです。Futureつまり、 Javascript または Scalaの a が構成可能であるのと同じ意味で、「未来」は構成可能ではありません。構成不可能な未来を構成可能な未来に変換するために使用できるパターンがあるかどうか疑問に思っています（できればメモリリークなしで）。

Datastax の Cassandra Python ドライバーのパフォーマンスセクションを見ると、常に連鎖可能な一連の挿入クエリを作成している例が分かります。つまり、このパターンのもう少し複雑なバージョンです。

これはおもちゃの例としてうまく機能します。1 つのクエリが完了すると、別の同等のクエリが再度実行されます。このスキームにより、コールバックを「チェーン」しようとしないバージョンでは約 2k 書き込み/秒が制限されるのに対し、7k 書き込み/秒を達成できます。

私は、その正確なメカニズムを取り戻すことができる何らかのメカニズムを作成することに頭を悩ませようとしましたが、役に立ちませんでした. 誰かがそれのようなものを思いつきますか？

私はカサンドラが初めてです。DataStax Community Editionに記載されている手順に従って、DataStax Cassandra community edition を Windows 7 64 ビットにインストールしました。まったく同じ手順に従いましたが、何らかの理由で OpsCenter に接続できませんでした。次に、OpsCenter サービスを手動で開始しようとしました。次のエラーが表示されます。

Windows は、ローカル コンピューターで DataStax OpsCenter Community 2.0.6 を開始できませんでした。詳細については、システム イベント ログを確認してください。これが Microsoft 以外のサービスである場合は、サービス ベンダーに連絡し、サービス固有のエラー コードを参照してください。

どんな助けでも大歓迎です。

ありがとう

初期ログ

INFO [main] 2014-03-14 11:01:53,329 Jetty サーバーを起動中: {:port 61621, :host nil, :ssl? false, :結合? false} INFO [初期化] 2014-03-14 11:01:53,356 新しい JMX 接続 (127.0.0.1:7199) INFO [初期化] 2014-03-14 11:01:53,374 新しい JMX 接続 (127.0.0.1:7199) INFO [Jetty] 2014-03-14 11:01:53,393 Jetty server started ERROR [Initialization] 2014-03-14 11:01:53,416 Exception in thread "Initialization" ERROR [Initialization] 2014-03-14 11:01: 53,418 clojure.lang.ExceptionInfo: throw+: {:type :bad-permissions, :message "cassandra.yaml 構成ファイルが見つかりません。構成ファイルが Cassandra インストールで見つからない場合は、'conf_location' オプションを設定してくださいOpsCenter クラスタ構成ファイルの Cassandra セクションを削除し、opscenterd を再起動します。次のディレクトリを確認しました: [\"/etc/dse/cassandra/cassandra.yaml\" \"/etc/cassandra/conf/cassandra.yaml\" \"/etc/cassandra/cassandra.yaml\" \"C:\\Program Files\ \DataStax Community\\utils\\conf\\cassandra.yaml\"]"} {:object {:type :bad-permissions, :message "cassandra.yaml構成ファイルが見つかりません。構成ファイルが Cassandra インストールで見つからない場合は、OpsCenter クラスタ構成ファイルの Cassandra セクションで「conf_location」オプションを設定し、opscenterd を再起動してください。次のディレクトリを確認しました: [\"/etc/dse/cassandra/cassandra.yaml\" \"/etc/cassandra/conf/cassandra.yaml\" \"/etc/cassandra/cassandra.yaml\" \"C: \\Program Files\\DataStax Community\\utils\\conf\\cassandra.yaml\"]"}, :environment {tar-location "C:

cassandra.yaml ファイルをコピーして utils\conf に追加すると、ログ ファイルに次のエラーが記録されるようになりました

新しいログ

15,128 60 秒で再接続。ERROR [StompConnection レシーバー] 2014-03-17 12:12:16,130 127.0.0.1:61620:java.net.ConnectException への接続に失敗しました: 接続が拒否されました: 接続情報 [StompConnection レシーバー] 2014-03-17 12:12:16,130 再接続中60年代に。ERROR [StompConnection レシーバー] 2014-03-17 12:13:17,137 127.0.0.1:61620:java.net.ConnectException への接続に失敗しました: 接続が拒否されました: 接続情報 [StompConnection レシーバー] 2014-03-17 12:13:17,137 再接続中60年代に。ERROR [StompConnection 受信者] 2014-03-17 12:14:18,140 127.0.0.1:61620:java.net.ConnectException への接続に失敗しました: 接続が拒否されました: 接続情報 [StompConnection 受信者] 2014-03-17 12:14:18,140 再接続中60年代に。エラー [StompConnection レシーバー] 2014-03-17 12:15:19,152 127.0.0.1:61620 への接続に失敗しました:java.net.ConnectException: 接続が拒否されました: connect INFO [StompConnection receiver] 2014-03-17 12:15:19,152 60秒で再接続。ERROR [StompConnection 受信者] 2014-03-17 12:16:20,156 127.0.0.1:61620:java.net.ConnectException への接続に失敗しました: 接続が拒否されました: 接続情報 [StompConnection 受信者] 2014-03-17 12:16:20,156 再接続中60年代に。ERROR [StompConnection 受信者] 2014-03-17 12:17:21,159 127.0.0.1:61620:java.net.ConnectException への接続に失敗しました: 接続が拒否されました: 接続情報 [StompConnection 受信者] 2014-03-17 12:17:21,159 再接続中60年代に。ERROR [StompConnection レシーバー] 2014-03-17 12:18:22,162 127.0.0.1:61620:java.net.ConnectException への接続に失敗しました: 接続が拒否されました: 接続情報 [StompConnection レシーバー] 2014-03-17 12:18:22,162 再接続中60年代に。ERROR [StompConnection receiver] 2014-03-17 12:19:23,175 127.0 への接続に失敗しました。

datastax cassandra-driver(python)をインポートすると、次のエラーが発生します

エラー

これがコードです