SqsTargetParameters

class aws_cdk.aws_pipes_targets_alpha.SqsTargetParameters(*, input_transformation=None, message_deduplication_id=None, message_group_id=None)

Bases: object

(experimental) SQS target properties.

Parameters:

• input_transformation (Optional[IInputTransformation]) – (experimental) The input transformation to apply to the message before sending it to the target. Default: none

• message_deduplication_id (Optional[str]) – (experimental) This parameter applies only to FIFO (first-in-first-out) queues. The token used for deduplication of sent messages. Default: none

• message_group_id (Optional[str]) – (experimental) The FIFO message group ID to use as the target. Default: none

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
)

Attributes

input_transformation

(experimental) The input transformation to apply to the message before sending it to the target.

Default:

none

See:

https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargetparameters.html#cfn-pipes-pipe-pipetargetparameters-inputtemplate

Stability:

experimental

message_deduplication_id

(experimental) This parameter applies only to FIFO (first-in-first-out) queues.

The token used for deduplication of sent messages.

Default:

none

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargetsqsqueueparameters.html#cfn-pipes-pipe-pipetargetsqsqueueparameters-messagededuplicationid

Stability:

experimental

message_group_id

(experimental) The FIFO message group ID to use as the target.

Default:

none

See:

http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipetargetsqsqueueparameters.html#cfn-pipes-pipe-pipetargetsqsqueueparameters-messagegroupid

Stability:

experimental