Values.SnowflakeDestinationConfigurationSourceConfigure Snowflake destination
type nonrec t = {accountUrl : SnowflakeAccountUrl.t;URL for accessing your Snowflake account. This URL must include your account identifier. Note that the protocol (https://) and port number are optional.
*)privateKey : SnowflakePrivateKey.t option;The private key used to encrypt your Snowflake client. For information, see Using Key Pair Authentication & Key Rotation.
*)keyPassphrase : SnowflakeKeyPassphrase.t option;Passphrase to decrypt the private key when the key is encrypted. For information, see Using Key Pair Authentication & Key Rotation.
*)user : SnowflakeUser.t option;User login name for the Snowflake account.
*)database : SnowflakeDatabase.t;All data in Snowflake is maintained in databases.
*)schema : SnowflakeSchema.t;Each database consists of one or more schemas, which are logical groupings of database objects, such as tables and views
*)table : SnowflakeTable.t;All data in Snowflake is stored in database tables, logically structured as collections of columns and rows.
*)snowflakeRoleConfiguration : SnowflakeRoleConfiguration.t option;Optionally configure a Snowflake role. Otherwise the default user role will be used.
*)dataLoadingOption : SnowflakeDataLoadingOption.t option;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.
*)metaDataColumnName : SnowflakeMetaDataColumnName.t option;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" }
*)contentColumnName : SnowflakeContentColumnName.t option;The name of the record content column.
*)snowflakeVpcConfiguration : SnowflakeVpcConfiguration.t option;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
*)cloudWatchLoggingOptions : CloudWatchLoggingOptions.t option;processingConfiguration : ProcessingConfiguration.t option;roleARN : RoleARN.t;The Amazon Resource Name (ARN) of the Snowflake role
*)retryOptions : SnowflakeRetryOptions.t option;The time period where Firehose will retry sending data to the chosen HTTP endpoint.
*)s3BackupMode : SnowflakeS3BackupMode.t option;Choose an S3 backup mode
*)s3Configuration : S3DestinationConfiguration.t;secretsManagerConfiguration : SecretsManagerConfiguration.t option;The configuration that defines how you access secrets for Snowflake.
*)bufferingHints : SnowflakeBufferingHints.t option;Describes the buffering to perform before delivering data to the Snowflake destination. If you do not specify any value, Firehose uses the default values.
*)}val make :
?privateKey:??? ->
?keyPassphrase:??? ->
?user:??? ->
?snowflakeRoleConfiguration:??? ->
?dataLoadingOption:??? ->
?metaDataColumnName:??? ->
?contentColumnName:??? ->
?snowflakeVpcConfiguration:??? ->
?cloudWatchLoggingOptions:??? ->
?processingConfiguration:??? ->
?retryOptions:??? ->
?s3BackupMode:??? ->
?secretsManagerConfiguration:??? ->
?bufferingHints:??? ->
accountUrl:SnowflakeAccountUrl.t ->
database:SnowflakeDatabase.t ->
schema:SnowflakeSchema.t ->
table:SnowflakeTable.t ->
roleARN:RoleARN.t ->
s3Configuration:S3DestinationConfiguration.t ->
unit ->
tval to_value :
t ->
[> `Structure of
(string
* [> `Enum of string
| `String of SnowflakeAccountUrl.t
| `Structure of
(string
* [> `Boolean of BooleanObject.t
| `Enum of string
| `Integer of SnowflakeRetryDurationInSeconds.t
| `List of
[> `Structure of
(string
* [> `Enum of string
| `List of
[> `Structure of
(string
* [> `Enum of string
| `String of ProcessorParameterValue.t ])
list ]
list ])
list ]
list
| `String of SnowflakeRole.t
| `Structure of
(string
* [> `Boolean of BooleanObject.t
| `Enum of string
| `Integer of SizeInMBs.t
| `String of LogGroupName.t
| `Structure of
(string * [> `String of AWSKMSKeyARN.t ]) list ])
list ])
list ])
list ]