我是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–指定表名或完全限定对象标识符(数据库名、架构名和表名(的字符串或字符串列表。