SqsTarget
- class aws_cdk.aws_pipes_targets_alpha.SqsTarget(queue, *, input_transformation=None, message_deduplication_id=None, message_group_id=None)
Bases:
object
(experimental) A EventBridge Pipes target that sends messages to an SQS queue.
- Stability:
experimental
- ExampleMetadata:
infused
Example:
# source_queue: sqs.Queue # target_queue: sqs.Queue pipe_target = targets.SqsTarget(target_queue) pipe = pipes.Pipe(self, "Pipe", source=SomeSource(source_queue), target=pipe_target )
- Parameters:
queue (
IQueue
) –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
Methods
- bind(pipe)
(experimental) Bind this target to a pipe.
- Parameters:
pipe (
IPipe
) –- Stability:
experimental
- Return type:
- grant_push(grantee)
(experimental) Grant the pipe role to push to the target.
- Parameters:
grantee (
IRole
) –- Stability:
experimental
- Return type:
None
Attributes
- target_arn
(experimental) The ARN of the target resource.
- Stability:
experimental