mongodb pyspark ec2授权问题

9o685dep  于 2021-05-24  发布在  Spark
关注(0)|答案(0)|浏览(205)

我在ec2示例中有mongodb,并尝试将其与pyspark连接,但它给出了错误:illegalargumentexception:requirement failed:无效uri。
这是我的密码:

from pyspark.sql import SparkSession
spark = SparkSession.builder.appName("myApp") \
.config("spark.mongodb.input.uri=mongodb://username:pass@ec2-0-00-00-000.compute-1.amazonaws.com:27017/xxx.coll")\
.config("spark.mongodb.output.uri=mongodb://username:pass@ec2-0-00-00-000.compute-1.amazonaws.com:27017/xxx.coll")\
.config('spark.jars.packages', 'org.mongodb.spark:mongo-spark-connector_2.12:3.0.0')\
.getOrCreate()

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

请帮帮我!

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题