取消
顯示的結果
而不是尋找
你的意思是:

雪花連接磚錯誤

shivank25”id=
新的貢獻者二世

我試圖連接到雪花使用數據磚但得到以下錯誤

net.snowflake.client.jdbc。SnowflakeSQLException: JDBC驅動程序遇到了一個通信錯誤。HTTP請求的信息:遇到例外:連接到xxx.region.snowflakecomputing.com: 443 [XXX.region.snowflakecomputing.com/, XXX.region.snowflakecomputing.com/]失敗:讀取超時。

用戶= dbutils.secrets.get ( “數據倉庫工作” , “snowflake-user” )
密碼= dbutils.secrets.get ( “數據倉庫工作” , “snowflake-password” )
SNOWFLAKE_SOURCE_NAME = “net.snowflake.spark.snowflake”
選擇= {
“sfUrl” : “xxx.snowflakecomputing.com” ,
“sfUser” :用戶,
“sfPassword” :密碼,
“sfDatabase” : “數據庫” ,
“sfSchema” : “模式” ,
“sfWarehouse” : “wharehouse”
}

snowflake_df =火花。讀\
格式 (SNOWFLAKE_SOURCE_NAME) \
.options \(* *選項)
.option ( “數據表” , “表” )\
.load ()

顯示器(snowflake_df)
你能請讓我知道如果我遺漏了什麼東西?

3回複3

Priyanka_Biswas”id=
新的貢獻者三世”id=
新的貢獻者三世

你好@shivank25,磚的磚連接器提供了一個雪花從雪花運行時支持讀寫數據。

請嚐試以下代碼,讓我知道它是否適合你?

snowflake_table = (spark.read
.format(“雪花”)
table_name .option(“數據表”)
database_host_url .option (“sfUrl”)
.option (“sfUser”,用戶名)
.option (“sfPassword”,密碼)
database_name .option (“sfDatabase”)
.option (“sfSchema schema_name)
warehouse_name .option (“sfWarehouse”)
.load ()

#使用雪花連接器

df =火花。讀\
.format (“雪花”)\
.options \(選項)
.option(“數據表”,“table_name”) \
.load ()
顯示器(df)

裁判:https://docs.www.eheci.com/external-data/snowflake.html

shivank25”id=
新的貢獻者二世

謝謝你的響應@Priyanka_Biswas

我現在得到以下錯誤

net.snowflake.client.jdbc。SnowflakeSQLException: SQL編譯錯誤:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - Py4JJavaError回溯(最近調用最後)文件<命令- 4201251452332141>:1 - - - - - > 1snowflake_table=(火花2 格式( 雪花 )

Vidula_Khanna”id=
主持人”id=
主持人

@shivank25

謝謝你發布你的問題在我們的社區!我們很高興幫助你。

幫助我們為您提供最準確的信息,請您花一些時間來回顧反應和選擇一個最好的回答了你的問題嗎?

這也將有助於其他社區成員可能也有類似的問題在未來。謝謝你的參與,讓我們知道如果你需要任何進一步的援助!

歡迎來到磚社區:讓學習、網絡和一起慶祝

加入我們的快速增長的數據專業人員和專家的80 k +社區成員,準備發現,幫助和合作而做出有意義的聯係。

點擊在這裏注冊今天,加入!

參與令人興奮的技術討論,加入一個組與你的同事和滿足我們的成員。

Baidu
map