write_pandas 雪花连接器函数无法对表进行操作

如何解决write_pandas 雪花连接器函数无法对表进行操作

我正在编写一个 python 脚本，该脚本旨在处理一些数据，如果不存在则创建一个表，并在插入刷新的数据集之前截断该表。我使用的角色具有使用、读取、写入、创建表权限以及如下设置的暂存权限：

grant usage,read,write on future stages in schema <schema> to role <role>

我通过雪花连接器在 python 中使用 write_pandas 函数。文档说这个函数使用 PUT 和 Copy Into 命令：

To write the data to the table,the function saves the data to Parquet files,uses the PUT command to upload these files to a temporary stage,and uses the COPY INTO <table> command to copy the data from the files to the table. You can use some of the function parameters to control how the PUT and COPY INTO <table> statements are executed.

我仍然收到无法对架构进行操作的错误消息，我不确定还需要添加什么。有人拥有运行 write_pandas 命令所需的权限列表吗？

解决方法

Windows 10、Python 3.9.4、Snowflake-Connector-Python 2.4.2、Pandas 1.1.5

• 我对 write_pandas 函数有同样的问题。

• 我对 Snowflake 拥有 accountadmin 权限。下面附上 Python 代码和错误回溯。

• 但是，如果我要明确编写一个 CSV 文件，我可以使用两个函数从 CSV 文件上传数据：

1. “put file://”（进入雪花暂存）和
2. “复制到自”（雪花暂存）。

所以，它肯定是带有 write_pandas 函数的东西。

```import pandas as pd
```import snowflake.connector
```...
```from snowflake.connector.pandas_tools import write_pandas
```conn = snowflake.connector.connect(
```        user=strSnowflakeUserLogin,```        password=strSnowflakeUserPassword,```        account=strSnowflakeAccount,```        role=strSnowflakeUserRole,```        warehouse=strSnoflakeWarehouse,```        database=strSnowflakeDatabase,```        schema=strSnowflakeSchema
```        )

Traceback (most recent call last):
  File "myPython.py",line xxx,in <module> myPythonModule()
    write_pandas(conn,df,strSnowflakeTable)
  File "C:\Users\<username>\AppData\Local\Programs\Python\Python39\lib\site-packages\snowflake\connector\pandas_tools.py",line 197,in write_pandas
    copy_results = cursor.execute(copy_into_sql,_is_internal=True).fetchall()
  File "C:\Users\<username>\AppData\Local\Programs\Python\Python39\lib\site-packages\snowflake\connector\cursor.py",line 692,in execute
    Error.errorhandler_wrapper(
  File "C:\Users\<username>\AppData\Local\Programs\Python\Python39\lib\site-packages\snowflake\connector\errors.py",line 258,in errorhandler_wrapper
    cursor.errorhandler(connection,cursor,error_class,error_value)
  File "C:\Users\<username>\AppData\Local\Programs\Python\Python39\lib\site-packages\snowflake\connector\errors.py",line 188,in default_errorhandler
    raise error_class(
snowflake.connector.errors.ProgrammingError: 001757 (42601): SQL compilation error:
Table 'mySnowflakeTable' does not exist

```...
```write_pandas(conn,strSnowflakeTable)

,

write_pandas() 不会自动创建表。如果该表不存在，则需要自己创建该表。每次运行 write_pandas() 时，它只会将数据框附加到您指定的表中。

另一方面，如果您使用df.to_sql(...,method=pd_writer)将pandas dataframe写入snowflake，它会自动为您创建表，您可以在if_exists中使用to_sql()指定不同的行为 - 追加、替换或失败 - 如果表已存在。