DCP ベースのストリーミングが Spark Couchbase 公式コネクタで安定しているかどうかを知りたいですか? ドキュメントには、まだ本番環境で使用する準備ができていないと記載されています。Java の例はありますか?
また、私が解決しようとしているユースケースと、スパークコネクタがここで意味があるかどうかについて誰かが光を当てることができれば:
いくつかのバッジに関する更新情報は、couchbase lite db から同期ゲートウェイに毎日届きます。現在、10 日間のウィンドウで、誰かが 5 つ以上のバッジを獲得した場合、お祝いのバッジをプッシュする必要があります。これは、10 日ごとに行う必要があります。
そこで、私が計画していたのは、DCP を使用して、毎日変更を確認し、ジョブを実行してから同期ゲートウェイにプッシュすることでした。10 日以内に 5 つ以上のバッジを獲得した場合は、それを同期ゲートウェイにプッシュします。
これはこれを行う正しい方法ですか、それともこれを行うためのより良い方法はありますか?
使用できるもう1つのことは次のとおりです。
では、どのアプローチがここでより良いでしょうか?