tabsdata.SnowflakeDestination

class SnowflakeDestination(

connection_parameters: dict,

destination_table: List[str] | str,

if_table_exists: Literal['append', 'replace'] = 'append',

stage: str | None = None,

**kwargs,

)

Bases: DestinationPlugin

Snowflake based data outputs.

__init__(

connection_parameters: dict,

destination_table: List[str] | str,

if_table_exists: Literal['append', 'replace'] = 'append',

stage: str | None = None,

**kwargs,

)

Initializes the SnowflakeDestination with the configuration desired to store the data.

Parameters:

• connection_parameters –

  Following values are to be defined in connection parameters.

  account: Snowflake account

  user: Snowflake user

  password: Snowflake user’s Personal Access Token (PAT). Password for programmatic access is not supported anymore.

  role: Snowflake role

  database: Snowflake database

  schema: Snowflake schema

  warehouse: Snowflake warehouse

• destination_table – Names of the destination tables to be created, replaced, or appended in Snowflake.

• if_table_exists – This is an optional property to define the strategy to follow when the table already exists. ‘replace’ will create overwrite the existing table, and ‘append’ will append to the existing data in the table. Defaults to ‘append’.

• stage – Snowflake stage name. If not provided, a temporary one will be created.

Methods

__init__(connection_parameters, ...[, ...])	Initializes the SnowflakeDestination with the configuration desired to store the data.
chunk(working_dir, *results)	Trigger the exporting of the data to local parquet chunks.
stream(working_dir, *results)	Trigger the exporting of the data.
write(files)	This method is used to write the files to the database.

Attributes

destination_table	Get the destination table(s) where the data will be stored.
if_table_exists	Returns the value of the if_table_exists property.