Struct SnowflakeDestinationConfiguration 

#[non_exhaustive]
pub struct SnowflakeDestinationConfiguration {

    pub account_url: String,
    pub private_key: Option<String>,
    pub key_passphrase: Option<String>,
    pub user: Option<String>,
    pub database: String,
    pub schema: String,
    pub table: String,
    pub snowflake_role_configuration: Option<SnowflakeRoleConfiguration>,
    pub data_loading_option: Option<SnowflakeDataLoadingOption>,
    pub meta_data_column_name: Option<String>,
    pub content_column_name: Option<String>,
    pub snowflake_vpc_configuration: Option<SnowflakeVpcConfiguration>,
    pub cloud_watch_logging_options: Option<CloudWatchLoggingOptions>,
    pub processing_configuration: Option<ProcessingConfiguration>,
    pub role_arn: String,
    pub retry_options: Option<SnowflakeRetryOptions>,
    pub s3_backup_mode: Option<SnowflakeS3BackupMode>,
    pub s3_configuration: Option<S3DestinationConfiguration>,
    pub secrets_manager_configuration: Option<SecretsManagerConfiguration>,
    pub buffering_hints: Option<SnowflakeBufferingHints>,
}

Configure Snowflake destination

Fields (Non-exhaustive)

Non-exhaustive structs could have additional fields added in future. Therefore, non-exhaustive structs cannot be constructed in external crates using the traditional Struct { .. } syntax; cannot be matched against without a wildcard ..; and struct update syntax will not work.

account_url: String

URL for accessing your Snowflake account. This URL must include your account identifier. Note that the protocol (https://) and port number are optional.

private_key: Option<String>

The private key used to encrypt your Snowflake client. For information, see Using Key Pair Authentication & Key Rotation.

key_passphrase: Option<String>

Passphrase to decrypt the private key when the key is encrypted. For information, see Using Key Pair Authentication & Key Rotation.

user: Option<String>

User login name for the Snowflake account.

database: String

All data in Snowflake is maintained in databases.

schema: String

Each database consists of one or more schemas, which are logical groupings of database objects, such as tables and views

table: String

All data in Snowflake is stored in database tables, logically structured as collections of columns and rows.

snowflake_role_configuration: Option<SnowflakeRoleConfiguration>

Optionally configure a Snowflake role. Otherwise the default user role will be used.

data_loading_option: Option<SnowflakeDataLoadingOption>

Choose to load JSON keys mapped to table column names or choose to split the JSON payload where content is mapped to a record content column and source metadata is mapped to a record metadata column.

meta_data_column_name: Option<String>

Specify a column name in the table, where the metadata information has to be loaded. When you enable this field, you will see the following column in the snowflake table, which differs based on the source type.

For Direct PUT as source

{ "firehoseDeliveryStreamName" : "streamname", "IngestionTime" : "timestamp" }

For Kinesis Data Stream as source

"kinesisStreamName" : "streamname", "kinesisShardId" : "Id", "kinesisPartitionKey" : "key", "kinesisSequenceNumber" : "1234", "subsequenceNumber" : "2334", "IngestionTime" : "timestamp" }

content_column_name: Option<String>

The name of the record content column.

snowflake_vpc_configuration: Option<SnowflakeVpcConfiguration>

The VPCE ID for Firehose to privately connect with Snowflake. The ID format is com.amazonaws.vpce.\[region\].vpce-svc-<\[id\]>. For more information, see Amazon PrivateLink & Snowflake

cloud_watch_logging_options: Option<CloudWatchLoggingOptions>

Describes the Amazon CloudWatch logging options for your Firehose stream.

processing_configuration: Option<ProcessingConfiguration>

Describes a data processing configuration.

role_arn: String

The Amazon Resource Name (ARN) of the Snowflake role

retry_options: Option<SnowflakeRetryOptions>

The time period where Firehose will retry sending data to the chosen HTTP endpoint.

s3_backup_mode: Option<SnowflakeS3BackupMode>

Choose an S3 backup mode

s3_configuration: Option<S3DestinationConfiguration>

Describes the configuration of a destination in Amazon S3.

secrets_manager_configuration: Option<SecretsManagerConfiguration>

The configuration that defines how you access secrets for Snowflake.

buffering_hints: Option<SnowflakeBufferingHints>

Describes the buffering to perform before delivering data to the Snowflake destination. If you do not specify any value, Firehose uses the default values.

Implementations

impl SnowflakeDestinationConfiguration

pub fn account_url(&self) -> &str

URL for accessing your Snowflake account. This URL must include your account identifier. Note that the protocol (https://) and port number are optional.

pub fn private_key(&self) -> Option<&str>

The private key used to encrypt your Snowflake client. For information, see Using Key Pair Authentication & Key Rotation.

pub fn key_passphrase(&self) -> Option<&str>

Passphrase to decrypt the private key when the key is encrypted. For information, see Using Key Pair Authentication & Key Rotation.

pub fn user(&self) -> Option<&str>

User login name for the Snowflake account.

pub fn database(&self) -> &str

All data in Snowflake is maintained in databases.

pub fn schema(&self) -> &str

Each database consists of one or more schemas, which are logical groupings of database objects, such as tables and views

pub fn table(&self) -> &str

All data in Snowflake is stored in database tables, logically structured as collections of columns and rows.

pub fn snowflake_role_configuration( &self, ) -> Option<&SnowflakeRoleConfiguration>

Optionally configure a Snowflake role. Otherwise the default user role will be used.

pub fn data_loading_option(&self) -> Option<&SnowflakeDataLoadingOption>

Choose to load JSON keys mapped to table column names or choose to split the JSON payload where content is mapped to a record content column and source metadata is mapped to a record metadata column.

pub fn meta_data_column_name(&self) -> Option<&str>

Specify a column name in the table, where the metadata information has to be loaded. When you enable this field, you will see the following column in the snowflake table, which differs based on the source type.

For Direct PUT as source

{ "firehoseDeliveryStreamName" : "streamname", "IngestionTime" : "timestamp" }

For Kinesis Data Stream as source

"kinesisStreamName" : "streamname", "kinesisShardId" : "Id", "kinesisPartitionKey" : "key", "kinesisSequenceNumber" : "1234", "subsequenceNumber" : "2334", "IngestionTime" : "timestamp" }

pub fn content_column_name(&self) -> Option<&str>

The name of the record content column.

pub fn snowflake_vpc_configuration(&self) -> Option<&SnowflakeVpcConfiguration>

The VPCE ID for Firehose to privately connect with Snowflake. The ID format is com.amazonaws.vpce.\[region\].vpce-svc-<\[id\]>. For more information, see Amazon PrivateLink & Snowflake

pub fn cloud_watch_logging_options(&self) -> Option<&CloudWatchLoggingOptions>

Describes the Amazon CloudWatch logging options for your Firehose stream.

pub fn processing_configuration(&self) -> Option<&ProcessingConfiguration>

Describes a data processing configuration.

pub fn role_arn(&self) -> &str

The Amazon Resource Name (ARN) of the Snowflake role

pub fn retry_options(&self) -> Option<&SnowflakeRetryOptions>

The time period where Firehose will retry sending data to the chosen HTTP endpoint.

pub fn s3_backup_mode(&self) -> Option<&SnowflakeS3BackupMode>

Choose an S3 backup mode

pub fn s3_configuration(&self) -> Option<&S3DestinationConfiguration>

Describes the configuration of a destination in Amazon S3.

pub fn secrets_manager_configuration( &self, ) -> Option<&SecretsManagerConfiguration>

The configuration that defines how you access secrets for Snowflake.

pub fn buffering_hints(&self) -> Option<&SnowflakeBufferingHints>

Describes the buffering to perform before delivering data to the Snowflake destination. If you do not specify any value, Firehose uses the default values.

impl SnowflakeDestinationConfiguration

pub fn builder() -> SnowflakeDestinationConfigurationBuilder

Creates a new builder-style object to manufacture SnowflakeDestinationConfiguration.

Trait Implementations

impl Clone for SnowflakeDestinationConfiguration

fn clone(&self) -> SnowflakeDestinationConfiguration

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for SnowflakeDestinationConfiguration

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl PartialEq for SnowflakeDestinationConfiguration

fn eq(&self, other: &SnowflakeDestinationConfiguration) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for SnowflakeDestinationConfiguration