def connect_to_snowflake()

in customer-stack/create-resources.py [0:0]


def connect_to_snowflake(get_secret_value_response, snowflake_role_name):
    secret_string = get_secret_value_response['SecretString']

    secret = json.loads(secret_string)
    snowflake_account = secret['accountid']
    snowflake_password = secret['password']
    snowflake_userName = secret['username']

    # Connect to Snowflake
    logger.info("Connecting to Snowflake")
    snowflake_connection = snowflake.connector.connect(
        user=snowflake_userName,
        password=snowflake_password,
        account=snowflake_account,
        role=snowflake_role_name
    )

    return snowflake_connection