Начало работы с Message Queue

Выполним основные действия с использованием AWS CLI — одного из инструментов для работы с Message Queue.

1. Установите AWS CLI — утилиту командной строки для работы с Message Queue.

2. Создайте сервисный аккаунт с ролью editor.

3. Создайте статические ключи доступа. Надежно сохраните идентификатор и секретный ключ. После того, как вы закроете окно, параметры секретного ключа станут недоступны.

4. Настройте AWS CLI:

   1. Запустите интерактивную настройку профиля:

      aws configure
      

   2. Укажите полученный ранее идентификатор ключа сервисного аккаунта:

      AWS Access Key ID [****************ver_]: <идентификатор_ключа_сервисного_аккаунта>
      

   3. Укажите полученный ранее секретный ключ сервисного аккаунта:

      AWS Secret Access Key [****************w5lb]: <секретный_ключ_сервисного_аккаунта>
      

   4. Укажите имя региона по умолчанию ru-central1:

      Default region name [ru-central1]: ru-central1
      

   5. Укажите формат выходных данных по умолчанию json:

      Default output format [None]: json
      

   6. Чтобы посмотреть текущие настройки профиля, выполните команду:

      aws configure list
      

      Результат:

            Name                    Value             Type    Location
            ----                    -----             ----    --------
         profile                <not set>             None    None
      access_key     ****************aBc1 shared-credentials-file
      secret_key     ****************DeF2 shared-credentials-file
          region              ru-central1      config-file    ~/.aws/config
      

5. Создайте очередь с именем sample-queue:

   AWS CLI

   Консоль управления

   aws sqs create-queue \
     --queue-name <имя_очереди> \
     --endpoint <эндпоинт>
   

   Где:

   • --queue-name — имя создаваемой очереди, например sample-queue.
   • --endpoint — эндпоинт в значении https://message-queue.api.cloud.yandex.net/.

   Результат:

   {
       "QueueUrl": "https://message-queue.api.cloud.yandex.net/aoeaql9r10cd********/000000000000********/sample-queue"
   }
   

   Сохраните полученный URL очереди, он понадобится позднее.

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

   2. Выберите сервис Message Queue.

   3. Нажмите кнопку Создать очередь.

   4. Укажите имя очереди: sample-queue.

      Имя может содержать строчные буквы латинского алфавита, цифры, дефисы и подчеркивания. Имя очереди FIFO должно заканчиваться суффиксом .fifo. Длина имени не должна превышать 80 символов.

   5. Выберите тип Стандартная. Не изменяйте другие настройки.

   6. Нажмите кнопку Создать.

   7. Откройте созданную очередь.

   8. На вкладке Обзор в блоке Общая информация скопируйте URL очереди, он понадобится позднее.

6. Отправьте сообщение в созданную очередь, используя сохраненный ранее URL очереди:

   AWS CLI

   aws sqs send-message \
     --message-body "<текст_сообщения>" \
     --endpoint <эндпоинт> \
     --queue-url <URL_очереди>
   

   Где:

   • --message-body — текст отправляемого в очередь сообщения, например, Hello World.
   • --endpoint — эндпоинт в значении https://message-queue.api.cloud.yandex.net/.
   • --queue-url — URL очереди, в которую будет отправлено сообщение.

   Результат:

   {
       "MD5OfMessageBody": "67e63db14341b5a696596634********",
       "MessageId": "765ff4d2-fa4bc83-6cfcc***-*****"
   }
   

7. Примите сообщение из очереди:

   AWS CLI

   aws sqs receive-message \
     --endpoint <эндпоинт> \
     --queue-url <URL_очереди>
   

   Где:

   • --endpoint — эндпоинт в значении https://message-queue.api.cloud.yandex.net/.
   • --queue-url — URL очереди, из которой нужно получить сообщение.

   Результат:

   {
       "Messages": [
           {
               "MessageId": "948de7-9ec8d787-c*******-*",
               "ReceiptHandle": "EAEggbj********",
               "MD5OfBody": "ed076287532e86365e841e92********",
               "Body": "Hello World",
               "Attributes": {
                   "ApproximateFirstReceiveTimestamp": "15459********",
                   "ApproximateReceiveCount": "1",
                   "SentTimestamp": "15459********",
                   "SenderId": "abcdefkbh72is78********"
               }
           }
       ]
   }
   

   Сохраните значение параметра ReceiptHandle, оно понадобится позднее.

8. Удалите сообщение из очереди.

   Сообщения после обработки следует удалять из очереди, чтобы приложения не обрабатывали их повторно.

   Чтобы удалить принятое из очереди сообщение, используйте сохраненное ранее значение параметра ReceiptHandle:

   AWS CLI

   aws sqs delete-message \
     --endpoint <эндпоинт> \
     --queue-url <URL_очереди>
     --receipt-handle <идентификатор_получения>
   

   Где:

   • --endpoint — эндпоинт в значении https://message-queue.api.cloud.yandex.net/.
   • --queue-url — URL очереди, из которой нужно удалить сообщение.
   • --receipt-handle — сохраненный ранее идентификатор получения сообщения ReceiptHandle.

9. Удалите очередь:

   AWS CLI

   Консоль управления

   aws sqs delete-queue \
     --endpoint <эндпоинт> \
     --queue-url <URL_очереди>
   

   Где:

   • --endpoint — эндпоинт в значении https://message-queue.api.cloud.yandex.net/.
   • --queue-url — URL очереди, которую нужно удалить.

   1. В консоли управления выберите каталог, которому принадлежит очередь.
   2. Выберите сервис Message Queue.
   3. Нажмите значок напротив нужной очереди и выберите Удалить.
   4. В открывшемся окне нажмите кнопку Удалить.