問題タブ [spring-data-cassandra]

Spring Data Cassandra プロジェクト v1.3.0 を使用していますが、Cassandra クラスター (v2.0.17) の SSL を構成できません。Sprint Data Cassandra のドキュメントによると、DataStax Java Driver (2.0.X) を使用して Cassandra 2.X をサポートしているため、問題はないはずです。cassandra クラスター Bean を初期化する私の Java cassandra 構成は次のとおりです。

SSL コンテキストを設定するための環境プロパティが適切に入力されており、cassandra 構成ファイルで使用されているのと同じキーストアとトラストストアであることを確認しました。以下は、クライアントからノードへの暗号化を有効にすることに関する私の cassandra 構成です。

クライアント アプリケーションを起動すると、cassandra クラスターの初期化中に次のエラーが表示されます。

誰かがこれについて洞察を持っているなら、それは大歓迎です。Datastax でこれらの手順に従って、サーバー証明書を準備し、クライアントからノードへの暗号化を有効にしました。

次のように定義された Cassandra テーブルがあります。

そこにいくつかのデータを配置します：

私はそれとspring-data-cassandra対話するために使用しようとしています。私はPOJOを持っています:

そしてRepository：

次に、単純なテストとしてすべてのレコードを取得しようとする次のコード:

残念ながら、これは例外をスローします。よりファンキーでない列タイプは問題なく動作します。たとえば、List<String>ネストされていない `Map タイプの列は正常に動作します。しかし、この地図の地図は私にとってはうまくいきません。

これがサポートされていないのかspring-data-cassandra(例外は DataStax コードにあるようですが)、POJO で何か違うことをする必要があるだけなのか疑問に思っています。

スローされる例外は次のとおりです。

使用時

パッケージ内のどこにcom.fooを拡張するインターフェースがありますCrudRepository。

データベースがダウンしている場合に起動時に例外がスローされないようにする方法はありますか?

理想的には、起動してリポジトリでメソッドを呼び出すと、最初にデータベースへの接続が試行され、データベースがまだダウンしている場合は、接続できないというエラーが返されます。

私が現在観察している動作は、NoHostAvailableExceptionスローされ、Web コンテナーが起動しないことです。

以下のコードを使用して、春のデータを使用して cassandra に接続しています。しかし、毎回接続を作成するのは苦痛です。

一般的な静的接続またはユーティリティの種類のものを使用する方法はありますか? 多くのCRUD操作が行われるWebアプリケーションでこれを使用しています。そのため、どこでもコードを繰り返すのは面倒です。

複数の Cassandra クラスターがあります。各クラスターには、特定の一連の接点があります。各クラスターには、テーブル/CF の個別のセットがあります。

私の C* クライアントでは、両方のクラスターを照会することになっています。Cassandra の spring-boot バージョンを使用しています。CassandraOperations を使用してクエリを実行しようとしています。どうすればこれを行うことができますか？

上記は、sessionA を使用して cassandra 操作をセットアップする例ですが、sessionB についても同じことを行うのはどうですか?

任意の時間ベースでクエリを実行すると、sessionA または sessionB のいずれかに移動できます。

任意のポインタをいただければ幸いです

ありがとう

私はSpringが初めてなので、初歩的な質問をご容赦ください。CRUD操作を行うために、春ベースのカサンドラを使用しています。単純な挿入が機能していないようで、誰かが私が間違っていることを指摘できるかどうか疑問に思っていました. 以下は、単に挿入を行ったときに発生するエラーです

コードは次のとおりです。

セッションが有効であると仮定します。実際に書き込みを行うコードは次のとおりです

アドレスのオブジェクトは次のとおりです。

初期化に欠けているものはありますか？

CassandraReporitory の findOne() または findAll() メソッドを使用すると、次の例外が発生します。

私のクラス定義は次のとおりです。

基本的に、ここで起こっていることは、findOne() または findAll() の呼び出し中に Cassandra から行を読み取った後、Spring Data cassandra が ClassGeneratingEntityInstantiator を使用して、複合主キー オブジェクトを設定する方法がわからない ItemAndLocation オブジェクトをインスタンス化しようとすることです。 ItemAndLocationKey. カスタム オブジェクト インスタンス化子を提供する方法がわかりませんでした。現在のリリースの例やドキュメントはありません。

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

Spring Integration を使用して、次のワークフローを実現しようとしています。

• 1) ポーリング REST API
• 2) POJO を Cassandra クラスターに保存する

Spring Integration を試すのは初めてなので、参照からの情報の量にまだ少し圧倒されています。いくつかの調査の後、次の作業を行うことができました。

• 1) ポーリング REST API
• 2) マッピングされた POJO JSON の結果を文字列に変換する
• 3) 文字列をファイルに保存

コードは次のとおりです。

これはうまくいきます！

しかし今、オブジェクトをファイルに書き込む代わりに、spring-data-cassandra を使用して Cassandra クラスターに格納したいと考えています。そのために、構成ファイルのファイル ハンドラーをコメント アウトし、トランスフォーマーで POJO を返し、次を作成しました。

しかし、これは間違ったアプローチのようです。サービス メソッドは決してトリガーされません。

私の質問は、私のユースケースの正しいアプローチは何でしょうか? サービス コンポーネントに MessageHandler インターフェイスを実装し、設定で @ServiceActivator を使用する必要がありますか。または、現在の「ゲートウェイアプローチ」に何か欠けているものがありますか?? または、私が見ることができない別の解決策があるかもしれません..

前に述べたように、私は SI に慣れていないので、これはばかげた質問かもしれません...

それにもかかわらず、事前にどうもありがとう！