问题
的雪花连接器的火花是用来读取数据,写入数据,雪花在砖工作期间。连接器让雪花看起来像另一个火花数据源。
当你试图查询雪花,你得到一个SnowflakeSQLException错误消息。
SnowflakeSQLException: SQL错误:访问控制权限操作模式不足的<模式> 2权限操作模式不足的<模式>在net.snowflake.client.jdbc.SnowflakeUtil.checkErrorAndThrowExceptionSub (SnowflakeUtil.java: 127)
导致
当你试图从雪花读写数据(AWS|Azure|GCP你使用模式而不是sfschema。
% python snowflake_table = (spark.read
.format(“雪花”).option(“数据表”,< table_name >) .option (“sfUrl”, < database_host_url >) .option (“sfUser”, <用户名>).option (“sfPassword”, <密码>).option (“sfDatabase”, < database_name >) .option(“模式”,< schema_name >) .option (“sfWarehouse”, < warehouse_name >) .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() )
请检查雪花使用火花连接器文档的更多信息。