dlt.destinations.impl.snowflake.factory

snowflake Objects

class snowflake(Destination[SnowflakeClientConfiguration, "SnowflakeClient"])

View source on GitHub

__init__

def __init__(credentials: Union[SnowflakeCredentials, Dict[str, Any],
                                str] = None,
             stage_name: Optional[str] = None,
             keep_staged_files: bool = True,
             csv_format: Optional[CsvFormatConfiguration] = None,
             query_tag: Optional[str] = None,
             create_indexes: bool = False,
             destination_name: str = None,
             environment: str = None,
             **kwargs: Any) -> None

View source on GitHub

Configure the Snowflake destination to use in a pipeline.

All arguments provided here supersede other configuration sources such as environment variables and dlt config files.

Arguments:

• credentials Union[SnowflakeCredentials, Dict[str, Any], str], optional - Credentials to connect to the snowflake database. Can be an instance of SnowflakeCredentials or a connection string in the format snowflake://user:password@host:port/database
• stage_name Optional[str], optional - Name of an existing stage to use for loading data. Default uses implicit stage per table
• keep_staged_files bool, optional - Whether to delete or keep staged files after loading
• csv_format Optional[CsvFormatConfiguration] - Optional csv format configuration
• query_tag Optional[str] - A tag with placeholders to tag sessions executing jobs
• create_indexes bool, optional - Whether UNIQUE or PRIMARY KEY constrains should be created
• destination_name str, optional - Name of the destination. Defaults to None.
• environment str, optional - Environment name. Defaults to None.
• **kwargs Any, optional - Additional arguments forwarded to the destination config