Class EventSourceMappingArgs

Inheritance

System.Object

InputArgs

ResourceArgs

EventSourceMappingArgs

Inherited Members

ResourceArgs.Empty

System.Object.Equals(System.Object)

System.Object.Equals(System.Object, System.Object)

System.Object.GetHashCode()

System.Object.GetType()

System.Object.MemberwiseClone()

System.Object.ReferenceEquals(System.Object, System.Object)

System.Object.ToString()

Namespace: Pulumi.Aws.Lambda

Assembly: Pulumi.Aws.dll

Syntax

public sealed class EventSourceMappingArgs : ResourceArgs

Constructors

EventSourceMappingArgs()

Declaration

public EventSourceMappingArgs()

Properties

BatchSize

The largest number of records that Lambda will retrieve from your event source at the time of invocation. Defaults to 100 for DynamoDB and Kinesis, 10 for SQS.

Declaration

public Input<int> BatchSize { get; set; }

Property Value

Type	Description
Input<System.Int32>

BisectBatchOnFunctionError

Declaration

public Input<bool> BisectBatchOnFunctionError { get; set; }

Property Value

Type	Description
Input<System.Boolean>

DestinationConfig

Declaration

public Input<EventSourceMappingDestinationConfigArgs> DestinationConfig { get; set; }

Property Value

Type	Description
Input<EventSourceMappingDestinationConfigArgs>

Enabled

Determines if the mapping will be enabled on creation. Defaults to true.

Declaration

public Input<bool> Enabled { get; set; }

Property Value

Type	Description
Input<System.Boolean>

EventSourceArn

The event source ARN - can be a Kinesis stream, DynamoDB stream, or SQS queue.

Declaration

public Input<string> EventSourceArn { get; set; }

Property Value

Type	Description
Input<System.String>

FunctionName

The name or the ARN of the Lambda function that will be subscribing to events.

Declaration

public Input<string> FunctionName { get; set; }

Property Value

Type	Description
Input<System.String>

MaximumBatchingWindowInSeconds

The maximum amount of time to gather records before invoking the function, in seconds. Records will continue to buffer until either maximum_batching_window_in_seconds expires or batch_size has been met. Defaults to as soon as records are available in the stream. If the batch it reads from the stream only has one record in it, Lambda only sends one record to the function.

Declaration

public Input<int> MaximumBatchingWindowInSeconds { get; set; }

Property Value

Type	Description
Input<System.Int32>

MaximumRecordAgeInSeconds

Declaration

public Input<int> MaximumRecordAgeInSeconds { get; set; }

Property Value

Type	Description
Input<System.Int32>

MaximumRetryAttempts

Declaration

public Input<int> MaximumRetryAttempts { get; set; }

Property Value

Type	Description
Input<System.Int32>

ParallelizationFactor

Declaration

public Input<int> ParallelizationFactor { get; set; }

Property Value

Type	Description
Input<System.Int32>

StartingPosition

The position in the stream where AWS Lambda should start reading. Must be one of AT_TIMESTAMP (Kinesis only), LATEST or TRIM_HORIZON if getting events from Kinesis or DynamoDB. Must not be provided if getting events from SQS. More information about these positions can be found in the AWS DynamoDB Streams API Reference and AWS Kinesis API Reference.

Declaration

public Input<string> StartingPosition { get; set; }

Property Value

Type	Description
Input<System.String>

StartingPositionTimestamp

A timestamp in RFC3339 format of the data record which to start reading when using starting_position set to AT_TIMESTAMP. If a record with this exact timestamp does not exist, the next later record is chosen. If the timestamp is older than the current trim horizon, the oldest available record is chosen.

• parallelization_factor: - (Optional) The number of batches to process from each shard concurrently. Only available for stream sources (DynamoDB and Kinesis). Minimum and default of 1, maximum of 10.
• maximum_retry_attempts: - (Optional) The maximum number of times to retry when the function returns an error. Only available for stream sources (DynamoDB and Kinesis). Minimum of 0, maximum and default of 10000.
• maximum_record_age_in_seconds: - (Optional) The maximum age of a record that Lambda sends to a function for processing. Only available for stream sources (DynamoDB and Kinesis). Minimum of 60, maximum and default of 604800.
• bisect_batch_on_function_error: - (Optional) If the function returns an error, split the batch in two and retry. Only available for stream sources (DynamoDB and Kinesis). Defaults to false.
• destination_config: - (Optional) An Amazon SQS queue or Amazon SNS topic destination for failed records. Only available for stream sources (DynamoDB and Kinesis). Detailed below.

Declaration

public Input<string> StartingPositionTimestamp { get; set; }

Property Value

Type	Description
Input<System.String>