python中的MongoSpark伴随对象[重复]

Question

在 Scala 应用程序中使用 Spark MongoDB 连接器时，您可以通过 import com.mongodb.spark.config._ 导入 MongoSpark 伴随对象，然后运行 val rdd = MongoSpark.load(spark) 加载您的收藏。我想在 python 应用程序中做同样的事情，但是我应该如何让 MongoSpark 对象在我的 python 应用程序中可用。没有要安装和导入的 python 包。什么是解决方法

Answer 1

请参阅Spark Connector Python Guide 了解更多信息。

下面是一个从 pySpark 连接到 MongoDB 的简短示例：

from pyspark.sql import SparkSession

spark = SparkSession \
    .builder \
    .appName("myApp") \
    .config("spark.mongodb.input.uri", "mongodb://127.0.0.1/test.coll") \
    .config("spark.mongodb.output.uri", "mongodb://127.0.0.1/test.coll") \
    .getOrCreate()

df = spark.read.format("com.mongodb.spark.sql.DefaultSource").load()
df.printSchema()