从雪花读取表格到数据块

Question

我已经看到了一些关于数据库到雪花的问题，但我的问题是如何将表格从雪花到数据库。

到目前为止我所做的：创建了一个集群并将集群附加到我的笔记本上（我正在使用Python）

# Use secrets DBUtil to get Snowflake credentials.
user = dbutils.secrets.get("snowflake-user", "secret-user")
password = dbutils.secrets.get("snowflake-pw", "secret-pw")
sf_url = dbutils.secrets.get("snowflake-url", "secret-sf-url")

# snowflake connection options
options = {
  "sfUrl": sf_url,
  "sfUser": user,
  "sfPassword": password,
  "sfDatabase": "DEV",
  "sfSchema": "PUBLIC",
  "sfWarehouse": "DEV_WH"
}

然后我试着用spark.read读取雪花中的FBK _视频表:

# Read table from Snowflake.
df = spark.read.format("snowflake").options(**options).option("dbtable", "FBK_VIDEOS").load()

我也尝试过：选项（“dbtable”，“从FBK_VIDEOS中选择*”）.load（）

但我看到df的以下错误：

net.snowflake.client.jdbc.SnowflakeSQLException：SQL编译错误：

追溯展开后显示了这一点:

Py4JJavaError                             Traceback (most recent call last)
<command-3339556253176158> in <module>
      1 # Read table from Snowflake.
----> 2 df = spark.read.format("snowflake").options(**options).option("dbtable", "FBK_VIDEOS").load()
      3 
      4 display(df)

/databricks/spark/python/pyspark/sql/readwriter.py in load(self, path, format, schema, **options)
    208             return self._df(self._jreader.load(self._spark._sc._jvm.PythonUtils.toSeq(path)))
    209         else:
--> 210             return self._df(self._jreader.load())
    211 
    212     def json(self, path, schema=None, primitivesAsString=None, prefersDecimal=None,

/databricks/spark/python/lib/py4j-0.10.9-src.zip/py4j/java_gateway.py in __call__(self, *args)
   1302 
   1303         answer = self.gateway_client.send_command(command)
-> 1304         return_value = get_return_value(
   1305             answer, self.gateway_client, self.target_id, self.name)

Answer 1

为完整性和将来可能遇到类似问题的用户提供答案。

正如评论中所回答的：Snowflake使用基于角色的访问控制系统，因此所使用的角色具有必要的权限至关重要。在这种情况下，代码中没有显示＜code＞USE ROLE＜/code＞，因此运行查询时处于活动状态的任何角色都没有足够的权限。