diff --git a/.devcontainer/connections.toml b/.devcontainer/connections.toml index 0acd64c3..33718e62 100644 --- a/.devcontainer/connections.toml +++ b/.devcontainer/connections.toml @@ -1,7 +1,7 @@ # Can override the default connection name with an environment variable as follows #export SNOWFLAKE_DEFAULT_CONNECTION_NAME="default" -[default] +[connections.default] account = "myaccount" user = "myuser" password = "mypassword" diff --git a/.devcontainer/create_session.py b/.devcontainer/create_session.py new file mode 100644 index 00000000..463c8d10 --- /dev/null +++ b/.devcontainer/create_session.py @@ -0,0 +1,17 @@ +from snowflake.snowpark import Session + +connection_parameters = { + "account": "urxxlpr-dp02760", + "user": "zeal041", + "password": "Snowflake20021025", + "role": "HOL_ROLE", + "warehouse": "HOL_WH", + "database": "HOL_DB", + "schema": "ANALYTICS" +} + +session = Session.builder.configs(connection_parameters).create() +print("✅ セッション作成成功") + +df = session.sql("SELECT CURRENT_USER(), CURRENT_ROLE(), CURRENT_DATABASE(), CURRENT_SCHEMA()").collect() +print(df) diff --git a/steps/02_load_raw.py b/steps/02_load_raw.py index 025c3702..fd34f015 100644 --- a/steps/02_load_raw.py +++ b/steps/02_load_raw.py @@ -69,7 +69,28 @@ def validate_raw_tables(session): # For local debugging if __name__ == "__main__": - # Create a local Snowpark session - with Session.builder.getOrCreate() as session: - load_all_raw_tables(session) + from snowflake.snowpark import Session + + connection_parameters = { + "account": "urxxlpr-dp02760", + "user": "zeal041", + "password": "Snowflake20021025", + "role": "HOL_ROLE", + "warehouse": "HOL_WH", + "database": "HOL_DB", + "schema": "ANALYTICS" + } + + #session = Session.builder.configs(connection_parameters).create() + + +# 以降、session を使って処理 +#df = session.table("RAW_WEATHER_DATA") +#df.show() + +# 最後にセッションを閉じる(任意) +#session.close() + + # with Session.builder.getOrCreate() as session: + # load_all_raw_tables(session) # validate_raw_tables(session)