我在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()
请帮帮我!
暂无答案!
目前还没有任何答案,快来回答吧!