如何使用雪花的雪地公园从一个数据库读取但写入另一个数据库?



我是Snowflake和Snowpark的新手,但我确实有令人尊敬的SQL和Python经验。我正在尝试使用Snowpark来进行数据准备,并最终将其用于数据科学模型。但是,我无法写入从中提取的数据库——我需要在第二个数据库中创建所有表。

我已经创建了代码块来表示输入和输出数据库在它们自己的会话中,但我不确定这是否有帮助,因为我必须在第一个会话中才能获得数据。

我在会话中使用类似于下面的代码来创建一个新表;输入";数据库:

my_table= session.table("<SCHEMA>.<TABLE_NAME>")
my_table.toPandas()
table_info = my_table.select(col("<col_name1>"),
col("<col_name2>"),
col("<col_name3>").alias("<new_name>"),
col("<col_name4"),
col("<col_name5")             
)

table_info.write.mode('overwrite').saveAsTable('MAINTABLE')

我需要将表MAINTABLE保存到一个辅助数据库中,该数据库与从中提取数据的数据库不同。我该怎么做?

可以提供完全限定的名称:

table_info.write.mode('overwrite').saveAsTable('DATABASE_NAME.SCHEMA_NAME.MAINTABLE')

DataFrameWriter.save_as_table

参数:

table_name–指定表名或完全限定对象标识符(数据库名、架构名和表名(的字符串或字符串列表。

相关内容

  • 没有找到相关文章

最新更新