InputTransformation

class aws_cdk.aws_pipes_alpha.InputTransformation(*args: Any, **kwargs)

Bases: object

(experimental) Transform or replace the input event payload.

Stability:: experimental
ExampleMetadata:: infused

Example:

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


pipe_target = targets.SqsTarget(target_queue,
    input_transformation=pipes.InputTransformation.from_object({
        "SomeKey": pipes.DynamicInput.from_event_path("$.body")
    })
)

pipe = pipes.Pipe(self, "Pipe",
    source=SomeSource(source_queue),
    target=pipe_target
)

Methods

bind(pipe)

(experimental) Bind the input transformation to the pipe and returns the inputTemplate string.

Parameters:

pipe (IPipe) –

Stability:

experimental

Return type:

InputTransformationConfig

Static Methods

classmethod from_event_path(json_path_expression)

(experimental) Creates an InputTransformation from a jsonPath expression of the input event.

Parameters:

json_path_expression (str) –

Stability:

experimental

Return type:

InputTransformation

classmethod from_object(input_template)

(experimental) Creates an InputTransformation from a pipe variable.

Parameters:

input_template (Mapping[str, Any]) –

Stability:

experimental

Return type:

InputTransformation

classmethod from_text(input_template)

(experimental) Creates an InputTransformation from a string.

Parameters:

input_template (str) –

Stability:

experimental

Return type:

InputTransformation