snowflake

snowflake

Snowflake stream configuration mappings.

SnowflakeFederated_StreamConfig dataclass

SnowflakeFederated_StreamConfig(
    data_provider_type: str = "snowflake-federated",
    parent: Any = None,
    raw: dict = dict(),
    source_name: str = None,
    source_type: str = None,
)

Bases: StreamConfig_Base

Snowflake federated stream configuration.

Used for federated Snowflake data sources.

SnowflakeInternalUnload_StreamConfig dataclass

SnowflakeInternalUnload_StreamConfig(
    data_provider_type: str = "snowflake-internal-unload",
    parent: Any = None,
    raw: dict = dict(),
    custom_query: str = None,
    database_name: str = None,
    schema_name: str = None,
    warehouse_name: str = None,
    query_tag: str = None,
    query_type: str = None,
    database_objects: str = None,
    view_name: str = None,
    cloud: str = None,
    bypass_data_upload: str = None,
    update_mode: str = None,
    partition_criteria: str = None,
    date_format: str = None,
)

Bases: StreamConfig_Base

Snowflake internal unload stream configuration.

Used for Snowflake managed unload operations with custom queries.

SnowflakeKeyPairAuth_StreamConfig dataclass

SnowflakeKeyPairAuth_StreamConfig(
    data_provider_type: str = "snowflakekeypairauthentication",
    parent: Any = None,
    raw: dict = dict(),
    query: str = None,
    database_name: str = None,
    schema_name: str = None,
    warehouse_name: str = None,
    report_type: str = None,
    query_tag: str = None,
    fetch_size: str = None,
    update_mode: str = None,
    convert_timezone: str = None,
    cloud: str = None,
)

Bases: StreamConfig_Base

Snowflake keypair authentication stream configuration.

Includes additional fields for keypair auth (query tags, fetch size, etc.).

Example

config = SnowflakeKeyPairAuth_StreamConfig.from_dict({ ... "query": "SELECT * FROM table", ... "databaseName": "SA_PRD", ... "queryTag": "domoD2C123", ... "fetchSize": "1000" ... }) config.query_tag "domoD2C123"

SnowflakeKeyPairUnloadV2_StreamConfig dataclass

SnowflakeKeyPairUnloadV2_StreamConfig(
    data_provider_type: str = "snowflake-key-pair-unload-v2",
    parent: Any = None,
    raw: dict = dict(),
    database_name: str = None,
    schema_name: str = None,
    warehouse_name: str = None,
    table_name: str = None,
    generated_query: str = None,
    column_names: str = None,
    query_type: str = None,
    database_objects: str = None,
    import_data_method: str = None,
    partition_criteria: str = None,
    partition_column_name: str = None,
    date_format: str = None,
    relative_days: str = None,
    upsert_key_columns: str = None,
    update_mode: str = None,
    bypass_data_upload: str = None,
    cloud: str = None,
)

Bases: StreamConfig_Base

Snowflake key pair unload v2 stream configuration.

Used for v2 keypair-authenticated unload operations.

SnowflakeKeyPairWriteback_StreamConfig dataclass

SnowflakeKeyPairWriteback_StreamConfig(
    data_provider_type: str = "snowflake-key-pair-writeback",
    parent: Any = None,
    raw: dict = dict(),
    database_name: str = None,
    schema_name: str = None,
    warehouse_name: str = None,
    queried_dataset_id: str = None,
    update_mode: str = None,
    update_table_options: str = None,
    escape_character: str = None,
    use_caps: str = None,
    validate_table_name: str = None,
    use_icebox: str = None,
    tablename_dropdown: str = None,
    cloud: str = None,
)

Bases: StreamConfig_Base

Snowflake key pair authentication writeback stream configuration.

Used for keypair-authenticated writes from Domo to Snowflake tables.

SnowflakeKeypairInternalManagedUnload_StreamConfig dataclass

SnowflakeKeypairInternalManagedUnload_StreamConfig(
    data_provider_type: str = "snowflake-keypair-internal-managed-unload",
    parent: Any = None,
    raw: dict = dict(),
    custom_query: str = None,
    database_name: str = None,
    schema_name: str = None,
    warehouse_name: str = None,
    query_tag: str = None,
    query_type: str = None,
    database_objects: str = None,
    cloud: str = None,
    bypass_data_upload: str = None,
    update_mode: str = None,
    partition_criteria: str = None,
    date_format: str = None,
    partition_column_dropdown_format: str = None,
    include_partition: str = None,
)

Bases: StreamConfig_Base

Snowflake keypair internal managed unload stream configuration.

Used for Snowflake keypair-authenticated managed unload operations.

SnowflakeKeypairInternalUnload_StreamConfig dataclass

SnowflakeKeypairInternalUnload_StreamConfig(
    data_provider_type: str = "snowflake-keypair-internal-unload",
    parent: Any = None,
    raw: dict = dict(),
    custom_query: str = None,
    database_name: str = None,
    schema_name: str = None,
    warehouse_name: str = None,
    query_tag: str = None,
    query_type: str = None,
    database_objects: str = None,
    cloud: str = None,
    bypass_data_upload: str = None,
    update_mode: str = None,
    partition_criteria: str = None,
    date_format: str = None,
    partition_column_dropdown_format: str = None,
    include_partition: str = None,
)

Bases: SnowflakeKeypairInternalManagedUnload_StreamConfig

Snowflake keypair internal unload stream configuration.

Alias for keypair internal managed unload with alternate provider key.

SnowflakeUnloadV2_StreamConfig dataclass

SnowflakeUnloadV2_StreamConfig(
    data_provider_type: str = "snowflake_unload_v2",
    parent: Any = None,
    raw: dict = dict(),
    database_name: str = None,
    schema_name: str = None,
    warehouse_name: str = None,
    table_name: str = None,
    generated_query: str = None,
    column_names: str = None,
    query_type: str = None,
    database_objects: str = None,
    import_data_method: str = None,
    partition_criteria: str = None,
    date_format: str = None,
    update_mode: str = None,
    bypass_data_upload: str = None,
)

Bases: StreamConfig_Base

Snowflake unload v2 stream configuration.

Used for v2 unload operations (both underscore and hyphen variants).

SnowflakeWriteback_StreamConfig dataclass

SnowflakeWriteback_StreamConfig(
    data_provider_type: str = "snowflake-writeback",
    parent: Any = None,
    raw: dict = dict(),
    table_name: str = None,
    database_name: str = None,
    schema_name: str = None,
    warehouse_name: str = None,
    queried_dataset_id: str = None,
    update_mode: str = None,
    update_table_options: str = None,
    escape_character: str = None,
    use_caps: str = None,
    validate_table_name: str = None,
    use_icebox: str = None,
    tablename_dropdown: str = None,
)

Bases: StreamConfig_Base

Snowflake writeback stream configuration.

Used for writing data from Domo back to Snowflake tables.

Snowflake_StreamConfig dataclass

Snowflake_StreamConfig(
    data_provider_type: str = "snowflake",
    parent: Any = None,
    raw: dict = dict(),
    query: str = None,
    database_name: str = None,
    warehouse_name: str = None,
    schema_name: str = None,
)

Bases: StreamConfig_Base

Snowflake stream configuration (typed, follows AccountConfig pattern).

Provides type-safe access to Snowflake stream parameters.

Example

config = Snowflake_StreamConfig.from_dict({ ... "query": "SELECT * FROM table", ... "databaseName": "SA_PRD", ... "warehouseName": "COMPUTE_WH" ... }) config.query # Type-safe attribute access "SELECT * FROM table" config.database_name "SA_PRD"