Shane Kalepp
06/22/2023, 1:52 PMShane Kalepp
06/22/2023, 1:52 PMdef table(snowflake: SnowflakeResource) -> pd.DataFrame:
with snowflake.get_connection() as conn:
return (
conn.cursor()
.execute(
"SELECT * FROM OPEN_WEATHER"
)
.fetch_pandas_all()
)
defs = Definitions(
resources={
"snowflake": SnowflakeResource(
account=EnvVar("SNOWFLAKE_ACCOUNT"),
user=EnvVar("SNOWFLAKE_USER"),
password=EnvVar("SNOWFLAKE_PASSWORD"),
database="PROD",
schema="RAW",
)
},
)
Tim Castillo
06/22/2023, 4:22 PMShane Kalepp
06/22/2023, 6:01 PMTim Castillo
06/22/2023, 6:04 PM