Spong Streaming to MongoDB

Question

私はApache Spark Streamingを通じてApache Kafkaからデータにアクセスしていますので、データをMongoDBに保存したいのですが、どうすればmongoDBに保存できますか？

Answer 1

出力操作は非常に制限されていますが、このタイムフレームで処理されたRDDにアクセスできる場合はいつでもforeachRDD()を使用できます。したがって、任意のカスタムロジックをここに配置することができます。つまり、MongoDBへの接続で明示的な挿入/更新操作を簡単に実行できます。