我能連接到MongoDB使用org.mongodb.spark: mongo-spark-connector_2.12:3.0.2和這段代碼:
df = spark.read.format (“com.mongodb.spark.sql.DefaultSource”)。選項(“uri”, jdbcUrl)
它工作得很好,但如果我去年MongoDB火花連接器安裝版本10.0.5和我嚐試連接使用:
df = spark.read.format (mongodb) .option (“spark.mongodb.input.uri”, jdbcUrl)
在這種情況下MongoDB服務器返回連接超時。什麼好主意嗎?我需要使用10 x庫,因為他們允許結構化流從mongoDB。
嗨,最後我發現我自己的解決方案。選項的問題是,它改變了過去的版本。
工作代碼:
spark.read.format .option (“spark.mongodb.read.connection (“mongodb”)。uri”....
謝謝!