問題タブ [mongodb-scala]

gridfs ファイルを作成する次のコードがあります。

コードは正常に動作しますが、同じ名前の 2 つのファイルを書き込むと、コレクション内のファイルが複製されます。ファイル名フィールドを使用して一意のインデックスを作成することを考えましたが、それでは最初のファイルが保持され、最新バージョンを保持する必要があります。どうすればいいですか？

ありがとう、

GA

Salat を使用した複合キーに関する投稿がありますが、 (mongo-db コンソールからdb.collection.ensureIndex({someField : 1})) インデックスを確保するための情報が不足しています。Salat のソースを調べたところ、フィールドにインデックスが必要であることを示す注釈がありませんでした。これを行う方法はありますか?

オブジェクトのリストを含む Web サービスを作成する必要があります。1 つのリストには、多くのタイプのオブジェクトを含めることができます。たとえば、ここにメディア アイテムのライブラリがあります。各アイテムは、リンクまたはビデオのいずれかであり、それぞれに独自のメタデータがあります。

WAR にコンパイルするものが必要で、以前に Lift を使用したことがあるからです。

この種のストレージに MongoDB を使用すると、定義上、異種アイテムのコレクションを処理できるはずなので、うまくいくと思いました。

Lift レコードに格納する BSON オブジェクトのタイプを定義することはできますが、1 つのレコード/コレクションに 1 つのタイプのオブジェクトのみを作成することに固執することはできないようです。理想的には、ライブラリ内の各「もの」(適切な言葉がないため) をビデオまたはリンクにしたいと考えています。例えば：

適切なタイプの継承でそれを実行できるはずですが、すべてのレコード オブジェクトの親がオブジェクトから継承する方法に戸惑います。これを機能させることはできますか？Lift がそのように使用できるさまざまなもののコレクションをお持ちですか?

これが私がこれまでに持っているものです。私はそれをテストしていませんが、それが機能したとしても、私が望むものではありません。

どうすればこれを入手できますか?

Play 2.1.5 で mongodb を使用して BSON リーダー/ライターを作成するのに苦労しています。

以下は app/model/Boat.scala のコードの抜粋です:

次に、 app/model/Accomodation.scala に次のものがあります。

これらのキーがmongodbレコードにない可能性があるため、一部のフィールドで「Option [String]」を使用しています。その場合、scala オブジェクトで空の値を返したいと思います。

これにより、コンパイル時に次のエラーが発生します。

多分誰かが私を正しい方向に向けるでしょう。

ありがとう！

私はMongoDBを使用するのにかなり慣れていません。

MongoDB コレクション内の特定のレコードの前のレコードを取得する必要があります。

1. 「_id = ObjectId(...)」フィールドでこれを行うことは可能ですか?
2. そうでない場合、指定されたレコードの前のレコードを識別するために、連続した値を持つキーを明示的に挿入する必要がありますか? (現在のコレクションにシーケンシャルなキーと値のペアがないと仮定します)

どんな助けでも大歓迎です。ありがとうございました。

Scala アプリケーションの mongoDB のメモリ内バージョンとしてscalatest-embedMongoを使用しています。現在、reactivemongo ドライバーをバージョン 0.10.x からバージョン 0.11.5 にアップグレードしました。scalatest-embedMongoは、以前のバージョンのリアクティブ mongo scala ドライバーでは正常に動作していましたが、リアクティブ mongo ドライバーのアップグレードされたバージョンでは、WriteResult Future は常に、reactiveMongo ドライバー API からソースされる ArrayIndexOutOfBounds を含む失敗を返します。私はこの新しい例外に困惑しています。

スタック トレース全体を次に示します。

前もって感謝します！！

コードを Casbah から mongodb-scala-driver に変換しています。クエリの結果をキャプチャする場合、これまでに思いついたのは次のとおりです。

私はちょうどその外観が好きではありません。どうすれば改善できますか？

Mongodb (1.1.1) 用の Scala ドライバーを使用して、一種の統合テストを作成しています。

future単純な挿入クエリがあり、またはobserver次の方法で管理できます。

および/またはでテストonErrorするにはどうすればよいですか? この状態を引き起こすにはどうすればよいですか?ObserverFailureFuture

現時点では、私は使用してMongodb Embedded (flapdoodle)います。

テストの開始時に Mongodb をシャットダウンすると、そのエラーに関連していないように見えるタイムアウトが発生します。

アップデート

WriteConcernコレクションに追加しました：

しかし、それは何も変わりません。

タイムアウト エラー (データベースまたはネットワークが何らかの理由でダウンした場合に発生) を含む、先物/オブザーバーによって返されるエラーはありますか?

mongo Spark コネクタを使用して、mongodb で「dense vector」と入力された列を使用してデータフレームを書き込もうとしています。

しかし、私はこのエラーを受け取ります:

[2.0,2.0,115.0,0.0,0.0,0.0,0.0,0.0] を BsonValue にキャストできません。org.apache.spark.ml.linalg.VectorUDT@3bfc3ba7 に一致する BsonValue がありません。

しかし、Array[Double] としてキャストされない理由については、https ://docs.mongodb.com/manual/reference/bson-types/ を参照してください。

私のデータフレームスキーマ: