Class: AWSCDK::AppFlow::CfnFlow::SnowflakeDestinationPropertiesProperty

Inherits:
Jsii::Struct
  • Object
show all
Defined in:
app_flow/cfn_flow.rb

Overview

The properties that are applied when Snowflake is being used as a destination.

Instance Attribute Summary collapse

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(intermediate_bucket_name:, object:, bucket_prefix: nil, error_handling_config: nil) ⇒ SnowflakeDestinationPropertiesProperty

Returns a new instance of SnowflakeDestinationPropertiesProperty.

Parameters:

  • intermediate_bucket_name (String)

    The intermediate bucket that Amazon AppFlow uses when moving data into Snowflake.

  • object (String)

    The object specified in the Snowflake flow destination.

  • bucket_prefix (String, nil) (defaults to: nil)

    The object key for the destination bucket in which Amazon AppFlow places the files.

  • error_handling_config (AWSCDK::IResolvable, AWSCDK::AppFlow::CfnFlow::ErrorHandlingConfigProperty, nil) (defaults to: nil)

    The settings that determine how Amazon AppFlow handles an error when placing data in the Snowflake destination.



2718
2719
2720
2721
2722
2723
2724
2725
2726
2727
# File 'app_flow/cfn_flow.rb', line 2718

def initialize(intermediate_bucket_name:, object:, bucket_prefix: nil, error_handling_config: nil)
  @intermediate_bucket_name = intermediate_bucket_name
  Jsii::Type.check_type(@intermediate_bucket_name, JSON.parse(Base64.strict_decode64("eyJwcmltaXRpdmUiOiJzdHJpbmcifQ==")), "intermediateBucketName")
  @object = object
  Jsii::Type.check_type(@object, JSON.parse(Base64.strict_decode64("eyJwcmltaXRpdmUiOiJzdHJpbmcifQ==")), "object")
  @bucket_prefix = bucket_prefix
  Jsii::Type.check_type(@bucket_prefix, JSON.parse(Base64.strict_decode64("eyJwcmltaXRpdmUiOiJzdHJpbmcifQ==")), "bucketPrefix") unless @bucket_prefix.nil?
  @error_handling_config = error_handling_config.is_a?(Hash) ? ::AWSCDK::AppFlow::CfnFlow::ErrorHandlingConfigProperty.new(**error_handling_config.transform_keys(&:to_sym)) : error_handling_config
  Jsii::Type.check_type(@error_handling_config, JSON.parse(Base64.strict_decode64("eyJ1bmlvbiI6eyJ0eXBlcyI6W3siZnFuIjoiYXdzLWNkay1saWIuSVJlc29sdmFibGUifSx7ImZxbiI6ImF3cy1jZGstbGliLmF3c19hcHBmbG93LkNmbkZsb3cuRXJyb3JIYW5kbGluZ0NvbmZpZ1Byb3BlcnR5In1dfX0=")), "errorHandlingConfig") unless @error_handling_config.nil?
end

Instance Attribute Details

#bucket_prefixString? (readonly)

The object key for the destination bucket in which Amazon AppFlow places the files.



2743
2744
2745
# File 'app_flow/cfn_flow.rb', line 2743

def bucket_prefix
  @bucket_prefix
end

#error_handling_configAWSCDK::IResolvable, ... (readonly)

The settings that determine how Amazon AppFlow handles an error when placing data in the Snowflake destination.

For example, this setting would determine if the flow should fail after one insertion error, or continue and attempt to insert every record regardless of the initial failure. ErrorHandlingConfig is a part of the destination connector details.



2750
2751
2752
# File 'app_flow/cfn_flow.rb', line 2750

def error_handling_config
  @error_handling_config
end

#intermediate_bucket_nameString (readonly)

The intermediate bucket that Amazon AppFlow uses when moving data into Snowflake.



2733
2734
2735
# File 'app_flow/cfn_flow.rb', line 2733

def intermediate_bucket_name
  @intermediate_bucket_name
end

#objectString (readonly)

The object specified in the Snowflake flow destination.



2738
2739
2740
# File 'app_flow/cfn_flow.rb', line 2738

def object
  @object
end

Class Method Details

.jsii_propertiesObject



2752
2753
2754
2755
2756
2757
2758
2759
# File 'app_flow/cfn_flow.rb', line 2752

def self.jsii_properties
  {
    :intermediate_bucket_name => "intermediateBucketName",
    :object => "object",
    :bucket_prefix => "bucketPrefix",
    :error_handling_config => "errorHandlingConfig",
  }
end

Instance Method Details

#to_jsiiObject



2761
2762
2763
2764
2765
2766
2767
2768
2769
2770
# File 'app_flow/cfn_flow.rb', line 2761

def to_jsii
  result = {}
  result.merge!({
    "intermediateBucketName" => @intermediate_bucket_name,
    "object" => @object,
    "bucketPrefix" => @bucket_prefix,
    "errorHandlingConfig" => @error_handling_config,
  })
  result.compact
end