dlt.destinations.impl.snowflake.factory
snowflake Objects
class snowflake(Destination[SnowflakeClientConfiguration, "SnowflakeClient"])
__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,
use_decfloat: bool = False,
destination_name: str = None,
environment: str = None,
**kwargs: Any) -> None
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:
credentialsUnion[SnowflakeCredentials, Dict[str, Any], str], optional - Credentials to connect to the snowflake database. Can be an instance ofSnowflakeCredentialsor a connection string in the formatsnowflake://user:password@host:port/databasestage_nameOptional[str], optional - Name of an existing stage to use for loading data. Default uses implicit stage per tablekeep_staged_filesbool, optional - Whether to delete or keep staged files after loadingcsv_formatOptional[CsvFormatConfiguration] - Optional csv format configurationquery_tagOptional[str] - A tag with placeholders to tag sessions executing jobscreate_indexesbool, optional - Whether UNIQUE or PRIMARY KEY constrains should be createduse_decfloatbool, optional - Whether to use DECFLOAT type for unbound decimals. DECFLOAT stores exact decimal values with up to 36 significant digits and a dynamic exponent. Only works with text-based staging formats (jsonl, csv) - not parquet.destination_namestr, optional - Name of the destination. Defaults to None.environmentstr, optional - Environment name. Defaults to None.**kwargsAny, optional - Additional arguments forwarded to the destination config