Class: AWSCDK::Lambda::EventSourceMappingProps

Inherits:
EventSourceMappingOptions
  • Object
show all
Defined in:
lambda/event_source_mapping_props.rb

Overview

Properties for declaring a new event source mapping.

Instance Attribute Summary collapse

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(batch_size: nil, bisect_batch_on_error: nil, enabled: nil, event_source_arn: nil, filter_encryption: nil, filters: nil, kafka_bootstrap_servers: nil, kafka_consumer_group_id: nil, kafka_topic: nil, log_level: nil, max_batching_window: nil, max_concurrency: nil, max_record_age: nil, metrics_config: nil, on_failure: nil, parallelization_factor: nil, provisioned_poller_config: nil, report_batch_item_failures: nil, retry_attempts: nil, schema_registry_config: nil, source_access_configurations: nil, starting_position: nil, starting_position_timestamp: nil, support_s3_on_failure_destination: nil, tumbling_window: nil, target:) ⇒ EventSourceMappingProps

Returns a new instance of EventSourceMappingProps.

Parameters:

  • batch_size (Numeric, nil) (defaults to: nil) —

    The largest number of records that AWS Lambda will retrieve from your event source at the time of invoking your function.

  • bisect_batch_on_error (Boolean, nil) (defaults to: nil) —

    If the function returns an error, split the batch in two and retry.

  • enabled (Boolean, nil) (defaults to: nil) —

    Set to false to disable the event source upon creation.

  • event_source_arn (String, nil) (defaults to: nil) —

    The Amazon Resource Name (ARN) of the event source.

  • filter_encryption (AWSCDK::KMS::IKey, nil) (defaults to: nil) —

    Add Customer managed KMS key to encrypt Filter Criteria.

  • filters (Array<Hash{String => Object}>, nil) (defaults to: nil) —

    Add filter criteria to Event Source.

  • kafka_bootstrap_servers (Array<String>, nil) (defaults to: nil) —

    A list of host and port pairs that are the addresses of the Kafka brokers in a self managed "bootstrap" Kafka cluster that a Kafka client connects to initially to bootstrap itself.

  • kafka_consumer_group_id (String, nil) (defaults to: nil) —

    The identifier for the Kafka consumer group to join.

  • kafka_topic (String, nil) (defaults to: nil) —

    The name of the Kafka topic.

  • log_level (AWSCDK::Lambda::EventSourceMappingLogLevel, nil) (defaults to: nil) —

    Configuration for logging verbosity from the event source mapping poller.

  • max_batching_window (AWSCDK::Duration, nil) (defaults to: nil) —

    The maximum amount of time to gather records before invoking the function.

  • max_concurrency (Numeric, nil) (defaults to: nil) —

    The maximum concurrency setting limits the number of concurrent instances of the function that an Amazon SQS event source can invoke.

  • max_record_age (AWSCDK::Duration, nil) (defaults to: nil) —

    The maximum age of a record that Lambda sends to a function for processing.

  • metrics_config (AWSCDK::Lambda::MetricsConfig, nil) (defaults to: nil) —

    Configuration for enhanced monitoring metrics collection When specified, enables collection of additional metrics for the stream event source.

  • on_failure (AWSCDK::Lambda::IEventSourceDlq, nil) (defaults to: nil) —

    An Amazon S3, Amazon SQS queue or Amazon SNS topic destination for discarded records.

  • parallelization_factor (Numeric, nil) (defaults to: nil) —

    The number of batches to process from each shard concurrently.

  • provisioned_poller_config (AWSCDK::Lambda::ProvisionedPollerConfig, nil) (defaults to: nil) —

    Configuration for provisioned pollers that read from the event source.

  • report_batch_item_failures (Boolean, nil) (defaults to: nil) —

    Allow functions to return partially successful responses for a batch of records.

  • retry_attempts (Numeric, nil) (defaults to: nil) —

    The maximum number of times to retry when the function returns an error.

  • schema_registry_config (AWSCDK::Lambda::ISchemaRegistry, nil) (defaults to: nil) —

    Specific configuration settings for a Kafka schema registry.

  • source_access_configurations (Array<AWSCDK::Lambda::SourceAccessConfiguration>, nil) (defaults to: nil) —

    Specific settings like the authentication protocol or the VPC components to secure access to your event source.

  • starting_position (AWSCDK::Lambda::StartingPosition, nil) (defaults to: nil) —

    The position in the DynamoDB, Kinesis or MSK stream where AWS Lambda should start reading.

  • starting_position_timestamp (Numeric, nil) (defaults to: nil) —

    The time from which to start reading, in Unix time seconds.

  • support_s3_on_failure_destination (Boolean, nil) (defaults to: nil) —

    Check if support S3 onfailure destination(OFD).

  • tumbling_window (AWSCDK::Duration, nil) (defaults to: nil) —

    The size of the tumbling windows to group records sent to DynamoDB or Kinesis.

  • target (AWSCDK::Lambda::IFunction) —

    The target AWS Lambda function.



33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
 
# File 'lambda/event_source_mapping_props.rb', line 33

def initialize(batch_size: nil, bisect_batch_on_error: nil, enabled: nil, event_source_arn: nil, filter_encryption: nil, filters: nil, kafka_bootstrap_servers: nil, kafka_consumer_group_id: nil, kafka_topic: nil, log_level: nil, max_batching_window: nil, max_concurrency: nil, max_record_age: nil, metrics_config: nil, on_failure: nil, parallelization_factor: nil, provisioned_poller_config: nil, report_batch_item_failures: nil, retry_attempts: nil, schema_registry_config: nil, source_access_configurations: nil, starting_position: nil, starting_position_timestamp: nil, support_s3_on_failure_destination: nil, tumbling_window: nil, target:)
  @batch_size = batch_size
  Jsii::Type.check_type(@batch_size, JSON.parse(Base64.strict_decode64("eyJwcmltaXRpdmUiOiJudW1iZXIifQ==")), "batchSize") unless @batch_size.nil?
  @bisect_batch_on_error = bisect_batch_on_error
  Jsii::Type.check_type(@bisect_batch_on_error, JSON.parse(Base64.strict_decode64("eyJwcmltaXRpdmUiOiJib29sZWFuIn0=")), "bisectBatchOnError") unless @bisect_batch_on_error.nil?
  @enabled = enabled
  Jsii::Type.check_type(@enabled, JSON.parse(Base64.strict_decode64("eyJwcmltaXRpdmUiOiJib29sZWFuIn0=")), "enabled") unless @enabled.nil?
  @event_source_arn = event_source_arn
  Jsii::Type.check_type(@event_source_arn, JSON.parse(Base64.strict_decode64("eyJwcmltaXRpdmUiOiJzdHJpbmcifQ==")), "eventSourceArn") unless @event_source_arn.nil?
  @filter_encryption = filter_encryption
  Jsii::Type.check_type(@filter_encryption, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3Nfa21zLklLZXkifQ==")), "filterEncryption") unless @filter_encryption.nil?
  @filters = filters
  Jsii::Type.check_type(@filters, JSON.parse(Base64.strict_decode64("eyJjb2xsZWN0aW9uIjp7ImVsZW1lbnR0eXBlIjp7ImNvbGxlY3Rpb24iOnsiZWxlbWVudHR5cGUiOnsicHJpbWl0aXZlIjoiYW55In0sImtpbmQiOiJtYXAifX0sImtpbmQiOiJhcnJheSJ9fQ==")), "filters") unless @filters.nil?
  @kafka_bootstrap_servers = kafka_bootstrap_servers
  Jsii::Type.check_type(@kafka_bootstrap_servers, JSON.parse(Base64.strict_decode64("eyJjb2xsZWN0aW9uIjp7ImVsZW1lbnR0eXBlIjp7InByaW1pdGl2ZSI6InN0cmluZyJ9LCJraW5kIjoiYXJyYXkifX0=")), "kafkaBootstrapServers") unless @kafka_bootstrap_servers.nil?
  @kafka_consumer_group_id = kafka_consumer_group_id
  Jsii::Type.check_type(@kafka_consumer_group_id, JSON.parse(Base64.strict_decode64("eyJwcmltaXRpdmUiOiJzdHJpbmcifQ==")), "kafkaConsumerGroupId") unless @kafka_consumer_group_id.nil?
  @kafka_topic = kafka_topic
  Jsii::Type.check_type(@kafka_topic, JSON.parse(Base64.strict_decode64("eyJwcmltaXRpdmUiOiJzdHJpbmcifQ==")), "kafkaTopic") unless @kafka_topic.nil?
  @log_level = log_level
  Jsii::Type.check_type(@log_level, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3NfbGFtYmRhLkV2ZW50U291cmNlTWFwcGluZ0xvZ0xldmVsIn0=")), "logLevel") unless @log_level.nil?
  @max_batching_window = max_batching_window
  Jsii::Type.check_type(@max_batching_window, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5EdXJhdGlvbiJ9")), "maxBatchingWindow") unless @max_batching_window.nil?
  @max_concurrency = max_concurrency
  Jsii::Type.check_type(@max_concurrency, JSON.parse(Base64.strict_decode64("eyJwcmltaXRpdmUiOiJudW1iZXIifQ==")), "maxConcurrency") unless @max_concurrency.nil?
  @max_record_age = max_record_age
  Jsii::Type.check_type(@max_record_age, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5EdXJhdGlvbiJ9")), "maxRecordAge") unless @max_record_age.nil?
  @metrics_config = metrics_config.is_a?(Hash) ? ::AWSCDK::Lambda::MetricsConfig.new(**metrics_config.transform_keys(&:to_sym)) : metrics_config
  Jsii::Type.check_type(@metrics_config, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3NfbGFtYmRhLk1ldHJpY3NDb25maWcifQ==")), "metricsConfig") unless @metrics_config.nil?
  @on_failure = on_failure
  Jsii::Type.check_type(@on_failure, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3NfbGFtYmRhLklFdmVudFNvdXJjZURscSJ9")), "onFailure") unless @on_failure.nil?
  @parallelization_factor = parallelization_factor
  Jsii::Type.check_type(@parallelization_factor, JSON.parse(Base64.strict_decode64("eyJwcmltaXRpdmUiOiJudW1iZXIifQ==")), "parallelizationFactor") unless @parallelization_factor.nil?
  @provisioned_poller_config = provisioned_poller_config.is_a?(Hash) ? ::AWSCDK::Lambda::ProvisionedPollerConfig.new(**provisioned_poller_config.transform_keys(&:to_sym)) : provisioned_poller_config
  Jsii::Type.check_type(@provisioned_poller_config, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3NfbGFtYmRhLlByb3Zpc2lvbmVkUG9sbGVyQ29uZmlnIn0=")), "provisionedPollerConfig") unless @provisioned_poller_config.nil?
  @report_batch_item_failures = report_batch_item_failures
  Jsii::Type.check_type(@report_batch_item_failures, JSON.parse(Base64.strict_decode64("eyJwcmltaXRpdmUiOiJib29sZWFuIn0=")), "reportBatchItemFailures") unless @report_batch_item_failures.nil?
  @retry_attempts = retry_attempts
  Jsii::Type.check_type(@retry_attempts, JSON.parse(Base64.strict_decode64("eyJwcmltaXRpdmUiOiJudW1iZXIifQ==")), "retryAttempts") unless @retry_attempts.nil?
  @schema_registry_config = schema_registry_config
  Jsii::Type.check_type(@schema_registry_config, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3NfbGFtYmRhLklTY2hlbWFSZWdpc3RyeSJ9")), "schemaRegistryConfig") unless @schema_registry_config.nil?
  @source_access_configurations = source_access_configurations.is_a?(Array) ? source_access_configurations.map { |jsii_v0| jsii_v0.is_a?(Hash) ? ::AWSCDK::Lambda::SourceAccessConfiguration.new(**jsii_v0.transform_keys(&:to_sym)) : jsii_v0 } : source_access_configurations
  Jsii::Type.check_type(@source_access_configurations, JSON.parse(Base64.strict_decode64("eyJjb2xsZWN0aW9uIjp7ImVsZW1lbnR0eXBlIjp7ImZxbiI6ImF3cy1jZGstbGliLmF3c19sYW1iZGEuU291cmNlQWNjZXNzQ29uZmlndXJhdGlvbiJ9LCJraW5kIjoiYXJyYXkifX0=")), "sourceAccessConfigurations") unless @source_access_configurations.nil?
  @starting_position = starting_position
  Jsii::Type.check_type(@starting_position, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3NfbGFtYmRhLlN0YXJ0aW5nUG9zaXRpb24ifQ==")), "startingPosition") unless @starting_position.nil?
  @starting_position_timestamp = starting_position_timestamp
  Jsii::Type.check_type(@starting_position_timestamp, JSON.parse(Base64.strict_decode64("eyJwcmltaXRpdmUiOiJudW1iZXIifQ==")), "startingPositionTimestamp") unless @starting_position_timestamp.nil?
  @support_s3_on_failure_destination = support_s3_on_failure_destination
  Jsii::Type.check_type(@support_s3_on_failure_destination, JSON.parse(Base64.strict_decode64("eyJwcmltaXRpdmUiOiJib29sZWFuIn0=")), "supportS3OnFailureDestination") unless @support_s3_on_failure_destination.nil?
  @tumbling_window = tumbling_window
  Jsii::Type.check_type(@tumbling_window, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5EdXJhdGlvbiJ9")), "tumblingWindow") unless @tumbling_window.nil?
  @target = target
  Jsii::Type.check_type(@target, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3NfbGFtYmRhLklGdW5jdGlvbiJ9")), "target")
end

Instance Attribute Details

#batch_size ⇒ Numeric? (readonly)

Note:

Default: - Amazon Kinesis, Amazon DynamoDB, and Amazon MSK is 100 records. The default for Amazon SQS is 10 messages. For standard SQS queues, the maximum is 10,000. For FIFO SQS queues, the maximum is 10.

The largest number of records that AWS Lambda will retrieve from your event source at the time of invoking your function.

Your function receives an event with all the retrieved records.

Valid Range: Minimum value of 1. Maximum value of 10000.

Returns:

  • (Numeric, nil) 


97
98
99
 
# File 'lambda/event_source_mapping_props.rb', line 97

def batch_size
  @batch_size
end

#bisect_batch_on_error ⇒ Boolean? (readonly)

Note:

Default: false

If the function returns an error, split the batch in two and retry.

Returns:

  • (Boolean, nil) 


102
103
104
 
# File 'lambda/event_source_mapping_props.rb', line 102

def bisect_batch_on_error
  @bisect_batch_on_error
end

#enabled ⇒ Boolean? (readonly)

Note:

Default: true

Set to false to disable the event source upon creation.

Returns:

  • (Boolean, nil) 


107
108
109
 
# File 'lambda/event_source_mapping_props.rb', line 107

def enabled
  @enabled
end

#event_source_arn ⇒ String? (readonly)

Note:

Default: - not set if using a self managed Kafka cluster, throws an error otherwise

The Amazon Resource Name (ARN) of the event source.

Any record added to this stream can invoke the Lambda function.

Returns:

  • (String, nil) 


115
116
117
 
# File 'lambda/event_source_mapping_props.rb', line 115

def event_source_arn
  @event_source_arn
end

#filter_encryption ⇒ AWSCDK::KMS::IKey? (readonly)

Note:

Default: - none

Add Customer managed KMS key to encrypt Filter Criteria.

Returns:

See Also:



121
122
123
 
# File 'lambda/event_source_mapping_props.rb', line 121

def filter_encryption
  @filter_encryption
end

#filters ⇒ Array<Hash{String => Object}>? (readonly)

Note:

Default: - none

Add filter criteria to Event Source.

Returns:

  • (Array<Hash{String => Object}>, nil)

See Also:



127
128
129
 
# File 'lambda/event_source_mapping_props.rb', line 127

def filters
  @filters
end

#kafka_bootstrap_servers ⇒ Array<String>? (readonly)

Note:

Default: - none

A list of host and port pairs that are the addresses of the Kafka brokers in a self managed "bootstrap" Kafka cluster that a Kafka client connects to initially to bootstrap itself.

They are in the format abc.example.com:9096.

Returns:

  • (Array<String>, nil) 


134
135
136
 
# File 'lambda/event_source_mapping_props.rb', line 134

def kafka_bootstrap_servers
  @kafka_bootstrap_servers
end

#kafka_consumer_group_id ⇒ String? (readonly)

Note:

Default: - none

The identifier for the Kafka consumer group to join.

The consumer group ID must be unique among all your Kafka event sources. After creating a Kafka event source mapping with the consumer group ID specified, you cannot update this value. The value must have a length between 1 and 200 and full the pattern '[a-zA-Z0-9-/:_+=.@-]'. For more information, see Customizable consumer group ID.

Returns:

  • (String, nil)

See Also:



142
143
144
 
# File 'lambda/event_source_mapping_props.rb', line 142

def kafka_consumer_group_id
  @kafka_consumer_group_id
end

#kafka_topic ⇒ String? (readonly)

Note:

Default: - no topic

The name of the Kafka topic.

Returns:

  • (String, nil) 


147
148
149
 
# File 'lambda/event_source_mapping_props.rb', line 147

def kafka_topic
  @kafka_topic
end

#log_level ⇒ AWSCDK::Lambda::EventSourceMappingLogLevel? (readonly)

Note:

Default: - No logging

Configuration for logging verbosity from the event source mapping poller.

This configuration controls the verbosity of the logs generated by the polling infrastructure that reads events from the event source. The logs provide insights into the internal operations of the event source mapping, including connection status, polling behavior, and error conditions.

Returns:



156
157
158
 
# File 'lambda/event_source_mapping_props.rb', line 156

def log_level
  @log_level
end

#max_batching_window ⇒ AWSCDK::Duration? (readonly)

Note:

Default: Duration.seconds(0)

The maximum amount of time to gather records before invoking the function.

Maximum of Duration.minutes(5)

Returns:



163
164
165
 
# File 'lambda/event_source_mapping_props.rb', line 163

def max_batching_window
  @max_batching_window
end

#max_concurrency ⇒ Numeric? (readonly)

Note:

Default: - No specific limit.

The maximum concurrency setting limits the number of concurrent instances of the function that an Amazon SQS event source can invoke.

Returns:

  • (Numeric, nil)

See Also:



169
170
171
 
# File 'lambda/event_source_mapping_props.rb', line 169

def max_concurrency
  @max_concurrency
end

#max_record_age ⇒ AWSCDK::Duration? (readonly)

Note:

Default: - infinite or until the record expires.

The maximum age of a record that Lambda sends to a function for processing.

Valid Range:

  • Minimum value of 60 seconds
  • Maximum value of 7 days

Returns:



179
180
181
 
# File 'lambda/event_source_mapping_props.rb', line 179

def max_record_age
  @max_record_age
end

#metrics_config ⇒ AWSCDK::Lambda::MetricsConfig? (readonly)

Note:

Default: - Enhanced monitoring is disabled

Configuration for enhanced monitoring metrics collection When specified, enables collection of additional metrics for the stream event source.

Returns:



184
185
186
 
# File 'lambda/event_source_mapping_props.rb', line 184

def metrics_config
  @metrics_config
end

#on_failure ⇒ AWSCDK::Lambda::IEventSourceDlq? (readonly)

Note:

Default: discarded records are ignored

An Amazon S3, Amazon SQS queue or Amazon SNS topic destination for discarded records.

Returns:



189
190
191
 
# File 'lambda/event_source_mapping_props.rb', line 189

def on_failure
  @on_failure
end

#parallelization_factor ⇒ Numeric? (readonly)

Note:

Default: 1

The number of batches to process from each shard concurrently.

Valid Range:

  • Minimum value of 1
  • Maximum value of 10

Returns:

  • (Numeric, nil) 


199
200
201
 
# File 'lambda/event_source_mapping_props.rb', line 199

def parallelization_factor
  @parallelization_factor
end

#provisioned_poller_config ⇒ AWSCDK::Lambda::ProvisionedPollerConfig? (readonly)

Note:

Default: - no provisioned pollers

Configuration for provisioned pollers that read from the event source.

When specified, allows control over the minimum and maximum number of pollers that can be provisioned to process events from the source.

Returns:



207
208
209
 
# File 'lambda/event_source_mapping_props.rb', line 207

def provisioned_poller_config
  @provisioned_poller_config
end

#report_batch_item_failures ⇒ Boolean? (readonly)

Note:

Default: false

Allow functions to return partially successful responses for a batch of records.

Returns:

  • (Boolean, nil)

See Also:



213
214
215
 
# File 'lambda/event_source_mapping_props.rb', line 213

def report_batch_item_failures
  @report_batch_item_failures
end

#retry_attempts ⇒ Numeric? (readonly)

Note:

Default: - infinite or until the record expires.

The maximum number of times to retry when the function returns an error.

Set to undefined if you want lambda to keep retrying infinitely or until the record expires.

Valid Range:

  • Minimum value of 0
  • Maximum value of 10000

Returns:

  • (Numeric, nil) 


226
227
228
 
# File 'lambda/event_source_mapping_props.rb', line 226

def retry_attempts
  @retry_attempts
end

#schema_registry_config ⇒ AWSCDK::Lambda::ISchemaRegistry? (readonly)

Note:

Default: - none

Specific configuration settings for a Kafka schema registry.

Returns:



231
232
233
 
# File 'lambda/event_source_mapping_props.rb', line 231

def schema_registry_config
  @schema_registry_config
end

#source_access_configurations ⇒ Array<AWSCDK::Lambda::SourceAccessConfiguration>? (readonly)

Note:

Default: - none

Specific settings like the authentication protocol or the VPC components to secure access to your event source.

Returns:

See Also:



237
238
239
 
# File 'lambda/event_source_mapping_props.rb', line 237

def source_access_configurations
  @source_access_configurations
end

#starting_position ⇒ AWSCDK::Lambda::StartingPosition? (readonly)

Note:

Default: - no starting position

The position in the DynamoDB, Kinesis or MSK stream where AWS Lambda should start reading.

Returns:

See Also:



243
244
245
 
# File 'lambda/event_source_mapping_props.rb', line 243

def starting_position
  @starting_position
end

#starting_position_timestamp ⇒ Numeric? (readonly)

Note:

Default: - no timestamp

The time from which to start reading, in Unix time seconds.

Returns:

  • (Numeric, nil) 


248
249
250
 
# File 'lambda/event_source_mapping_props.rb', line 248

def starting_position_timestamp
  @starting_position_timestamp
end

#support_s3_on_failure_destination ⇒ Boolean? (readonly)

Note:

Default: false

Check if support S3 onfailure destination(OFD).

Kinesis, DynamoDB, MSK and self managed kafka event support S3 OFD

Returns:

  • (Boolean, nil) 


255
256
257
 
# File 'lambda/event_source_mapping_props.rb', line 255

def support_s3_on_failure_destination
  @support_s3_on_failure_destination
end

#target ⇒ AWSCDK::Lambda::IFunction (readonly)

The target AWS Lambda function.

Returns:



265
266
267
 
# File 'lambda/event_source_mapping_props.rb', line 265

def target
  @target
end

#tumbling_window ⇒ AWSCDK::Duration? (readonly)

Note:

Default: - None

The size of the tumbling windows to group records sent to DynamoDB or Kinesis.

Returns:

See Also:



261
262
263
 
# File 'lambda/event_source_mapping_props.rb', line 261

def tumbling_window
  @tumbling_window
end

Class Method Details

.jsii_properties ⇒ Object 



267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
 
# File 'lambda/event_source_mapping_props.rb', line 267

def self.jsii_properties
  {
    :batch_size => "batchSize",
    :bisect_batch_on_error => "bisectBatchOnError",
    :enabled => "enabled",
    :event_source_arn => "eventSourceArn",
    :filter_encryption => "filterEncryption",
    :filters => "filters",
    :kafka_bootstrap_servers => "kafkaBootstrapServers",
    :kafka_consumer_group_id => "kafkaConsumerGroupId",
    :kafka_topic => "kafkaTopic",
    :log_level => "logLevel",
    :max_batching_window => "maxBatchingWindow",
    :max_concurrency => "maxConcurrency",
    :max_record_age => "maxRecordAge",
    :metrics_config => "metricsConfig",
    :on_failure => "onFailure",
    :parallelization_factor => "parallelizationFactor",
    :provisioned_poller_config => "provisionedPollerConfig",
    :report_batch_item_failures => "reportBatchItemFailures",
    :retry_attempts => "retryAttempts",
    :schema_registry_config => "schemaRegistryConfig",
    :source_access_configurations => "sourceAccessConfigurations",
    :starting_position => "startingPosition",
    :starting_position_timestamp => "startingPositionTimestamp",
    :support_s3_on_failure_destination => "supportS3OnFailureDestination",
    :tumbling_window => "tumblingWindow",
    :target => "target",
  }
end

Instance Method Details

#to_jsii ⇒ Object 



298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
 
# File 'lambda/event_source_mapping_props.rb', line 298

def to_jsii
  result = {}
  result.merge!(super)
  result.merge!({
    "batchSize" => @batch_size,
    "bisectBatchOnError" => @bisect_batch_on_error,
    "enabled" => @enabled,
    "eventSourceArn" => @event_source_arn,
    "filterEncryption" => @filter_encryption,
    "filters" => @filters,
    "kafkaBootstrapServers" => @kafka_bootstrap_servers,
    "kafkaConsumerGroupId" => @kafka_consumer_group_id,
    "kafkaTopic" => @kafka_topic,
    "logLevel" => @log_level,
    "maxBatchingWindow" => @max_batching_window,
    "maxConcurrency" => @max_concurrency,
    "maxRecordAge" => @max_record_age,
    "metricsConfig" => @metrics_config,
    "onFailure" => @on_failure,
    "parallelizationFactor" => @parallelization_factor,
    "provisionedPollerConfig" => @provisioned_poller_config,
    "reportBatchItemFailures" => @report_batch_item_failures,
    "retryAttempts" => @retry_attempts,
    "schemaRegistryConfig" => @schema_registry_config,
    "sourceAccessConfigurations" => @source_access_configurations,
    "startingPosition" => @starting_position,
    "startingPositionTimestamp" => @starting_position_timestamp,
    "supportS3OnFailureDestination" => @support_s3_on_failure_destination,
    "tumblingWindow" => @tumbling_window,
    "target" => @target,
  })
  result.compact
end