`utils.rcclient.datasources.snowflake`

Module Contents

Classes

class utils.rcclient.datasources.snowflake.Snowflake(options)

Bases: utils.rcclient.datasources.conn.Conn

property connection

__connection

__client

chunk_size = 16384

get_client()

get_connection()

validate_builder_options()

validate_writer_options()

validate_source_options()

list_files(local_dir)

classmethod __fetch_pandas(cur, query)

get_tables()

get_data(query=None)

_get_data(query)

write_data(df, table_name, options)

build(entity_folder)

get_url()

classmethod map_and_cast_dtypes_to_sqlalchemy(df)

write(entity_input_file_path, entity_input_schema_path)