SnowflakeDestConn

class

class SnowflakeDestConn(
    account: AccountSpec,
    credentials: CredentialsSpec,
    role: NameSpec | None = None,
    database: NameSpec | None = None,
    schema: NameSpec | None = None,
    warehouse: NameSpec | None = None,
    stage: IdentifierSpec | None = None,
    conn_cfg: CfgSpec | None = None,
)

Bases: Conn

Categories: destination

Snowflake account connection.

Registered on a collection; the runtime resolves it and hands it to the plugin at run time. Each string field accepts a plain string or a Secret. role / database / schema / warehouse follow the same Snowflake identifier rules as stage.

Parameters

parameter

accountAccountSpec (str | Secret)

A valid Snowflake account identifier / locator, e.g. ABCDEFG-XY12345 (alphanumerics with dots, hyphens and underscores; starts and ends alphanumeric).

parameter

credentialsCredentialsSpec (UserPassword)

UserPassword (user + password or PAT).

parameter

roleNameSpec | None (str | Secret | None)

Optional default role to USE before writing.

parameter

databaseNameSpec | None (str | Secret | None)

Optional default database. Required when schema is set.

parameter

schemaNameSpec | None (str | Secret | None)

Optional default schema. Requires database.

parameter

warehouseNameSpec | None (str | Secret | None)

Optional default warehouse; the plugin issues USE WAREHOUSE only when set.

parameter

stageIdentifierSpec | None (str | Secret | None)

Optional permanent stage for PUT + COPY INTO; when unset the plugin creates a session-scoped TEMPORARY stage. A Snowflake identifier -- unquoted, or double-quoted for case-sensitive / special-char names.

parameter

conn_cfgCfgSpec | None (dict | None)

Optional connector-config dict (see CfgSpec), forwarded to snowflake-connector-python.

Methods

method

validate

def validate()

Cross-field validation: schema requires database.

Called by the framework; raises SnowflakeValidateException.