LambdaEnrichment

class aws_cdk.aws_pipes_enrichments_alpha.LambdaEnrichment(lambda_, *, input_transformation=None)

Bases: object

(experimental) A Lambda enrichment for a pipe.

Stability:: experimental
ExampleMetadata:: infused

Example:

# source_queue: sqs.Queue
# target_queue: sqs.Queue

# enrichment_function: lambda.Function


enrichment = enrichments.LambdaEnrichment(enrichment_function)

pipe = pipes.Pipe(self, "Pipe",
    source=SomeSource(source_queue),
    enrichment=enrichment,
    target=SomeTarget(target_queue)
)

Parameters:

lambda –
input_transformation (Optional[InputTransformation]) – (experimental) The input transformation for the enrichment. Default: - None

Stability:

experimental

Methods

bind(pipe)

(experimental) Bind this enrichment to a pipe.

Parameters:

pipe (IPipe) –

Stability:

experimental

Return type:

EnrichmentParametersConfig

grant_invoke(pipe_role)

(experimental) Grant the pipes role to invoke the enrichment.

Parameters:

pipe_role (IRole) –

Stability:

experimental

Return type:

None

Attributes

enrichment_arn

(experimental) The ARN of the enrichment resource.

Length Constraints: Minimum length of 0. Maximum length of 1600.

Stability:: experimental