使用Snowpark连接来自不同数据库的数据帧

Question

我试图连接来自雪花的不同数据库的两个表/数据帧，我试图使用snowpark而不是sql方式(即session.sql("((来实现这一点。

# Connecting to Database one
first_session = Session.builder.configs(connection_parameters).create()
# Connecting to Database Two
second_session = Session.builder.configs(connection_parameters).create()
table_one = first_session.table("table_one")
table_two = second_session.table("table_two")
result = table_two.join(
table_one,
(
(table_two.col_x == table_one.col_x)
),
)

Error that shows up when above code is run - 
Object 'table_one' does not exist or not authorized

Answer 1

最简单、最好的解决方案。为表提供完全限定的名称。DB_NAME.SCHEMA_NAME.TABLE_NAME

并确保您登录的用户可以访问这两个对象。

此外，如果两个数据库都在同一个SF帐户中，我认为没有必要创建两个不同的会话。