写入MongoDB_MonogDB 中文网

MongoDB工具 >MongoDB Spark连接器 >Spark Connector Scala指南 > 写入MongoDB

将RDD数据保存到MongoDB时，该数据必须可转换为BSON文档。您可能需要包括 map转换将数据转换成一个Document（或 BsonDocument或DBObject）。

以下示例创建一个10文档的RDD并将其保存到在中指定的MongoDB集合中SparkConf：

import org.bson.Document

val documents = sc.parallelize((1 to 10).map(i => Document.parse(s"{test: $i}")))

MongoSpark.save(documents) // Uses the SparkConf for configuration

用一个 `WriteConfig`

MongoSpark.save()可以接受WriteConfig指定各种写配置设置（例如集合或写关注）的对象。

例如，以下代码将数据保存到spark集合中，并具有majority 写注意事项：

复制

import com.mongodb.spark.config._

val writeConfig = WriteConfig(Map("collection" -> "spark", "writeConcern.w" -> "majority"), Some(WriteConfig(sc)))
val sparkDocuments = sc.parallelize((1 to 10).map(i => Document.parse(s"{spark: $i}")))

MongoSpark.save(sparkDocuments, writeConfig)

RDD保存助手方法

RDD具有隐式的辅助方法saveToMongoDB()，可将数据写入MongoDB：

例如，以下代码使用documents上面定义的RDD并使用saveToMongoDB()不带任何参数的方法将文档保存到在中指定的集合中SparkConf：

复制

documents.saveToMongoDB() // Uses the SparkConf for configuration

调用saveToMongoDB()一个WriteConfig对象以指定其他MongoDB服务器地址，数据库和集合。请参阅写入配置设置以获取可用设置：

复制

documents.saveToMongoDB(WriteConfig(Map("uri" -> "mongodb://example.com/database.collection")))
// Uses the WriteConfig

不支持的类型

某些Scala类型（例如Lists）不受支持，应将其转换为Java等效。要从Scala转换成本机类型，请包含以下import语句以使用该.asJava 方法：

以下操作将导入.asJava方法，将Scala列表转换为其等效的Java，然后将其保存到MongoDB：

复制

import scala.collection.JavaConverters._
import org.bson.Document

val documents = sc.parallelize(
  Seq(new Document("fruits", List("apples", "oranges", "pears").asJava))
)
MongoSpark.save(documents)

MongoDB 工具

写入MongoDB

用一个 WriteConfig

RDD保存助手方法

不支持的类型

用一个 `WriteConfig`