問題
的雪花連接器的火花在Databricks中工作時,用於從雪花中讀取數據,並向雪花中寫入數據。連接器使Snowflake看起來像另一個Spark數據源。
當你試圖查詢雪花時,你會得到一個SnowflakeSQLException錯誤消息。
在net. snowflakeutil .client.jdbc. snowflakeutil . checkerrorandthrowexceptionsub (SnowflakeUtil.java:127): SQL訪問控製錯誤:權限不足操作模式'< schema >'
導致
當你試圖從雪花中讀寫數據(AWS|Azure|GCP)你用模式而不是sfschema.
%python snowflake_table = (spark.read .;
.format("snowflake") .option("dbtable",) .option("sfUrl", ) .option("sfUser", ) .option("sfPassword", ) .option("sfDatabase", ) .option("Schema", ) .option("sfWarehouse", ) .load())
雪花官方不支持模式作為一種選擇。
在某些情況下,模式被視為sfschema,但不能保證這種情況一定會發生。
解決方案
當從雪花中讀取或寫入數據時,必須使用sfschema而不是模式雪花選項。
%python snowflake_table = (spark.read .;.format("snowflake") .option("dbtable",) .option("sfUrl", ) .option("sfUser", ) .option("sfPassword", ) .option("sfDatabase", ) .option("sfSchema", ) .option("sfWarehouse", ) .load() )
請複習雪花使用Spark連接器文檔獲取更多信息。