CreateQueue

Запрос создает новую стандартную очередь или очередь FIFO. В запросе можно передать один или несколько атрибутов.

Атрибут

Attribute.N.Name (ключ)

Attribute.N.Value (значение)

Карта атрибутов с соответствующими значениями.

Ниже перечислены имена, описания и значения специальных параметров запроса, которые CreateQueueиспользует действие:

• DelaySeconds- Время в секундах, на которое задерживается доставка всех сообщений в очереди. Допустимые значения: целое число от 0 до 900 секунд (15 минут). По умолчанию: 0.

• MaximumMessageSize- Максимальное количество байтов, которое может содержать сообщение, прежде чем VK Cloud SQS отклонит его. Допустимые значения: целое число от 1024 байтов (1 КиБ) до 262 144 байта (256 КиБ). По умолчанию: 262144 (256 КБ).

• MessageRetentionPeriod- Продолжительность времени в секундах, в течение которого VK Cloud SQS сохраняет сообщение. Допустимые значения: целое число от 60 секунд (1 минута) до 1 209 600 секунд (14 дней). По умолчанию: 345 600 (4 дня).

• Policy- Политика очереди.

• ReceiveMessageWaitTimeSeconds- Время в секундах, в течение которого действие ожидает прибытия сообщения. Допустимые значения: целое число от 0 до 20 (секунд). По умолчанию: 0. ReceiveMessage

• RedrivePolicy- Строка, которая включает параметры для функции очереди недоставленных сообщений исходной очереди в виде объекта JSON.

  • deadLetterTargetArn- Имя ресурса VK Cloud (ARN) очереди недоставленных сообщений, в которую VK Cloud SQS перемещает сообщения после maxReceiveCountпревышения значения.
  • maxReceiveCount- Сколько раз сообщение доставлялось в исходную очередь до того, как оно было перемещено в очередь недоставленных сообщений. Когда ReceiveCountдля сообщения превышает значение maxReceiveCountдля очереди, VK Cloud SQS перемещает сообщение в очередь недоставленных сообщений.

• VisibilityTimeout- Тайм-аут видимости очереди в секундах. Допустимые значения: целое число от 0 до 43 200 (12 часов). По умолчанию: 30.

Следующие атрибуты применяются только к шифрованию на стороне сервера :

• KmsMasterKeyId- Идентификатор управляемого VK Cloud главного ключа клиента (CMK) для VK Cloud SQS или настраиваемого CMK.
• KmsDataKeyReusePeriodSeconds- Время в секундах, в течение которого VK Cloud SQS может повторно использовать ключ данных для шифрования или расшифровки сообщений перед повторным вызовом VK Cloud KMS. Целое число, представляющее секунды, от 60 секунд (1 минута) до 86 400 секунд (24 часа). По умолчанию: 300 (5 минут). Более короткий период времени обеспечивает лучшую безопасность, но приводит к большему количеству обращений к KMS, за которые может взиматься плата после уровня бесплатного пользования.

Следующие атрибуты применяются только к очередям FIFO (first-in-first-out) :

• FifoQueue- Обозначает очередь как FIFO. Допустимые значения: trueи false. Если вы не укажете FifoQueueатрибут, VK Cloud SQS создаст стандартную очередь. Вы можете указать этот атрибут только во время создания очереди. Вы не можете изменить его для существующей очереди. Когда вы устанавливаете этот атрибут, вы также должны MessageGroupIdявно указать для своих сообщений.

• ContentBasedDeduplication- Включает дедупликацию на основе содержимого. Допустимые значения: trueи false. Обратите внимание на следующее:

  • Каждое сообщение должно иметь уникальный MessageDeduplicationId.

    • Вы можете MessageDeduplicationIdявно указать.
    • Если вы не можете предоставить MessageDeduplicationIdи включить ContentBasedDeduplicationдля своей очереди, VK Cloud SQS использует хэш SHA-256 для генерации с MessageDeduplicationIdиспользованием тела сообщения (но не атрибутов сообщения).
    • Если вы не предоставите MessageDeduplicationIdи очередь не ContentBasedDeduplicationустановлена, действие завершится ошибкой.
    • Если очередь ContentBasedDeduplicationустановлена, вы MessageDeduplicationIdотменяете сгенерированную.

  • Когда ContentBasedDeduplicationдействует, сообщения с идентичным содержимым, отправленные в течение интервала дедупликации, обрабатываются как дубликаты, и доставляется только одна копия сообщения.

  • Если вы отправляете одно сообщение с ContentBasedDeduplicationвключенным, а затем другое сообщение с таким MessageDeduplicationIdже, как и сообщение, созданное для первого MessageDeduplicationId, два сообщения рассматриваются как дубликаты, и доставляется только одна копия сообщения.

Служба возвращает следующий элемент.

QueueUrl

URL-адрес созданной очереди VK Cloud SQS.

Тип: Строка

AWS.SimpleQueueService.QueueDeletedRecently

Вы должны подождать 60 секунд после удаления очереди, прежде чем вы сможете создать другую очередь с тем же именем.

Код состояния HTTP: 400

QueueAlreadyExists

Очередь с таким названием уже существует. VK Cloud SQS возвращает эту ошибку, только если запрос включает атрибуты, значения которых отличаются от значений существующей очереди.

Код состояния HTTP: 400

В следующем примере запроса создается новая очередь с именем MyQueue. Структура AUTHPARAMSзависит от подписи запроса API.

Образец запроса

https://sqs.mcs.mail.ru/
?Action=CreateQueue
&QueueName=MyQueue
&Tag.Key=QueueType
&Tag.Value=Production
&Attribute.1.Name=VisibilityTimeout
&Attribute.1.Value=40
&Expires=2020-10-18T22:52:43PST
&Version=2012-11-05
&AUTHPARAMS

Образец ответа

<CreateQueueResponse>
    <CreateQueueResult>
        <QueueUrl>https://queue.mcs.mail.ru/123456789012/MyQueue</QueueUrl>
    </CreateQueueResult>
    <ResponseMetadata>
        <RequestId>7a62c49f-347e-4fc4-9331-6e8e7a96aa73</RequestId>
    </ResponseMetadata>
</CreateQueueResponse>

В следующем примере создается очередь задержки, которая скрывает каждое сообщение от потребителей в течение первых 45 секунд (пока сообщение находится в очереди), путем вызова действия CreateQueue с атрибутом DelaySeconds, установленным на 45 секунд.

Важно

URL-адреса и имена очередей чувствительны к регистру.

Образец запроса

https://sqs.mcs.mail.ru/123456789012/MyQueue/
?Action=CreateQueue
&QueueName=MyQueue
&Attribute.1.Name=DelaySeconds
&Attribute.1.Value=45
&Expires=2020-12-20T22:52:43PST
&Version=2012-11-05
&AUTHPARAMS