SQSClient

Index > SQS > SQSClient

Auto-generated documentation for SQS type annotations stubs module mypy-boto3-sqs.

SQSClient

Type annotations and code completion for boto3.client("sqs"). boto3 documentation

# SQSClient usage example

from boto3.session import Session
from mypy_boto3_sqs.client import SQSClient

def get_sqs_client() -> SQSClient:
    return Session().client("sqs")

Exceptions

boto3 client exceptions are generated in runtime. This class provides code completion for boto3.client("sqs").exceptions structure.

# Exceptions.exceptions usage example

client = boto3.client("sqs")

try:
    do_something(client)
except (
    client.exceptions.BatchEntryIdsNotDistinct,
    client.exceptions.BatchRequestTooLong,
    client.exceptions.ClientError,
    client.exceptions.EmptyBatchRequest,
    client.exceptions.InvalidAddress,
    client.exceptions.InvalidAttributeName,
    client.exceptions.InvalidAttributeValue,
    client.exceptions.InvalidBatchEntryId,
    client.exceptions.InvalidIdFormat,
    client.exceptions.InvalidMessageContents,
    client.exceptions.InvalidSecurity,
    client.exceptions.KmsAccessDenied,
    client.exceptions.KmsDisabled,
    client.exceptions.KmsInvalidKeyUsage,
    client.exceptions.KmsInvalidState,
    client.exceptions.KmsNotFound,
    client.exceptions.KmsOptInRequired,
    client.exceptions.KmsThrottled,
    client.exceptions.MessageNotInflight,
    client.exceptions.OverLimit,
    client.exceptions.PurgeQueueInProgress,
    client.exceptions.QueueDeletedRecently,
    client.exceptions.QueueDoesNotExist,
    client.exceptions.QueueNameExists,
    client.exceptions.ReceiptHandleIsInvalid,
    client.exceptions.RequestThrottled,
    client.exceptions.ResourceNotFoundException,
    client.exceptions.TooManyEntriesInBatchRequest,
    client.exceptions.UnsupportedOperation,
) as e:
    print(e)

# Exceptions.exceptions type checking example

from mypy_boto3_sqs.client import Exceptions

def handle_error(exc: Exceptions.BatchEntryIdsNotDistinct) -> None:
    ...

Methods

can_paginate

Type annotations and code completion for boto3.client("sqs").can_paginate method. boto3 documentation

# can_paginate method definition

def can_paginate(
    self,
    operation_name: str,
) -> bool:
    ...

generate_presigned_url

Type annotations and code completion for boto3.client("sqs").generate_presigned_url method. boto3 documentation

# generate_presigned_url method definition

def generate_presigned_url(
    self,
    ClientMethod: str,
    Params: Mapping[str, Any] = ...,
    ExpiresIn: int = 3600,
    HttpMethod: str = ...,
) -> str:
    ...

add_permission

Adds a permission to a queue for a specific principal.

Type annotations and code completion for boto3.client("sqs").add_permission method. boto3 documentation

# add_permission method definition

def add_permission(
    self,
    *,
    QueueUrl: str,
    Label: str,
    AWSAccountIds: Sequence[str],
    Actions: Sequence[str],
) -> EmptyResponseMetadataTypeDef:  # (1)
    ...

1. See EmptyResponseMetadataTypeDef

# add_permission method usage example with argument unpacking

kwargs: AddPermissionRequestTypeDef = {  # (1)
    "QueueUrl": ...,
    "Label": ...,
    "AWSAccountIds": ...,
    "Actions": ...,
}

parent.add_permission(**kwargs)

1. See AddPermissionRequestTypeDef

cancel_message_move_task

Cancels a specified message movement task.

Type annotations and code completion for boto3.client("sqs").cancel_message_move_task method. boto3 documentation

# cancel_message_move_task method definition

def cancel_message_move_task(
    self,
    *,
    TaskHandle: str,
) -> CancelMessageMoveTaskResultTypeDef:  # (1)
    ...

1. See CancelMessageMoveTaskResultTypeDef

# cancel_message_move_task method usage example with argument unpacking

kwargs: CancelMessageMoveTaskRequestTypeDef = {  # (1)
    "TaskHandle": ...,
}

parent.cancel_message_move_task(**kwargs)

1. See CancelMessageMoveTaskRequestTypeDef

change_message_visibility

Changes the visibility timeout of a specified message in a queue to a new value.

Type annotations and code completion for boto3.client("sqs").change_message_visibility method. boto3 documentation

# change_message_visibility method definition

def change_message_visibility(
    self,
    *,
    QueueUrl: str,
    ReceiptHandle: str,
    VisibilityTimeout: int,
) -> EmptyResponseMetadataTypeDef:  # (1)
    ...

1. See EmptyResponseMetadataTypeDef

# change_message_visibility method usage example with argument unpacking

kwargs: ChangeMessageVisibilityRequestTypeDef = {  # (1)
    "QueueUrl": ...,
    "ReceiptHandle": ...,
    "VisibilityTimeout": ...,
}

parent.change_message_visibility(**kwargs)

1. See ChangeMessageVisibilityRequestTypeDef

change_message_visibility_batch

Changes the visibility timeout of multiple messages.

Type annotations and code completion for boto3.client("sqs").change_message_visibility_batch method. boto3 documentation

# change_message_visibility_batch method definition

def change_message_visibility_batch(
    self,
    *,
    QueueUrl: str,
    Entries: Sequence[ChangeMessageVisibilityBatchRequestEntryTypeDef],  # (1)
) -> ChangeMessageVisibilityBatchResultTypeDef:  # (2)
    ...

1. See Sequence[ChangeMessageVisibilityBatchRequestEntryTypeDef]
2. See ChangeMessageVisibilityBatchResultTypeDef

# change_message_visibility_batch method usage example with argument unpacking

kwargs: ChangeMessageVisibilityBatchRequestTypeDef = {  # (1)
    "QueueUrl": ...,
    "Entries": ...,
}

parent.change_message_visibility_batch(**kwargs)

1. See ChangeMessageVisibilityBatchRequestTypeDef

create_queue

Creates a new standard or FIFO queue.

Type annotations and code completion for boto3.client("sqs").create_queue method. boto3 documentation

# create_queue method definition

def create_queue(
    self,
    *,
    QueueName: str,
    Attributes: Mapping[QueueAttributeNameType, str] = ...,  # (1)
    tags: Mapping[str, str] = ...,
) -> CreateQueueResultTypeDef:  # (2)
    ...

1. See Mapping[QueueAttributeNameType, str]
2. See CreateQueueResultTypeDef

# create_queue method usage example with argument unpacking

kwargs: CreateQueueRequestTypeDef = {  # (1)
    "QueueName": ...,
}

parent.create_queue(**kwargs)

1. See CreateQueueRequestTypeDef

delete_message

Deletes the specified message from the specified queue.

Type annotations and code completion for boto3.client("sqs").delete_message method. boto3 documentation

# delete_message method definition

def delete_message(
    self,
    *,
    QueueUrl: str,
    ReceiptHandle: str,
) -> EmptyResponseMetadataTypeDef:  # (1)
    ...

1. See EmptyResponseMetadataTypeDef

# delete_message method usage example with argument unpacking

kwargs: DeleteMessageRequestTypeDef = {  # (1)
    "QueueUrl": ...,
    "ReceiptHandle": ...,
}

parent.delete_message(**kwargs)

1. See DeleteMessageRequestTypeDef

delete_message_batch

Deletes up to ten messages from the specified queue.

Type annotations and code completion for boto3.client("sqs").delete_message_batch method. boto3 documentation

# delete_message_batch method definition

def delete_message_batch(
    self,
    *,
    QueueUrl: str,
    Entries: Sequence[DeleteMessageBatchRequestEntryTypeDef],  # (1)
) -> DeleteMessageBatchResultTypeDef:  # (2)
    ...

1. See Sequence[DeleteMessageBatchRequestEntryTypeDef]
2. See DeleteMessageBatchResultTypeDef

# delete_message_batch method usage example with argument unpacking

kwargs: DeleteMessageBatchRequestTypeDef = {  # (1)
    "QueueUrl": ...,
    "Entries": ...,
}

parent.delete_message_batch(**kwargs)

1. See DeleteMessageBatchRequestTypeDef

delete_queue

Deletes the queue specified by the QueueUrl, regardless of the queue's contents.

Type annotations and code completion for boto3.client("sqs").delete_queue method. boto3 documentation

# delete_queue method definition

def delete_queue(
    self,
    *,
    QueueUrl: str,
) -> EmptyResponseMetadataTypeDef:  # (1)
    ...

1. See EmptyResponseMetadataTypeDef

# delete_queue method usage example with argument unpacking

kwargs: DeleteQueueRequestTypeDef = {  # (1)
    "QueueUrl": ...,
}

parent.delete_queue(**kwargs)

1. See DeleteQueueRequestTypeDef

get_queue_attributes

Gets attributes for the specified queue.

Type annotations and code completion for boto3.client("sqs").get_queue_attributes method. boto3 documentation

# get_queue_attributes method definition

def get_queue_attributes(
    self,
    *,
    QueueUrl: str,
    AttributeNames: Sequence[QueueAttributeFilterType] = ...,  # (1)
) -> GetQueueAttributesResultTypeDef:  # (2)
    ...

1. See Sequence[QueueAttributeFilterType]
2. See GetQueueAttributesResultTypeDef

# get_queue_attributes method usage example with argument unpacking

kwargs: GetQueueAttributesRequestTypeDef = {  # (1)
    "QueueUrl": ...,
}

parent.get_queue_attributes(**kwargs)

1. See GetQueueAttributesRequestTypeDef

get_queue_url

The GetQueueUrl API returns the URL of an existing Amazon SQS queue.

Type annotations and code completion for boto3.client("sqs").get_queue_url method. boto3 documentation

# get_queue_url method definition

def get_queue_url(
    self,
    *,
    QueueName: str,
    QueueOwnerAWSAccountId: str = ...,
) -> GetQueueUrlResultTypeDef:  # (1)
    ...

1. See GetQueueUrlResultTypeDef

# get_queue_url method usage example with argument unpacking

kwargs: GetQueueUrlRequestTypeDef = {  # (1)
    "QueueName": ...,
}

parent.get_queue_url(**kwargs)

1. See GetQueueUrlRequestTypeDef

list_dead_letter_source_queues

Returns a list of your queues that have the RedrivePolicy queue attribute configured with a dead-letter queue.

Type annotations and code completion for boto3.client("sqs").list_dead_letter_source_queues method. boto3 documentation

# list_dead_letter_source_queues method definition

def list_dead_letter_source_queues(
    self,
    *,
    QueueUrl: str,
    NextToken: str = ...,
    MaxResults: int = ...,
) -> ListDeadLetterSourceQueuesResultTypeDef:  # (1)
    ...

1. See ListDeadLetterSourceQueuesResultTypeDef

# list_dead_letter_source_queues method usage example with argument unpacking

kwargs: ListDeadLetterSourceQueuesRequestTypeDef = {  # (1)
    "QueueUrl": ...,
}

parent.list_dead_letter_source_queues(**kwargs)

1. See ListDeadLetterSourceQueuesRequestTypeDef

list_message_move_tasks

Gets the most recent message movement tasks (up to 10) under a specific source queue.

Type annotations and code completion for boto3.client("sqs").list_message_move_tasks method. boto3 documentation

# list_message_move_tasks method definition

def list_message_move_tasks(
    self,
    *,
    SourceArn: str,
    MaxResults: int = ...,
) -> ListMessageMoveTasksResultTypeDef:  # (1)
    ...

1. See ListMessageMoveTasksResultTypeDef

# list_message_move_tasks method usage example with argument unpacking

kwargs: ListMessageMoveTasksRequestTypeDef = {  # (1)
    "SourceArn": ...,
}

parent.list_message_move_tasks(**kwargs)

1. See ListMessageMoveTasksRequestTypeDef

list_queue_tags

List all cost allocation tags added to the specified Amazon SQS queue.

Type annotations and code completion for boto3.client("sqs").list_queue_tags method. boto3 documentation

# list_queue_tags method definition

def list_queue_tags(
    self,
    *,
    QueueUrl: str,
) -> ListQueueTagsResultTypeDef:  # (1)
    ...

1. See ListQueueTagsResultTypeDef

# list_queue_tags method usage example with argument unpacking

kwargs: ListQueueTagsRequestTypeDef = {  # (1)
    "QueueUrl": ...,
}

parent.list_queue_tags(**kwargs)

1. See ListQueueTagsRequestTypeDef

list_queues

Returns a list of your queues in the current region.

Type annotations and code completion for boto3.client("sqs").list_queues method. boto3 documentation

# list_queues method definition

def list_queues(
    self,
    *,
    QueueNamePrefix: str = ...,
    NextToken: str = ...,
    MaxResults: int = ...,
) -> ListQueuesResultTypeDef:  # (1)
    ...

1. See ListQueuesResultTypeDef

# list_queues method usage example with argument unpacking

kwargs: ListQueuesRequestTypeDef = {  # (1)
    "QueueNamePrefix": ...,
}

parent.list_queues(**kwargs)

1. See ListQueuesRequestTypeDef

purge_queue

Deletes available messages in a queue (including in-flight messages) specified by the QueueURL parameter.

Type annotations and code completion for boto3.client("sqs").purge_queue method. boto3 documentation

# purge_queue method definition

def purge_queue(
    self,
    *,
    QueueUrl: str,
) -> EmptyResponseMetadataTypeDef:  # (1)
    ...

1. See EmptyResponseMetadataTypeDef

# purge_queue method usage example with argument unpacking

kwargs: PurgeQueueRequestTypeDef = {  # (1)
    "QueueUrl": ...,
}

parent.purge_queue(**kwargs)

1. See PurgeQueueRequestTypeDef

receive_message

Retrieves one or more messages (up to 10), from the specified queue.

Type annotations and code completion for boto3.client("sqs").receive_message method. boto3 documentation

# receive_message method definition

def receive_message(
    self,
    *,
    QueueUrl: str,
    AttributeNames: Sequence[QueueAttributeFilterType] = ...,  # (1)
    MessageSystemAttributeNames: Sequence[MessageSystemAttributeNameType] = ...,  # (2)
    MessageAttributeNames: Sequence[str] = ...,
    MaxNumberOfMessages: int = ...,
    VisibilityTimeout: int = ...,
    WaitTimeSeconds: int = ...,
    ReceiveRequestAttemptId: str = ...,
) -> ReceiveMessageResultTypeDef:  # (3)
    ...

1. See Sequence[QueueAttributeFilterType]
2. See Sequence[MessageSystemAttributeNameType]
3. See ReceiveMessageResultTypeDef

# receive_message method usage example with argument unpacking

kwargs: ReceiveMessageRequestTypeDef = {  # (1)
    "QueueUrl": ...,
}

parent.receive_message(**kwargs)

1. See ReceiveMessageRequestTypeDef

remove_permission

Revokes any permissions in the queue policy that matches the specified Label parameter.

Type annotations and code completion for boto3.client("sqs").remove_permission method. boto3 documentation

# remove_permission method definition

def remove_permission(
    self,
    *,
    QueueUrl: str,
    Label: str,
) -> EmptyResponseMetadataTypeDef:  # (1)
    ...

1. See EmptyResponseMetadataTypeDef

# remove_permission method usage example with argument unpacking

kwargs: RemovePermissionRequestTypeDef = {  # (1)
    "QueueUrl": ...,
    "Label": ...,
}

parent.remove_permission(**kwargs)

1. See RemovePermissionRequestTypeDef

send_message

Delivers a message to the specified queue.

Type annotations and code completion for boto3.client("sqs").send_message method. boto3 documentation

# send_message method definition

def send_message(
    self,
    *,
    QueueUrl: str,
    MessageBody: str,
    DelaySeconds: int = ...,
    MessageAttributes: Mapping[str, MessageAttributeValueUnionTypeDef] = ...,  # (1)
    MessageSystemAttributes: Mapping[MessageSystemAttributeNameForSendsType, MessageSystemAttributeValueTypeDef] = ...,  # (2)
    MessageDeduplicationId: str = ...,
    MessageGroupId: str = ...,
) -> SendMessageResultTypeDef:  # (3)
    ...

1. See Mapping[str, MessageAttributeValueUnionTypeDef]
2. See Mapping[Literal['AWSTraceHeader'], MessageSystemAttributeValueTypeDef]
3. See SendMessageResultTypeDef

# send_message method usage example with argument unpacking

kwargs: SendMessageRequestTypeDef = {  # (1)
    "QueueUrl": ...,
    "MessageBody": ...,
}

parent.send_message(**kwargs)

1. See SendMessageRequestTypeDef

send_message_batch

You can use SendMessageBatch to send up to 10 messages to the specified queue by assigning either identical or different values to each message (or by not assigning values at all).

Type annotations and code completion for boto3.client("sqs").send_message_batch method. boto3 documentation

# send_message_batch method definition

def send_message_batch(
    self,
    *,
    QueueUrl: str,
    Entries: Sequence[SendMessageBatchRequestEntryTypeDef],  # (1)
) -> SendMessageBatchResultTypeDef:  # (2)
    ...

1. See Sequence[SendMessageBatchRequestEntryTypeDef]
2. See SendMessageBatchResultTypeDef

# send_message_batch method usage example with argument unpacking

kwargs: SendMessageBatchRequestTypeDef = {  # (1)
    "QueueUrl": ...,
    "Entries": ...,
}

parent.send_message_batch(**kwargs)

1. See SendMessageBatchRequestTypeDef

set_queue_attributes

Sets the value of one or more queue attributes, like a policy.

Type annotations and code completion for boto3.client("sqs").set_queue_attributes method. boto3 documentation

# set_queue_attributes method definition

def set_queue_attributes(
    self,
    *,
    QueueUrl: str,
    Attributes: Mapping[QueueAttributeNameType, str],  # (1)
) -> EmptyResponseMetadataTypeDef:  # (2)
    ...

1. See Mapping[QueueAttributeNameType, str]
2. See EmptyResponseMetadataTypeDef

# set_queue_attributes method usage example with argument unpacking

kwargs: SetQueueAttributesRequestTypeDef = {  # (1)
    "QueueUrl": ...,
    "Attributes": ...,
}

parent.set_queue_attributes(**kwargs)

1. See SetQueueAttributesRequestTypeDef

start_message_move_task

Starts an asynchronous task to move messages from a specified source queue to a specified destination queue.

Type annotations and code completion for boto3.client("sqs").start_message_move_task method. boto3 documentation

# start_message_move_task method definition

def start_message_move_task(
    self,
    *,
    SourceArn: str,
    DestinationArn: str = ...,
    MaxNumberOfMessagesPerSecond: int = ...,
) -> StartMessageMoveTaskResultTypeDef:  # (1)
    ...

1. See StartMessageMoveTaskResultTypeDef

# start_message_move_task method usage example with argument unpacking

kwargs: StartMessageMoveTaskRequestTypeDef = {  # (1)
    "SourceArn": ...,
}

parent.start_message_move_task(**kwargs)

1. See StartMessageMoveTaskRequestTypeDef

tag_queue

Add cost allocation tags to the specified Amazon SQS queue.

Type annotations and code completion for boto3.client("sqs").tag_queue method. boto3 documentation

# tag_queue method definition

def tag_queue(
    self,
    *,
    QueueUrl: str,
    Tags: Mapping[str, str],
) -> EmptyResponseMetadataTypeDef:  # (1)
    ...

1. See EmptyResponseMetadataTypeDef

# tag_queue method usage example with argument unpacking

kwargs: TagQueueRequestTypeDef = {  # (1)
    "QueueUrl": ...,
    "Tags": ...,
}

parent.tag_queue(**kwargs)

1. See TagQueueRequestTypeDef

untag_queue

Remove cost allocation tags from the specified Amazon SQS queue.

Type annotations and code completion for boto3.client("sqs").untag_queue method. boto3 documentation

# untag_queue method definition

def untag_queue(
    self,
    *,
    QueueUrl: str,
    TagKeys: Sequence[str],
) -> EmptyResponseMetadataTypeDef:  # (1)
    ...

1. See EmptyResponseMetadataTypeDef

# untag_queue method usage example with argument unpacking

kwargs: UntagQueueRequestTypeDef = {  # (1)
    "QueueUrl": ...,
    "TagKeys": ...,
}

parent.untag_queue(**kwargs)

1. See UntagQueueRequestTypeDef

get_paginator

Type annotations and code completion for boto3.client("sqs").get_paginator method with overloads.

• client.get_paginator("list_dead_letter_source_queues") -> ListDeadLetterSourceQueuesPaginator
• client.get_paginator("list_queues") -> ListQueuesPaginator