SendToQueue

class aws_cdk.aws_stepfunctions_tasks.SendToQueue(queue, *, message_body, delay=None, integration_pattern=None, message_deduplication_id=None, message_group_id=None)

Bases: object

A StepFunctions Task to send messages to SQS queue.

A Function can be used directly as a Resource, but this class mirrors integration with other AWS services via a specific class instance.

stability :stability: experimental

__init__(queue, *, message_body, delay=None, integration_pattern=None, message_deduplication_id=None, message_group_id=None)
Parameters
  • queue (IQueue) –

  • props

  • message_body (TaskInput) – The text message to send to the queue.

  • delay (Optional[Duration]) – The length of time, in seconds, for which to delay a specific message. Valid values are 0-900 seconds. Default: Default value of the queue is used

  • integration_pattern (Optional[ServiceIntegrationPattern]) – The service integration pattern indicates different ways to call SendMessage to SQS. The valid value is either FIRE_AND_FORGET or WAIT_FOR_TASK_TOKEN. Default: FIRE_AND_FORGET

  • message_deduplication_id (Optional[str]) – The token used for deduplication of sent messages. Default: Use content-based deduplication

  • message_group_id (Optional[str]) – The tag that specifies that a message belongs to a specific message group. Required for FIFO queues. FIFO ordering applies to messages in the same message group. Default: No group ID

stability :stability: experimental

Return type

None

Methods

bind(_task)

Called when the task object is used in a workflow.

Parameters

_task (Task) –

stability :stability: experimental

Return type

StepFunctionsTaskConfig