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_state_machine: sfn.IStateMachine


pipe_target = targets.SfnStateMachine(target_state_machine,
    input_transformation=pipes.InputTransformation.from_object({"body": "<$.body>"}),
    invocation_type=targets.StateMachineInvocationType.FIRE_AND_FORGET
)

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