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: - nonemessage_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: - nonemessage_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=SqsSource(source_queue), target=pipe_target )
Attributes
- input_transformation
(experimental) The input transformation to apply to the message before sending it to the target.
- message_deduplication_id
(experimental) This parameter applies only to FIFO (first-in-first-out) queues.
The token used for deduplication of sent messages.
- message_group_id
(experimental) The FIFO message group ID to use as the target.