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=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:
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:
- classmethod from_object(input_template)
(experimental) Creates an InputTransformation from a pipe variable.
- Parameters:
input_template (
Mapping
[str
,Any
]) –- Stability:
experimental
- Return type:
- classmethod from_text(input_template)
(experimental) Creates an InputTransformation from a string.
- Parameters:
input_template (
str
) –- Stability:
experimental
- Return type: