List Event Source Mappings

lambda_list_event_source_mappings

R Documentation

Lists event source mappings

Description

Lists event source mappings. Specify an EventSourceArn to show only event source mappings for a single event source.

Usage

lambda_list_event_source_mappings(EventSourceArn, FunctionName, Marker,
  MaxItems)

Arguments

EventSourceArn

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

• Amazon Kinesis – The ARN of the data stream or a stream consumer.

• Amazon DynamoDB Streams – The ARN of the stream.

• Amazon Simple Queue Service – The ARN of the queue.

• Amazon Managed Streaming for Apache Kafka – The ARN of the cluster or the ARN of the VPC connection (for cross-account event source mappings).

• Amazon MQ – The ARN of the broker.

• Amazon DocumentDB – The ARN of the DocumentDB change stream.

FunctionName

The name or ARN of the Lambda function.

Name formats

• Function name – MyFunction.

• Function ARN – ⁠arn:aws:lambda:us-west-2:123456789012:function:MyFunction⁠.

• Version or Alias ARN – ⁠arn:aws:lambda:us-west-2:123456789012:function:MyFunction:PROD⁠.

• Partial ARN – ⁠123456789012:function:MyFunction⁠.

The length constraint applies only to the full ARN. If you specify only the function name, it's limited to 64 characters in length.

Marker

A pagination token returned by a previous call.

MaxItems

The maximum number of event source mappings to return. Note that ListEventSourceMappings returns a maximum of 100 items in each response, even if you set the number higher.

Value

A list with the following syntax:

list(
  NextMarker = "string",
  EventSourceMappings = list(
    list(
      UUID = "string",
      StartingPosition = "TRIM_HORIZON"|"LATEST"|"AT_TIMESTAMP",
      StartingPositionTimestamp = as.POSIXct(
        "2015-01-01"
      ),
      BatchSize = 123,
      MaximumBatchingWindowInSeconds = 123,
      ParallelizationFactor = 123,
      EventSourceArn = "string",
      FilterCriteria = list(
        Filters = list(
          list(
            Pattern = "string"
          )
        )
      ),
      FunctionArn = "string",
      LastModified = as.POSIXct(
        "2015-01-01"
      ),
      LastProcessingResult = "string",
      State = "string",
      StateTransitionReason = "string",
      DestinationConfig = list(
        OnSuccess = list(
          Destination = "string"
        ),
        OnFailure = list(
          Destination = "string"
        )
      ),
      Topics = list(
        "string"
      ),
      Queues = list(
        "string"
      ),
      SourceAccessConfigurations = list(
        list(
          Type = "BASIC_AUTH"|"VPC_SUBNET"|"VPC_SECURITY_GROUP"|"SASL_SCRAM_512_AUTH"|"SASL_SCRAM_256_AUTH"|"VIRTUAL_HOST"|"CLIENT_CERTIFICATE_TLS_AUTH"|"SERVER_ROOT_CA_CERTIFICATE",
          URI = "string"
        )
      ),
      SelfManagedEventSource = list(
        Endpoints = list(
          list(
            "string"
          )
        )
      ),
      MaximumRecordAgeInSeconds = 123,
      BisectBatchOnFunctionError = TRUE|FALSE,
      MaximumRetryAttempts = 123,
      TumblingWindowInSeconds = 123,
      FunctionResponseTypes = list(
        "ReportBatchItemFailures"
      ),
      AmazonManagedKafkaEventSourceConfig = list(
        ConsumerGroupId = "string"
      ),
      SelfManagedKafkaEventSourceConfig = list(
        ConsumerGroupId = "string"
      ),
      ScalingConfig = list(
        MaximumConcurrency = 123
      ),
      DocumentDBEventSourceConfig = list(
        DatabaseName = "string",
        CollectionName = "string",
        FullDocument = "UpdateLookup"|"Default"
      ),
      KMSKeyArn = "string",
      FilterCriteriaError = list(
        ErrorCode = "string",
        Message = "string"
      )
    )
  )
)

Request syntax

svc$list_event_source_mappings(
  EventSourceArn = "string",
  FunctionName = "string",
  Marker = "string",
  MaxItems = 123
)