用pandas.DataFrame编写snowflake.snowpark雪花

Question

我需要使用snowflake.snowpark编写雪花数据。我有一些pandas.DataFrame，有一些转换(corr矩阵，描述统计，模型输出，.)，但是我不能把它写回我的雪花数据库。谢谢你帮忙。

from snowflake.snowpark import Session
from snowflake.snowpark import table
from snowflake.snowpark.functions import udf
from snowflake.snowpark.functions import col
from snowflake.snowpark.types import StringType

sess = None

print('Connecting...')

cnn_params = {
"account": "eu-west-1",
"user": "user",
"password": 'pass',
"warehouse": "xs",
"database": "demodb",
"schema": "demosch",
"role": "ACCOUNTADMIN"
}

try:
    print('session...')
    import pandas as pd
    import numpy as np
    sess = Session.builder.configs(cnn_params).create()
    
    df = pd.DataFrame(np.random.randint(0,100,size=(100, 4)), columns=list('ABCD'))
    #print(df.describe())
    
    df.describe().write.mode("overwrite").save_as_table("describe_output", table_type="temporary")
    
except Exception as e:
    print(e)
finally:
    if sess:
        sess.close()
        print('connection closed...')
print('done.')

我的产出：

'DataFrame' object has no attribute 'write'
connection closed...

Answer 1

你已经创造了潘达斯的数据。您需要一个雪花数据，才能将其写回数据库。参见创建雪花数据雪花文档中的示例3

Answer 2

您可以使用session.write_pandas(df)将熊猫数据写入雪花表，也可以使用create_dataframe创建斯诺公园数据，然后使用.write.mode...创建