問題タブ [reactivemongo]

ReactiveMongo を使用する MongoDB 用の DAO アクターを作成しています。非常に単純な CRUD 操作をいくつか実装したいと考えています。その中には、一度に多くのレコードをアップサートする機能があります。私はリアクティブなアプリケーション (Akka 上に構築) を持っているので、冪等のアクションを持つことが重要なので、操作は挿入ではなくアップサートにする必要があります。

これまでのところ、次の（醜い）コードがあります。

reactmongo API だけを使用して、一度に多くのレコードをアップサートするすぐに使える方法はありますか?

私は MongoDB の初心者なので、これは多くの人にとって些細なことに聞こえるかもしれません。どんな助けでも大歓迎です！

MongoDB で地理空間クエリを実行するには、場所を含むドキュメント (2dまたは2dsphere地理空間インデックスを含む) は次のようになります。

私は Scala、ReactiveMongo、および Play Framework に非常に慣れていませんが、私の意見では、そのような場所を使用する明白な方法は、次のようなケース クラスを使用することです。

また、Web サイトの API が扱う JSON 表現は次のようになります。

今、ReactiveMongo モデルにこれらのフォーマット間でシリアル化/逆シリアル化するように指示する方法がわかりません。

私のコントローラーは次のようになります。

PointWriter と PointReader を使用しようとしました。これは私のmodels.scalaです：

コントローラー アクションを呼び出すとcreateCC、適切にフォーマットされた Point オブジェクトが新しく作成されたドキュメントになると予想されますが、実際に得られるのは次のようなものです。

したがって、そのようなオブジェクトをデータベースに書き込む方法を ReactiveMongoに使用PointWriterして指示しようとしても、まったく効果がありません。PointReaderPoint

私がしなければならないことを理解するのを手伝ってくれる人はいますか?

(私は PHP のバックグラウンドを持っており、Scala について理解を深めようとしています...)

更新: tmbo の回答のおかげで、このライターを思いつきました:

私たちのプロジェクトでは、Scala と Reactivemongo を使用しています。（私は両方とも非常に新しいです）「きれいな」Bsonをコンソールに出力すると、次のようになります。

コンソールから対応するケース クラスに解析できるようにする必要があります。

何か助けてください。

ReactiveMongo で Play フレームワークを使用しています。ReactiveMongo API のほとんどは Play に基づいていますEnumerator。MongoDB からデータを取得し、それを「そのまま」非同期で返す限り、すべて問題ありません。また、BSON を String に変換するなど、データの変換Enumerator.mapも明らかです。

しかし、今日、最終的に次のコードに絞り込まれる問題に直面しました。Enumerator指定された からアイテムを消費し、Enumeratorそれらの間にいくつかのアイテムを挿入するを作成しようとして、1日の半分を無駄にしました。一度にすべてのアイテムをロードしないことが重要です。多数のアイテムが存在する可能性があるためです (コード例には、「1」と「2」の 2 つのアイテムしかありません)。しかし、意味的にはmkStringコレクションに似ています。非常に簡単に実行できると確信していますが、私ができる最高のものはこのコードでした。Enumeratorusing を作成する非常によく似たコードConcurrent.broadcastは、WebSocket に役立ちます。しかし、ここでもそれは機能しません。HTTP 応答は返されません。を見るとEnumeratee、そのような機能を提供することになっているように見えますが、トリックを実行する方法が見つかりませんでした。

PS に電話をかけようとしchan.eofAndEndましたIteratee.mapDoneが、chunked(enums >>> Enumerator.eof代わりにchunked(enums)- は役に立ちませんでした。応答が返されることがありますが、正しいデータが含まれていません。何が恋しいですか？

以下は、以前の投稿で提示したケース クラスです ... ただし、cmbaxterによって提案された修正があります。

今、受信した Json を検証してデータベース (MongoDB) に保存する Play コントローラーを実装しようとしています。以下は私のコードです：

コンパイラが Json デシリアライザーを見つけられないため、上記のコードはコンパイルされません。

andを実装する代わりに、コンパニオン オブジェクトで定義したBSONDocumentWriterandを再利用することは可能でしょうか?BSONDocumentReaderUserReadsWrites

ReactiveMongo Scala ドライバーを使用して mongoDB に接続する Play アプリケーションをセットアップしようとしています。私はそれを機能させましたが、最終的には SSL サポートで構築された mongoDB に接続したいと考えています。ReactiveMongo は SSL 経由で mongoDB に接続する機能を提供しますか?

過去にSSLを使用してCasbahに接続できました

非同期ノンブロッキングの性質から ReactiveMongo を使用したいのですが、Casbah が唯一の選択肢である場合は、Casbah を使用できます。

これは、MongoDB との間で読み書きしたい単純な JSON です。

MongoDB に保存する前に、"ff59ab34cc59ff59ab34cc59"に変換し、名前を...ObjectIDにid変更する必要があります。_idReads

そしてもちろん、私には逆のことも必要です。Writesつまり、名前_idを に変更し、 を 形式のプレーン テキストにid変換します。ObjectID"ff59ab34cc59ff59ab34cc59"