PUT /2015-03-31/event-source-mappings/{UUID}
Updates an event source mapping. You can change the function that Lambda invokes, or pause invocation and resume later from the same location.
For details about how to configure different event sources, see the following topics.
-
Amazon DynamoDB Streams
-
Amazon Kinesis
-
Amazon SQS
-
Amazon MQ and RabbitMQ
-
Amazon MSK
-
Apache Kafka
-
Amazon DocumentDB
The following error handling options are available only for stream sources (DynamoDB and Kinesis):
-
BisectBatchOnFunctionError
– If the function returns an error, split the batch in two and retry. -
DestinationConfig
– Send discarded records to an Amazon SQS queue or Amazon SNS topic. -
MaximumRecordAgeInSeconds
– Discard records older than the specified age. The default value is infinite (-1). When set to infinite (-1), failed records are retried until the record expires -
MaximumRetryAttempts
– Discard records after the specified number of retries. The default value is infinite (-1). When set to infinite (-1), failed records are retried until the record expires. -
ParallelizationFactor
– Process multiple batches from each shard concurrently.
For information about which configuration parameters apply to each event source, see the following topics.
-
Amazon DynamoDB Streams
-
Amazon Kinesis
-
Amazon SQS
-
Amazon MQ and RabbitMQ
-
Amazon MSK
-
Apache Kafka
-
Amazon DocumentDB
Servers
- https://lambda.{region}.amazonaws.com
- https://lambda.{region}.amazonaws.com.cn
Path parameters
Name | Type | Required | Description |
---|---|---|---|
UUID |
String | Yes |
The identifier of the event source mapping. |
Request headers
Name | Type | Required | Description |
---|---|---|---|
X-Amz-Content-Sha256 |
String | No | |
X-Amz-Credential |
String | No | |
Content-Type |
String | Yes |
The media type of the request body.
Default value: "application/json" |
X-Amz-Date |
String | No | |
X-Amz-Algorithm |
String | No | |
X-Amz-SignedHeaders |
String | No | |
X-Amz-Security-Token |
String | No | |
X-Amz-Signature |
String | No |
Request body fields
Name | Type | Required | Description |
---|---|---|---|
DocumentDBEventSourceConfig |
Object | No |
Specific configuration settings for a DocumentDB event source. |
DocumentDBEventSourceConfig.CollectionName |
String | No |
The name of the collection to consume within the database. If you do not specify a collection, Lambda consumes all collections. |
DocumentDBEventSourceConfig.DatabaseName |
String | No |
The name of the database to consume within the DocumentDB cluster. |
DocumentDBEventSourceConfig.FullDocument |
String | No |
Determines what DocumentDB sends to your event stream during document update operations. If set to UpdateLookup, DocumentDB sends a delta describing the changes, along with a copy of the entire document. Otherwise, DocumentDB sends only a partial document that contains the changes. Possible values:
|
BisectBatchOnFunctionError |
Boolean | No |
(Kinesis and DynamoDB Streams only) If the function returns an error, split the batch in two and retry. |
DestinationConfig |
Object | No |
A configuration object that specifies the destination of an event after Lambda processes it. |
FunctionName |
String | No |
The name of the Lambda function. Name formats
The length constraint applies only to the full ARN. If you specify only the function name, it's limited to 64 characters in length. |
BatchSize |
Integer | No |
The maximum number of records in each batch that Lambda pulls from your stream or queue and sends to your function. Lambda passes all of the records in the batch to the function in a single call, up to the payload limit for synchronous invocation (6 MB).
|
MaximumBatchingWindowInSeconds |
Integer | No |
The maximum amount of time, in seconds, that Lambda spends gathering records before invoking the function. You can configure For streams and Amazon SQS event sources, the default batching window is 0 seconds. For Amazon MSK, Self-managed Apache Kafka, Amazon MQ, and DocumentDB event sources, the default batching window is 500 ms. Note that because you can only change Related setting: For streams and Amazon SQS event sources, when you set |
ParallelizationFactor |
Integer | No |
(Kinesis and DynamoDB Streams only) The number of batches to process from each shard concurrently. |
FunctionResponseTypes[] |
Array | No |
(Kinesis, DynamoDB Streams, and Amazon SQS) A list of current response type enums applied to the event source mapping. |
MaximumRetryAttempts |
Integer | No |
(Kinesis and DynamoDB Streams only) Discard records after the specified number of retries. The default value is infinite (-1). When set to infinite (-1), failed records are retried until the record expires. |
FilterCriteria |
Object | No |
An object that contains the filters for an event source. |
FilterCriteria.Filters[] |
Array | No |
A list of filters. |
ScalingConfig |
Object | No |
(Amazon SQS only) The scaling configuration for the event source. To remove the configuration, pass an empty value. |
ScalingConfig.MaximumConcurrency |
Integer | No |
Limits the number of concurrent instances that the Amazon SQS event source can invoke. |
SourceAccessConfigurations[] |
Array | No |
An array of authentication protocols or VPC components required to secure your event source. |
SourceAccessConfigurations[].URI |
String | No |
The value for your chosen configuration in |
SourceAccessConfigurations[].Type |
String | No |
The type of authentication protocol, VPC components, or virtual host for your event source. For example:
Possible values:
|
MaximumRecordAgeInSeconds |
Integer | No |
(Kinesis and DynamoDB Streams only) Discard records older than the specified age. The default value is infinite (-1). |
TumblingWindowInSeconds |
Integer | No |
(Kinesis and DynamoDB Streams only) The duration in seconds of a processing window for DynamoDB and Kinesis Streams event sources. A value of 0 seconds indicates no tumbling window. |
Enabled |
Boolean | No |
When true, the event source mapping is active. When false, Lambda pauses polling and invocation. Default: True |
How to start integrating
- Add HTTP Task to your workflow definition.
- Search for the API you want to integrate with and click on the name.
- This loads the API reference documentation and prepares the Http request settings.
- Click Test request to test run your request to the API and see the API's response.