DynamicInput

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

Bases: object

(experimental) Dynamic variables that can be used in the input transformation.

Stability:: experimental
ExampleMetadata:: infused

Example:

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


target_input_transformation = pipes.InputTransformation.from_object({
    "static_field": "static value",
    "dynamic_field": pipes.DynamicInput.from_event_path("$.body.payload"),
    "pipe_variable": pipes.DynamicInput.pipe_name
})

pipe = pipes.Pipe(self, "Pipe",
    pipe_name="MyPipe",
    source=SqsSource(source_queue),
    target=SqsTarget(target_queue, {
        "input_transformation": target_input_transformation
    })
)

Methods

resolve(_context)

(experimental) Produce the Token’s value at resolution time.

Parameters:

_context (IResolveContext) –

Stability:

experimental

Return type:

Any

to_json()

(experimental) Return a JSON representation of a dynamic input.

Stability:: experimental
Return type:: str

to_string()

(experimental) Return a string representation of a dynamic input.

Stability:: experimental
Return type:: str

Attributes

creation_stack

(experimental) The creation stack of this resolvable which will be appended to errors thrown during resolution.

This may return an array with a single informational element indicating how to get this property populated, if it was skipped for performance reasons.

Stability:: experimental

display_hint

(experimental) Human readable display hint about the event pattern.

Stability:: experimental

enrichment_arn = <aws_cdk.aws_pipes_alpha.DynamicInput object>

event = <aws_cdk.aws_pipes_alpha.DynamicInput object>

event_ingestion_time = <aws_cdk.aws_pipes_alpha.DynamicInput object>

event_json = <aws_cdk.aws_pipes_alpha.DynamicInput object>

pipe_arn = <aws_cdk.aws_pipes_alpha.DynamicInput object>

pipe_name = <aws_cdk.aws_pipes_alpha.DynamicInput object>

source_arn = <aws_cdk.aws_pipes_alpha.DynamicInput object>

target_arn = <aws_cdk.aws_pipes_alpha.DynamicInput object>

Static Methods

classmethod from_event_path(path)

(experimental) Value from the event payload at jsonPath.

Parameters:

path (str) –

Stability:

experimental

Return type:

DynamicInput