嗨@Jensen Ackles,
很明顯,你把錯誤的jdbc連接。日誌中我們仍然可以看到它。
試試這樣:
url = " jdbc: mysql / /some-instance.rds.amazonaws.com/ < database_name > "
這裏也是例子與司機選擇:
火花文檔:https://spark.apache.org/docs/latest/sql-data-sources-jdbc.html
順便說一下,祝賀你取得前5名的貢獻者在磚社區在這麼短的時間內。
謝謝,
帕特。
嗨@Jensen Ackles,
很明顯,你把錯誤的jdbc連接。日誌中我們仍然可以看到它。
試試這樣:
url = " jdbc: mysql / /some-instance.rds.amazonaws.com/ < database_name > "
這裏也是例子與司機選擇:
火花文檔:https://spark.apache.org/docs/latest/sql-data-sources-jdbc.html
順便說一下,祝賀你取得前5名的貢獻者在磚社區在這麼短的時間內。
謝謝,
帕特。
你好,
與JDBC URL看起來問題。當我試圖訪問SQL Azure數據庫。我也麵臨著同樣的問題。所以我創建了JDBC URL如下順利。
jdbc::狀態"置疑" / / < serverurl >: 1433;數據庫= <數據庫名>;用戶= <用戶名> @ < servername >;密碼= <密碼>;加密= true; trustServerCertificate = false; hostNameInCertificate = *。database.windows.net;loginTimeout = 30;
db_user = " XXXXXXX "
db_password = " XXXXXXX "
db_jdbc_url = " jdbc::狀態"置疑" / / < serverurl >: 1433;數據庫= <數據庫名>;用戶= < db_user > @ < servername >;密碼= < db_password >;加密= true; trustServerCertificate = false; hostNameInCertificate = *。database.windows.net”;loginTimeout = 30;
def datahub_db_config(查詢):
queryresult = (spark.read.format (jdbc)
.option (“url”, db_jdbc_url)
.option(“查詢”,查詢)。
db_user選項(“用戶”)
.option(“密碼”,db_password) .load ()
)
返回queryresult
查詢結果= datahub_db_config (=“select * from <表>”)
結果= datahub_db_config(查詢(查詢)