雪花連接磚錯誤

[shivank25]

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

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)

你能請讓我知道如果我遺漏了什麼東西?

[Priyanka_Biswas]

你好@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]

謝謝你的響應@Priyanka_Biswas。

我現在得到以下錯誤

net.snowflake.client.jdbc。SnowflakeSQLException: SQL編譯錯誤:

- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - Py4JJavaError回溯(最近調用最後)文件<命令- 4201251452332141>:1 - - - - - > 1snowflake_table=(火花。讀2 。格式(” 雪花 ”)

[Vidula_Khanna]

嗨@shivank25

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

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

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