将scala/spark信息写入MongoDB

import org.mongodb.scala._
import org.mongodb.scala.bson.collection.mutable.Document

val mongoClient: MongoClient = MongoClient()
val database: MongoDatabase = mongoClient.getDatabase("your_database_name")
val collection: MongoCollection[Document] = database.getCollection("your_collection_name")

case class Person(name: String, age: Int)
val person = Person("John Doe", 30)
val document = Document("name" -> person.name, "age" -> person.age)

val insertObservable: Observable[Completed] = collection.insertOne(document)
insertObservable.subscribe(new Observer[Completed] {
  override def onNext(result: Completed): Unit = println("Inserted")
  override def onError(e: Throwable): Unit = println("Failed")
  override def onComplete(): Unit = println("Completed")
})