0

如何使用pyspark从databricks集群连接到mongodb Atlas

这是我在笔记本中的简单代码

from pyspark.sql import SparkSession
spark = SparkSession \
    .builder \
    .appName("myApp") \
    .config("spark.mongodb.input.uri", "mongodb+srv://admin:<password>@mongocluster.fxilr.mongodb.net/TestDatabase.Events") \
    .getOrCreate()

df = spark.read.format("mongo").load()
df.printSchema()

但我收到错误

IllegalArgumentException：缺少数据库名称。通过 'spark.mongodb.input.uri' 或 'spark.mongodb.input.database' 属性设置

我在做什么错

4

0 回答 0