SnowparkSQLでJOINする際のデータフレーム名の指定方法が知りたい

Question

実現したいこと

SnowparkSQLでデータフレームに対してalias()を使用せずにJOINしたい。

前提

データフレームに対するalias()はコマンドリファレンスに記載もなく
実行しようとするとウォーニングが発生。

発生している問題・エラーメッセージ

WARNING：snowpark:DataFrame.alias() is experimental since 1.5.0 Do not use it n production.

該当のソースコード

from snowflake.snowpark import functions as F
from snowflake.snowpark.session import session

session.builder.configs(PARM).create()

temp_df1 = session.sql(f"SELECT * FROM tbl1")
temp_df2 = session.sql(f"SELECT * FROM tbl2")

#ここをalias()使用せずにデータフレーム名を指定したい
df1 = temp_df1.alias("tbl1")
df2 = temp_df2.alias("tbl2")

result_df = df1.JOIN(df2, df1.cola == df2.cola & df1.colb == df2.colb, how = "left).select(
F.col(df1.cola),
F.col'df1.colb),
F.col(colc)
)

### 試したこと

alias()を使用しない場合にカラム名がcola**df1**ではなく
**1_0000_**colaのようにカラム名の前に内部値のような数値が入る形になってしまう。
この数値は繰り返す都度、カウントアップされていく。
その為、データフレーム名の指定ができずにJOINができない・

Comments

[MasahikoHirata]

まず色々と目につく部分が。
大文字小文字の使い方とか’（’の閉じ忘れとか。

Answer 1

これで試してみてください。

from snowflake.snowpark import Session
import snowflake.snowpark.functions as F

# セッション作成（PARMは定義済みと想定）
session = Session.builder.configs(PARM).create()

# SQLで取得
df1 = session.sql("SELECT * FROM tbl1")
df2 = session.sql("SELECT * FROM tbl2")

# JOINの実行（カッコによる優先順位指定が必須）
# カラム指定にデータフレームオブジェクトそのものを使います
result_df = df1.join(
    df2, 
    on=[df1["cola"] == df2["cola"], df1["colb"] == df2["colb"]], 
    how="left"
)

# セレクト時のカラム指定
# df1["cola"] と書くことで、背後の「1_0000_」という別名をSnowparkが自動で解決します
final_df = result_df.select(
    df1["cola"],
    df1["colb"],
    F.col("colc") # df2にしかない、または名前が重複していないならこれでもOK
)