1. Packages
  2. AWS Native
  3. API Docs
  4. lambda
  5. EventSourceMapping

AWS Native is in preview. AWS Classic is fully supported.

AWS Native v0.103.0 published on Monday, Apr 22, 2024 by Pulumi

aws-native.lambda.EventSourceMapping

Explore with Pulumi AI

aws-native logo

AWS Native is in preview. AWS Classic is fully supported.

AWS Native v0.103.0 published on Monday, Apr 22, 2024 by Pulumi

    Resource Type definition for AWS::Lambda::EventSourceMapping

    Create EventSourceMapping Resource

    Resources are created with functions called constructors. To learn more about declaring and configuring resources, see Resources.

    Constructor syntax

    new EventSourceMapping(name: string, args: EventSourceMappingArgs, opts?: CustomResourceOptions);
    @overload
    def EventSourceMapping(resource_name: str,
                           args: EventSourceMappingArgs,
                           opts: Optional[ResourceOptions] = None)
    
    @overload
    def EventSourceMapping(resource_name: str,
                           opts: Optional[ResourceOptions] = None,
                           function_name: Optional[str] = None,
                           maximum_batching_window_in_seconds: Optional[int] = None,
                           destination_config: Optional[_lambda_.EventSourceMappingDestinationConfigArgs] = None,
                           maximum_retry_attempts: Optional[int] = None,
                           document_db_event_source_config: Optional[_lambda_.EventSourceMappingDocumentDbEventSourceConfigArgs] = None,
                           enabled: Optional[bool] = None,
                           event_source_arn: Optional[str] = None,
                           filter_criteria: Optional[_lambda_.EventSourceMappingFilterCriteriaArgs] = None,
                           batch_size: Optional[int] = None,
                           parallelization_factor: Optional[int] = None,
                           amazon_managed_kafka_event_source_config: Optional[_lambda_.EventSourceMappingAmazonManagedKafkaEventSourceConfigArgs] = None,
                           tumbling_window_in_seconds: Optional[int] = None,
                           bisect_batch_on_function_error: Optional[bool] = None,
                           function_response_types: Optional[Sequence[lambda_.EventSourceMappingFunctionResponseTypesItem]] = None,
                           queues: Optional[Sequence[str]] = None,
                           scaling_config: Optional[_lambda_.EventSourceMappingScalingConfigArgs] = None,
                           self_managed_event_source: Optional[_lambda_.EventSourceMappingSelfManagedEventSourceArgs] = None,
                           self_managed_kafka_event_source_config: Optional[_lambda_.EventSourceMappingSelfManagedKafkaEventSourceConfigArgs] = None,
                           source_access_configurations: Optional[Sequence[_lambda_.EventSourceMappingSourceAccessConfigurationArgs]] = None,
                           starting_position: Optional[str] = None,
                           starting_position_timestamp: Optional[float] = None,
                           topics: Optional[Sequence[str]] = None,
                           maximum_record_age_in_seconds: Optional[int] = None)
    func NewEventSourceMapping(ctx *Context, name string, args EventSourceMappingArgs, opts ...ResourceOption) (*EventSourceMapping, error)
    public EventSourceMapping(string name, EventSourceMappingArgs args, CustomResourceOptions? opts = null)
    public EventSourceMapping(String name, EventSourceMappingArgs args)
    public EventSourceMapping(String name, EventSourceMappingArgs args, CustomResourceOptions options)
    
    type: aws-native:lambda:EventSourceMapping
    properties: # The arguments to resource properties.
    options: # Bag of options to control resource's behavior.
    
    

    Parameters

    name string
    The unique name of the resource.
    args EventSourceMappingArgs
    The arguments to resource properties.
    opts CustomResourceOptions
    Bag of options to control resource's behavior.
    resource_name str
    The unique name of the resource.
    args EventSourceMappingArgs
    The arguments to resource properties.
    opts ResourceOptions
    Bag of options to control resource's behavior.
    ctx Context
    Context object for the current deployment.
    name string
    The unique name of the resource.
    args EventSourceMappingArgs
    The arguments to resource properties.
    opts ResourceOption
    Bag of options to control resource's behavior.
    name string
    The unique name of the resource.
    args EventSourceMappingArgs
    The arguments to resource properties.
    opts CustomResourceOptions
    Bag of options to control resource's behavior.
    name String
    The unique name of the resource.
    args EventSourceMappingArgs
    The arguments to resource properties.
    options CustomResourceOptions
    Bag of options to control resource's behavior.

    Example

    The following reference example uses placeholder values for all input properties.

    Coming soon!
    
    Coming soon!
    
    Coming soon!
    
    Coming soon!
    
    const eventSourceMappingResource = new aws_native.lambda.EventSourceMapping("eventSourceMappingResource", {
        functionName: "string",
        maximumBatchingWindowInSeconds: 0,
        destinationConfig: {
            onFailure: {
                destination: "string",
            },
        },
        maximumRetryAttempts: 0,
        documentDbEventSourceConfig: {
            collectionName: "string",
            databaseName: "string",
            fullDocument: aws_native.lambda.EventSourceMappingDocumentDbEventSourceConfigFullDocument.UpdateLookup,
        },
        enabled: false,
        eventSourceArn: "string",
        filterCriteria: {
            filters: [{
                pattern: "string",
            }],
        },
        batchSize: 0,
        parallelizationFactor: 0,
        amazonManagedKafkaEventSourceConfig: {
            consumerGroupId: "string",
        },
        tumblingWindowInSeconds: 0,
        bisectBatchOnFunctionError: false,
        functionResponseTypes: [aws_native.lambda.EventSourceMappingFunctionResponseTypesItem.ReportBatchItemFailures],
        queues: ["string"],
        scalingConfig: {
            maximumConcurrency: 0,
        },
        selfManagedEventSource: {
            endpoints: {
                kafkaBootstrapServers: ["string"],
            },
        },
        selfManagedKafkaEventSourceConfig: {
            consumerGroupId: "string",
        },
        sourceAccessConfigurations: [{
            type: aws_native.lambda.EventSourceMappingSourceAccessConfigurationType.BasicAuth,
            uri: "string",
        }],
        startingPosition: "string",
        startingPositionTimestamp: 0,
        topics: ["string"],
        maximumRecordAgeInSeconds: 0,
    });
    
    Coming soon!
    

    EventSourceMapping Resource Properties

    To learn more about resource properties and how to use them, see Inputs and Outputs in the Architecture and Concepts docs.

    Inputs

    The EventSourceMapping resource accepts the following input properties:

    FunctionName string
    The name of the Lambda function.
    AmazonManagedKafkaEventSourceConfig Pulumi.AwsNative.Lambda.Inputs.EventSourceMappingAmazonManagedKafkaEventSourceConfig
    Specific configuration settings for an MSK event source.
    BatchSize int
    The maximum number of items to retrieve in a single batch.
    BisectBatchOnFunctionError bool
    (Streams) If the function returns an error, split the batch in two and retry.
    DestinationConfig Pulumi.AwsNative.Lambda.Inputs.EventSourceMappingDestinationConfig
    (Streams) An Amazon SQS queue or Amazon SNS topic destination for discarded records.
    DocumentDbEventSourceConfig Pulumi.AwsNative.Lambda.Inputs.EventSourceMappingDocumentDbEventSourceConfig
    Document db event source config.
    Enabled bool
    Disables the event source mapping to pause polling and invocation.
    EventSourceArn string
    The Amazon Resource Name (ARN) of the event source.
    FilterCriteria Pulumi.AwsNative.Lambda.Inputs.EventSourceMappingFilterCriteria
    The filter criteria to control event filtering.
    FunctionResponseTypes List<Pulumi.AwsNative.Lambda.EventSourceMappingFunctionResponseTypesItem>
    (Streams) A list of response types supported by the function.
    MaximumBatchingWindowInSeconds int
    (Streams) The maximum amount of time to gather records before invoking the function, in seconds.
    MaximumRecordAgeInSeconds int
    (Streams) The maximum age of a record that Lambda sends to a function for processing.
    MaximumRetryAttempts int
    (Streams) The maximum number of times to retry when the function returns an error.
    ParallelizationFactor int
    (Streams) The number of batches to process from each shard concurrently.
    Queues List<string>
    (ActiveMQ) A list of ActiveMQ queues.
    ScalingConfig Pulumi.AwsNative.Lambda.Inputs.EventSourceMappingScalingConfig
    The scaling configuration for the event source.
    SelfManagedEventSource Pulumi.AwsNative.Lambda.Inputs.EventSourceMappingSelfManagedEventSource
    Self-managed event source endpoints.
    SelfManagedKafkaEventSourceConfig Pulumi.AwsNative.Lambda.Inputs.EventSourceMappingSelfManagedKafkaEventSourceConfig
    Specific configuration settings for a Self-Managed Apache Kafka event source.
    SourceAccessConfigurations List<Pulumi.AwsNative.Lambda.Inputs.EventSourceMappingSourceAccessConfiguration>
    A list of SourceAccessConfiguration.
    StartingPosition string
    The position in a stream from which to start reading. Required for Amazon Kinesis and Amazon DynamoDB Streams sources.
    StartingPositionTimestamp double
    With StartingPosition set to AT_TIMESTAMP, the time from which to start reading, in Unix time seconds.
    Topics List<string>
    (Kafka) A list of Kafka topics.
    TumblingWindowInSeconds int
    (Streams) Tumbling window (non-overlapping time window) duration to perform aggregations.
    FunctionName string
    The name of the Lambda function.
    AmazonManagedKafkaEventSourceConfig EventSourceMappingAmazonManagedKafkaEventSourceConfigArgs
    Specific configuration settings for an MSK event source.
    BatchSize int
    The maximum number of items to retrieve in a single batch.
    BisectBatchOnFunctionError bool
    (Streams) If the function returns an error, split the batch in two and retry.
    DestinationConfig EventSourceMappingDestinationConfigArgs
    (Streams) An Amazon SQS queue or Amazon SNS topic destination for discarded records.
    DocumentDbEventSourceConfig EventSourceMappingDocumentDbEventSourceConfigArgs
    Document db event source config.
    Enabled bool
    Disables the event source mapping to pause polling and invocation.
    EventSourceArn string
    The Amazon Resource Name (ARN) of the event source.
    FilterCriteria EventSourceMappingFilterCriteriaArgs
    The filter criteria to control event filtering.
    FunctionResponseTypes []EventSourceMappingFunctionResponseTypesItem
    (Streams) A list of response types supported by the function.
    MaximumBatchingWindowInSeconds int
    (Streams) The maximum amount of time to gather records before invoking the function, in seconds.
    MaximumRecordAgeInSeconds int
    (Streams) The maximum age of a record that Lambda sends to a function for processing.
    MaximumRetryAttempts int
    (Streams) The maximum number of times to retry when the function returns an error.
    ParallelizationFactor int
    (Streams) The number of batches to process from each shard concurrently.
    Queues []string
    (ActiveMQ) A list of ActiveMQ queues.
    ScalingConfig EventSourceMappingScalingConfigArgs
    The scaling configuration for the event source.
    SelfManagedEventSource EventSourceMappingSelfManagedEventSourceArgs
    Self-managed event source endpoints.
    SelfManagedKafkaEventSourceConfig EventSourceMappingSelfManagedKafkaEventSourceConfigArgs
    Specific configuration settings for a Self-Managed Apache Kafka event source.
    SourceAccessConfigurations []EventSourceMappingSourceAccessConfigurationArgs
    A list of SourceAccessConfiguration.
    StartingPosition string
    The position in a stream from which to start reading. Required for Amazon Kinesis and Amazon DynamoDB Streams sources.
    StartingPositionTimestamp float64
    With StartingPosition set to AT_TIMESTAMP, the time from which to start reading, in Unix time seconds.
    Topics []string
    (Kafka) A list of Kafka topics.
    TumblingWindowInSeconds int
    (Streams) Tumbling window (non-overlapping time window) duration to perform aggregations.
    functionName String
    The name of the Lambda function.
    amazonManagedKafkaEventSourceConfig EventSourceMappingAmazonManagedKafkaEventSourceConfig
    Specific configuration settings for an MSK event source.
    batchSize Integer
    The maximum number of items to retrieve in a single batch.
    bisectBatchOnFunctionError Boolean
    (Streams) If the function returns an error, split the batch in two and retry.
    destinationConfig EventSourceMappingDestinationConfig
    (Streams) An Amazon SQS queue or Amazon SNS topic destination for discarded records.
    documentDbEventSourceConfig EventSourceMappingDocumentDbEventSourceConfig
    Document db event source config.
    enabled Boolean
    Disables the event source mapping to pause polling and invocation.
    eventSourceArn String
    The Amazon Resource Name (ARN) of the event source.
    filterCriteria EventSourceMappingFilterCriteria
    The filter criteria to control event filtering.
    functionResponseTypes List<EventSourceMappingFunctionResponseTypesItem>
    (Streams) A list of response types supported by the function.
    maximumBatchingWindowInSeconds Integer
    (Streams) The maximum amount of time to gather records before invoking the function, in seconds.
    maximumRecordAgeInSeconds Integer
    (Streams) The maximum age of a record that Lambda sends to a function for processing.
    maximumRetryAttempts Integer
    (Streams) The maximum number of times to retry when the function returns an error.
    parallelizationFactor Integer
    (Streams) The number of batches to process from each shard concurrently.
    queues List<String>
    (ActiveMQ) A list of ActiveMQ queues.
    scalingConfig EventSourceMappingScalingConfig
    The scaling configuration for the event source.
    selfManagedEventSource EventSourceMappingSelfManagedEventSource
    Self-managed event source endpoints.
    selfManagedKafkaEventSourceConfig EventSourceMappingSelfManagedKafkaEventSourceConfig
    Specific configuration settings for a Self-Managed Apache Kafka event source.
    sourceAccessConfigurations List<EventSourceMappingSourceAccessConfiguration>
    A list of SourceAccessConfiguration.
    startingPosition String
    The position in a stream from which to start reading. Required for Amazon Kinesis and Amazon DynamoDB Streams sources.
    startingPositionTimestamp Double
    With StartingPosition set to AT_TIMESTAMP, the time from which to start reading, in Unix time seconds.
    topics List<String>
    (Kafka) A list of Kafka topics.
    tumblingWindowInSeconds Integer
    (Streams) Tumbling window (non-overlapping time window) duration to perform aggregations.
    functionName string
    The name of the Lambda function.
    amazonManagedKafkaEventSourceConfig EventSourceMappingAmazonManagedKafkaEventSourceConfig
    Specific configuration settings for an MSK event source.
    batchSize number
    The maximum number of items to retrieve in a single batch.
    bisectBatchOnFunctionError boolean
    (Streams) If the function returns an error, split the batch in two and retry.
    destinationConfig EventSourceMappingDestinationConfig
    (Streams) An Amazon SQS queue or Amazon SNS topic destination for discarded records.
    documentDbEventSourceConfig EventSourceMappingDocumentDbEventSourceConfig
    Document db event source config.
    enabled boolean
    Disables the event source mapping to pause polling and invocation.
    eventSourceArn string
    The Amazon Resource Name (ARN) of the event source.
    filterCriteria EventSourceMappingFilterCriteria
    The filter criteria to control event filtering.
    functionResponseTypes EventSourceMappingFunctionResponseTypesItem[]
    (Streams) A list of response types supported by the function.
    maximumBatchingWindowInSeconds number
    (Streams) The maximum amount of time to gather records before invoking the function, in seconds.
    maximumRecordAgeInSeconds number
    (Streams) The maximum age of a record that Lambda sends to a function for processing.
    maximumRetryAttempts number
    (Streams) The maximum number of times to retry when the function returns an error.
    parallelizationFactor number
    (Streams) The number of batches to process from each shard concurrently.
    queues string[]
    (ActiveMQ) A list of ActiveMQ queues.
    scalingConfig EventSourceMappingScalingConfig
    The scaling configuration for the event source.
    selfManagedEventSource EventSourceMappingSelfManagedEventSource
    Self-managed event source endpoints.
    selfManagedKafkaEventSourceConfig EventSourceMappingSelfManagedKafkaEventSourceConfig
    Specific configuration settings for a Self-Managed Apache Kafka event source.
    sourceAccessConfigurations EventSourceMappingSourceAccessConfiguration[]
    A list of SourceAccessConfiguration.
    startingPosition string
    The position in a stream from which to start reading. Required for Amazon Kinesis and Amazon DynamoDB Streams sources.
    startingPositionTimestamp number
    With StartingPosition set to AT_TIMESTAMP, the time from which to start reading, in Unix time seconds.
    topics string[]
    (Kafka) A list of Kafka topics.
    tumblingWindowInSeconds number
    (Streams) Tumbling window (non-overlapping time window) duration to perform aggregations.
    function_name str
    The name of the Lambda function.
    amazon_managed_kafka_event_source_config lambda_.EventSourceMappingAmazonManagedKafkaEventSourceConfigArgs
    Specific configuration settings for an MSK event source.
    batch_size int
    The maximum number of items to retrieve in a single batch.
    bisect_batch_on_function_error bool
    (Streams) If the function returns an error, split the batch in two and retry.
    destination_config lambda_.EventSourceMappingDestinationConfigArgs
    (Streams) An Amazon SQS queue or Amazon SNS topic destination for discarded records.
    document_db_event_source_config lambda_.EventSourceMappingDocumentDbEventSourceConfigArgs
    Document db event source config.
    enabled bool
    Disables the event source mapping to pause polling and invocation.
    event_source_arn str
    The Amazon Resource Name (ARN) of the event source.
    filter_criteria lambda_.EventSourceMappingFilterCriteriaArgs
    The filter criteria to control event filtering.
    function_response_types Sequence[lambda_.EventSourceMappingFunctionResponseTypesItem]
    (Streams) A list of response types supported by the function.
    maximum_batching_window_in_seconds int
    (Streams) The maximum amount of time to gather records before invoking the function, in seconds.
    maximum_record_age_in_seconds int
    (Streams) The maximum age of a record that Lambda sends to a function for processing.
    maximum_retry_attempts int
    (Streams) The maximum number of times to retry when the function returns an error.
    parallelization_factor int
    (Streams) The number of batches to process from each shard concurrently.
    queues Sequence[str]
    (ActiveMQ) A list of ActiveMQ queues.
    scaling_config lambda_.EventSourceMappingScalingConfigArgs
    The scaling configuration for the event source.
    self_managed_event_source lambda_.EventSourceMappingSelfManagedEventSourceArgs
    Self-managed event source endpoints.
    self_managed_kafka_event_source_config lambda_.EventSourceMappingSelfManagedKafkaEventSourceConfigArgs
    Specific configuration settings for a Self-Managed Apache Kafka event source.
    source_access_configurations Sequence[lambda_.EventSourceMappingSourceAccessConfigurationArgs]
    A list of SourceAccessConfiguration.
    starting_position str
    The position in a stream from which to start reading. Required for Amazon Kinesis and Amazon DynamoDB Streams sources.
    starting_position_timestamp float
    With StartingPosition set to AT_TIMESTAMP, the time from which to start reading, in Unix time seconds.
    topics Sequence[str]
    (Kafka) A list of Kafka topics.
    tumbling_window_in_seconds int
    (Streams) Tumbling window (non-overlapping time window) duration to perform aggregations.
    functionName String
    The name of the Lambda function.
    amazonManagedKafkaEventSourceConfig Property Map
    Specific configuration settings for an MSK event source.
    batchSize Number
    The maximum number of items to retrieve in a single batch.
    bisectBatchOnFunctionError Boolean
    (Streams) If the function returns an error, split the batch in two and retry.
    destinationConfig Property Map
    (Streams) An Amazon SQS queue or Amazon SNS topic destination for discarded records.
    documentDbEventSourceConfig Property Map
    Document db event source config.
    enabled Boolean
    Disables the event source mapping to pause polling and invocation.
    eventSourceArn String
    The Amazon Resource Name (ARN) of the event source.
    filterCriteria Property Map
    The filter criteria to control event filtering.
    functionResponseTypes List<"ReportBatchItemFailures">
    (Streams) A list of response types supported by the function.
    maximumBatchingWindowInSeconds Number
    (Streams) The maximum amount of time to gather records before invoking the function, in seconds.
    maximumRecordAgeInSeconds Number
    (Streams) The maximum age of a record that Lambda sends to a function for processing.
    maximumRetryAttempts Number
    (Streams) The maximum number of times to retry when the function returns an error.
    parallelizationFactor Number
    (Streams) The number of batches to process from each shard concurrently.
    queues List<String>
    (ActiveMQ) A list of ActiveMQ queues.
    scalingConfig Property Map
    The scaling configuration for the event source.
    selfManagedEventSource Property Map
    Self-managed event source endpoints.
    selfManagedKafkaEventSourceConfig Property Map
    Specific configuration settings for a Self-Managed Apache Kafka event source.
    sourceAccessConfigurations List<Property Map>
    A list of SourceAccessConfiguration.
    startingPosition String
    The position in a stream from which to start reading. Required for Amazon Kinesis and Amazon DynamoDB Streams sources.
    startingPositionTimestamp Number
    With StartingPosition set to AT_TIMESTAMP, the time from which to start reading, in Unix time seconds.
    topics List<String>
    (Kafka) A list of Kafka topics.
    tumblingWindowInSeconds Number
    (Streams) Tumbling window (non-overlapping time window) duration to perform aggregations.

    Outputs

    All input properties are implicitly available as output properties. Additionally, the EventSourceMapping resource produces the following output properties:

    AwsId string
    Event Source Mapping Identifier UUID.
    Id string
    The provider-assigned unique ID for this managed resource.
    AwsId string
    Event Source Mapping Identifier UUID.
    Id string
    The provider-assigned unique ID for this managed resource.
    awsId String
    Event Source Mapping Identifier UUID.
    id String
    The provider-assigned unique ID for this managed resource.
    awsId string
    Event Source Mapping Identifier UUID.
    id string
    The provider-assigned unique ID for this managed resource.
    aws_id str
    Event Source Mapping Identifier UUID.
    id str
    The provider-assigned unique ID for this managed resource.
    awsId String
    Event Source Mapping Identifier UUID.
    id String
    The provider-assigned unique ID for this managed resource.

    Supporting Types

    EventSourceMappingAmazonManagedKafkaEventSourceConfig, EventSourceMappingAmazonManagedKafkaEventSourceConfigArgs

    ConsumerGroupId string
    The identifier for the Kafka Consumer Group to join.
    ConsumerGroupId string
    The identifier for the Kafka Consumer Group to join.
    consumerGroupId String
    The identifier for the Kafka Consumer Group to join.
    consumerGroupId string
    The identifier for the Kafka Consumer Group to join.
    consumer_group_id str
    The identifier for the Kafka Consumer Group to join.
    consumerGroupId String
    The identifier for the Kafka Consumer Group to join.

    EventSourceMappingDestinationConfig, EventSourceMappingDestinationConfigArgs

    OnFailure Pulumi.AwsNative.Lambda.Inputs.EventSourceMappingOnFailure
    The destination configuration for failed invocations.
    OnFailure EventSourceMappingOnFailure
    The destination configuration for failed invocations.
    onFailure EventSourceMappingOnFailure
    The destination configuration for failed invocations.
    onFailure EventSourceMappingOnFailure
    The destination configuration for failed invocations.
    on_failure lambda_.EventSourceMappingOnFailure
    The destination configuration for failed invocations.
    onFailure Property Map
    The destination configuration for failed invocations.

    EventSourceMappingDocumentDbEventSourceConfig, EventSourceMappingDocumentDbEventSourceConfigArgs

    CollectionName string
    The collection name to connect to.
    DatabaseName string
    The database name to connect to.
    FullDocument Pulumi.AwsNative.Lambda.EventSourceMappingDocumentDbEventSourceConfigFullDocument
    Include full document in change stream response. The default option will only send the changes made to documents to Lambda. If you want the complete document sent to Lambda, set this to UpdateLookup.
    CollectionName string
    The collection name to connect to.
    DatabaseName string
    The database name to connect to.
    FullDocument EventSourceMappingDocumentDbEventSourceConfigFullDocument
    Include full document in change stream response. The default option will only send the changes made to documents to Lambda. If you want the complete document sent to Lambda, set this to UpdateLookup.
    collectionName String
    The collection name to connect to.
    databaseName String
    The database name to connect to.
    fullDocument EventSourceMappingDocumentDbEventSourceConfigFullDocument
    Include full document in change stream response. The default option will only send the changes made to documents to Lambda. If you want the complete document sent to Lambda, set this to UpdateLookup.
    collectionName string
    The collection name to connect to.
    databaseName string
    The database name to connect to.
    fullDocument EventSourceMappingDocumentDbEventSourceConfigFullDocument
    Include full document in change stream response. The default option will only send the changes made to documents to Lambda. If you want the complete document sent to Lambda, set this to UpdateLookup.
    collection_name str
    The collection name to connect to.
    database_name str
    The database name to connect to.
    full_document lambda_.EventSourceMappingDocumentDbEventSourceConfigFullDocument
    Include full document in change stream response. The default option will only send the changes made to documents to Lambda. If you want the complete document sent to Lambda, set this to UpdateLookup.
    collectionName String
    The collection name to connect to.
    databaseName String
    The database name to connect to.
    fullDocument "UpdateLookup" | "Default"
    Include full document in change stream response. The default option will only send the changes made to documents to Lambda. If you want the complete document sent to Lambda, set this to UpdateLookup.

    EventSourceMappingDocumentDbEventSourceConfigFullDocument, EventSourceMappingDocumentDbEventSourceConfigFullDocumentArgs

    UpdateLookup
    UpdateLookup
    Default
    Default
    EventSourceMappingDocumentDbEventSourceConfigFullDocumentUpdateLookup
    UpdateLookup
    EventSourceMappingDocumentDbEventSourceConfigFullDocumentDefault
    Default
    UpdateLookup
    UpdateLookup
    Default
    Default
    UpdateLookup
    UpdateLookup
    Default
    Default
    UPDATE_LOOKUP
    UpdateLookup
    DEFAULT
    Default
    "UpdateLookup"
    UpdateLookup
    "Default"
    Default

    EventSourceMappingEndpoints, EventSourceMappingEndpointsArgs

    KafkaBootstrapServers List<string>
    A list of Kafka server endpoints.
    KafkaBootstrapServers []string
    A list of Kafka server endpoints.
    kafkaBootstrapServers List<String>
    A list of Kafka server endpoints.
    kafkaBootstrapServers string[]
    A list of Kafka server endpoints.
    kafka_bootstrap_servers Sequence[str]
    A list of Kafka server endpoints.
    kafkaBootstrapServers List<String>
    A list of Kafka server endpoints.

    EventSourceMappingFilter, EventSourceMappingFilterArgs

    Pattern string
    The filter pattern that defines which events should be passed for invocations.
    Pattern string
    The filter pattern that defines which events should be passed for invocations.
    pattern String
    The filter pattern that defines which events should be passed for invocations.
    pattern string
    The filter pattern that defines which events should be passed for invocations.
    pattern str
    The filter pattern that defines which events should be passed for invocations.
    pattern String
    The filter pattern that defines which events should be passed for invocations.

    EventSourceMappingFilterCriteria, EventSourceMappingFilterCriteriaArgs

    Filters []EventSourceMappingFilter
    List of filters of this FilterCriteria
    filters List<EventSourceMappingFilter>
    List of filters of this FilterCriteria
    filters EventSourceMappingFilter[]
    List of filters of this FilterCriteria
    filters Sequence[lambda_.EventSourceMappingFilter]
    List of filters of this FilterCriteria
    filters List<Property Map>
    List of filters of this FilterCriteria

    EventSourceMappingFunctionResponseTypesItem, EventSourceMappingFunctionResponseTypesItemArgs

    ReportBatchItemFailures
    ReportBatchItemFailures
    EventSourceMappingFunctionResponseTypesItemReportBatchItemFailures
    ReportBatchItemFailures
    ReportBatchItemFailures
    ReportBatchItemFailures
    ReportBatchItemFailures
    ReportBatchItemFailures
    REPORT_BATCH_ITEM_FAILURES
    ReportBatchItemFailures
    "ReportBatchItemFailures"
    ReportBatchItemFailures

    EventSourceMappingOnFailure, EventSourceMappingOnFailureArgs

    Destination string
    The Amazon Resource Name (ARN) of the destination resource.
    Destination string
    The Amazon Resource Name (ARN) of the destination resource.
    destination String
    The Amazon Resource Name (ARN) of the destination resource.
    destination string
    The Amazon Resource Name (ARN) of the destination resource.
    destination str
    The Amazon Resource Name (ARN) of the destination resource.
    destination String
    The Amazon Resource Name (ARN) of the destination resource.

    EventSourceMappingScalingConfig, EventSourceMappingScalingConfigArgs

    MaximumConcurrency int
    The maximum number of concurrent functions that the event source can invoke.
    MaximumConcurrency int
    The maximum number of concurrent functions that the event source can invoke.
    maximumConcurrency Integer
    The maximum number of concurrent functions that the event source can invoke.
    maximumConcurrency number
    The maximum number of concurrent functions that the event source can invoke.
    maximum_concurrency int
    The maximum number of concurrent functions that the event source can invoke.
    maximumConcurrency Number
    The maximum number of concurrent functions that the event source can invoke.

    EventSourceMappingSelfManagedEventSource, EventSourceMappingSelfManagedEventSourceArgs

    Endpoints Pulumi.AwsNative.Lambda.Inputs.EventSourceMappingEndpoints
    The endpoints for a self-managed event source.
    Endpoints EventSourceMappingEndpoints
    The endpoints for a self-managed event source.
    endpoints EventSourceMappingEndpoints
    The endpoints for a self-managed event source.
    endpoints EventSourceMappingEndpoints
    The endpoints for a self-managed event source.
    endpoints lambda_.EventSourceMappingEndpoints
    The endpoints for a self-managed event source.
    endpoints Property Map
    The endpoints for a self-managed event source.

    EventSourceMappingSelfManagedKafkaEventSourceConfig, EventSourceMappingSelfManagedKafkaEventSourceConfigArgs

    ConsumerGroupId string
    The identifier for the Kafka Consumer Group to join.
    ConsumerGroupId string
    The identifier for the Kafka Consumer Group to join.
    consumerGroupId String
    The identifier for the Kafka Consumer Group to join.
    consumerGroupId string
    The identifier for the Kafka Consumer Group to join.
    consumer_group_id str
    The identifier for the Kafka Consumer Group to join.
    consumerGroupId String
    The identifier for the Kafka Consumer Group to join.

    EventSourceMappingSourceAccessConfiguration, EventSourceMappingSourceAccessConfigurationArgs

    Type Pulumi.AwsNative.Lambda.EventSourceMappingSourceAccessConfigurationType
    The type of source access configuration.
    Uri string
    The URI for the source access configuration resource.
    Type EventSourceMappingSourceAccessConfigurationType
    The type of source access configuration.
    Uri string
    The URI for the source access configuration resource.
    type EventSourceMappingSourceAccessConfigurationType
    The type of source access configuration.
    uri String
    The URI for the source access configuration resource.
    type EventSourceMappingSourceAccessConfigurationType
    The type of source access configuration.
    uri string
    The URI for the source access configuration resource.
    type lambda_.EventSourceMappingSourceAccessConfigurationType
    The type of source access configuration.
    uri str
    The URI for the source access configuration resource.

    EventSourceMappingSourceAccessConfigurationType, EventSourceMappingSourceAccessConfigurationTypeArgs

    BasicAuth
    BASIC_AUTH
    VpcSubnet
    VPC_SUBNET
    VpcSecurityGroup
    VPC_SECURITY_GROUP
    SaslScram512Auth
    SASL_SCRAM_512_AUTH
    SaslScram256Auth
    SASL_SCRAM_256_AUTH
    VirtualHost
    VIRTUAL_HOST
    ClientCertificateTlsAuth
    CLIENT_CERTIFICATE_TLS_AUTH
    ServerRootCaCertificate
    SERVER_ROOT_CA_CERTIFICATE
    EventSourceMappingSourceAccessConfigurationTypeBasicAuth
    BASIC_AUTH
    EventSourceMappingSourceAccessConfigurationTypeVpcSubnet
    VPC_SUBNET
    EventSourceMappingSourceAccessConfigurationTypeVpcSecurityGroup
    VPC_SECURITY_GROUP
    EventSourceMappingSourceAccessConfigurationTypeSaslScram512Auth
    SASL_SCRAM_512_AUTH
    EventSourceMappingSourceAccessConfigurationTypeSaslScram256Auth
    SASL_SCRAM_256_AUTH
    EventSourceMappingSourceAccessConfigurationTypeVirtualHost
    VIRTUAL_HOST
    EventSourceMappingSourceAccessConfigurationTypeClientCertificateTlsAuth
    CLIENT_CERTIFICATE_TLS_AUTH
    EventSourceMappingSourceAccessConfigurationTypeServerRootCaCertificate
    SERVER_ROOT_CA_CERTIFICATE
    BasicAuth
    BASIC_AUTH
    VpcSubnet
    VPC_SUBNET
    VpcSecurityGroup
    VPC_SECURITY_GROUP
    SaslScram512Auth
    SASL_SCRAM_512_AUTH
    SaslScram256Auth
    SASL_SCRAM_256_AUTH
    VirtualHost
    VIRTUAL_HOST
    ClientCertificateTlsAuth
    CLIENT_CERTIFICATE_TLS_AUTH
    ServerRootCaCertificate
    SERVER_ROOT_CA_CERTIFICATE
    BasicAuth
    BASIC_AUTH
    VpcSubnet
    VPC_SUBNET
    VpcSecurityGroup
    VPC_SECURITY_GROUP
    SaslScram512Auth
    SASL_SCRAM_512_AUTH
    SaslScram256Auth
    SASL_SCRAM_256_AUTH
    VirtualHost
    VIRTUAL_HOST
    ClientCertificateTlsAuth
    CLIENT_CERTIFICATE_TLS_AUTH
    ServerRootCaCertificate
    SERVER_ROOT_CA_CERTIFICATE
    BASIC_AUTH
    BASIC_AUTH
    VPC_SUBNET
    VPC_SUBNET
    VPC_SECURITY_GROUP
    VPC_SECURITY_GROUP
    SASL_SCRAM512_AUTH
    SASL_SCRAM_512_AUTH
    SASL_SCRAM256_AUTH
    SASL_SCRAM_256_AUTH
    VIRTUAL_HOST
    VIRTUAL_HOST
    CLIENT_CERTIFICATE_TLS_AUTH
    CLIENT_CERTIFICATE_TLS_AUTH
    SERVER_ROOT_CA_CERTIFICATE
    SERVER_ROOT_CA_CERTIFICATE
    "BASIC_AUTH"
    BASIC_AUTH
    "VPC_SUBNET"
    VPC_SUBNET
    "VPC_SECURITY_GROUP"
    VPC_SECURITY_GROUP
    "SASL_SCRAM_512_AUTH"
    SASL_SCRAM_512_AUTH
    "SASL_SCRAM_256_AUTH"
    SASL_SCRAM_256_AUTH
    "VIRTUAL_HOST"
    VIRTUAL_HOST
    "CLIENT_CERTIFICATE_TLS_AUTH"
    CLIENT_CERTIFICATE_TLS_AUTH
    "SERVER_ROOT_CA_CERTIFICATE"
    SERVER_ROOT_CA_CERTIFICATE

    Package Details

    Repository
    AWS Native pulumi/pulumi-aws-native
    License
    Apache-2.0
    aws-native logo

    AWS Native is in preview. AWS Classic is fully supported.

    AWS Native v0.103.0 published on Monday, Apr 22, 2024 by Pulumi