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_topic: sns.Topic


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

pipe = pipes.Pipe(self, "Pipe",
    source=SqsSource(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