Prefect Collection for interacting with Snowflake in your flows: prefect-snowflake

[anna_geller]

Docs

https://prefecthq.github.io/prefect-snowflake/

Code

GitHub - PrefectHQ/prefect-snowflake: Prefect integrations for interacting...

Examples

from prefect import flow
from prefect_snowflake import SnowflakeCredentials
from prefect_snowflake.database import snowflake_query


@flow
def snowflake_query_flow():
    snowflake_credentials = SnowflakeCredentials(
        account="account",
        user="user",
        password="password",
    )
    result = snowflake_query(
        "SELECT * FROM table WHERE id=%{id_param}s LIMIT 8;",
        snowflake_credentials,
        params={"id_param": 1}
    )
    return result

snowflake_query_flow()