即使指定SSL選項,無法連接到MySQL。什麼可能出錯?有人能經曆類似的問題?
df_target_master = spark.read.format (jdbc) \
.option(“司機”,“com.mysql.jdbc.Driver”) \
.option (“url”, host_url) \
.option(“數據表”,supply_master) \
.option(“用戶”,user_id) \
.option(“密碼”,pwd) \
.option \ (“ssl”,真正的)
.option (“sslmode”、“verify-ca”) \
.option (“sslrootcert”、“< s3 bucket位置”)\
.load ()
嘿,
這裏的解決方案:ssl的正確選擇是“useSSL”而不僅僅是“ssl”。
下麵這段代碼可以工作原理:
df_target_master = spark.read.format (jdbc) \
.option(“司機”,“com.mysql.jdbc.Driver”) \
.option (“url”, host_url) \
.option(“數據表”,supply_master) \
.option(“用戶”,user_id) \
.option(“密碼”,pwd) \
.option (“useSSL”,真的)\
.option (“sslmode”、“verify-ca”) \
.option (“sslrootcert”、“< s3 bucket位置”)\
.load ()
我能訪問mySQL啟用了“執行SSL連接”在Azure隻有這種變化。
在磚上麵11.2運行時,您可以使用MySQL連接器在磚運行時。代碼可能是這樣的:
remote_table = (spark.read
.format (mysql)
.option(“數據表”,表)
.option(“主機”,database_host_url)
.option(“端口”,3306年)
database_name .option(“數據庫”)
uid .option(“用戶”)
.option(“密碼”,pwd)
.option (“useSSL”,真的)
.option (“sslmode”、“verify-ca”)
.load ()
)