Использование Managed Redis® как брокера сообщений

Перед началом работы

1. Зарегистрируйтесь в личном кабинете Cloud.ru.

   Если вы уже зарегистрированы, войдите под своей учетной записью.

2. Создайте и загрузите SSH-ключ в облако.

Разверните необходимые ресурсы в облаке

1. Название: pub-sub-VPC.

2. Создайте подсеть:

   • Название: pub-sub-subnet.

   • Адрес: 10.10.1.0/24.

   • VPC: pub-sub-VPC.

• отображается сеть pub-sub-VPC;

• количество подсетей — 1;

• подсеть pub-sub-subnet доступна.

1. Создайте виртуальную машину со следующими параметрами:

   • Название: pub-sub.

   • Образ: Публичные → Ubuntu 22.04.

   • Метод аутентификации: SSH-ключ и пароль.

   • SSH-ключ: ваш SSH-ключ.

   • Пароль: ваш пароль.

   • Имя хоста: pub-sub.

   • Подключить публичный IP: включено.

   • Тип IP-адреса: Прямой.

   • Группы безопасности: SSH-access_ru.AZ-1.

   • Подсеть: pub-sub-subnet.

   • Гарантированная доля vCPU: 10%.

   • vCPU: 1.

   • RAM: 1.

1. Создайте кластер Managed Redis со следующими параметрами:

   • Название кластера у—кажите pub-sub.

   • Версия Redis: v7.0.5.

   • vCPU: 2.

   • RAM: 4.

   • Подсеть: pub-sub-subnet.

Настройте окружение на виртуальной машине

1. Подключитесь к виртуальной машине pub-sub через серийную консоль по инструкции.

2. Активируйте сетевой интерфейс по инструкции:

   sudo cloud-init clean
   sudo cloud-init init
   
   

3. Подключитесь к виртуальной машине pub-sub по SSH по инструкции.

4. Обновите систему и установите необходимые пакеты:

   sudo apt update && sudo apt upgrade -y
   sudo apt install -y python3 python3-venv python3-pip
   
   

Разработайте сервисы publisher и subscriber

1. Создайте директорию «pubsub» и перейдите в неё:

   mkdir pubsub
   cd pubsub
   
   

2. Создайте файл publisher.py и вставьте в него следующий код:

   nano publisher.py
   
   

   Содержимое файла:

   import argparse
   import json
   import os
   import sys
   import uuid
   from datetime import datetime, timezone
   
   import redis
   from dotenv import load_dotenv
   
   def build_payload(message: str) -> str:
      """Return JSON-encoded message with id and timestamp."""
      return json.dumps(
         {
               "id": str(uuid.uuid4()),
               "timestamp": datetime.now(timezone.utc).isoformat(),
               "message": message,
         }
      )
   
   def main() -> None:
      load_dotenv()
   
      parser = argparse.ArgumentParser(description="Publish a message to Redis.")
      parser.add_argument(
         "message",
         nargs="?",
         help="Message text; if omitted you will be prompted.",
      )
      parser.add_argument(
         "--channel",
         default=os.getenv("CHANNEL", "messages"),
         help="Redis Pub/Sub channel name (default: messages)",
      )
      args = parser.parse_args()
   
      msg_text = args.message or input("Enter your message: ")
   
      redis_url = os.getenv("REDIS_URL", "redis://localhost:6379/0")
      try:
         r = redis.from_url(redis_url)
         sent = r.publish(args.channel, build_payload(msg_text))
      except redis.ConnectionError as exc:
         print(f"Redis connection failed: {exc}", file=sys.stderr)
         sys.exit(1)
   
      print(
         f"Published to channel '{args.channel}' "
         f"(delivered to {sent} subscriber[s])."
      )
   
   if __name__ == "__main__":
      main()
   
   

3. Создайте файл subscriber.py и вставьте в него следующий код:

   nano subscriber.py
   
   

   Содержимое файла:

   import argparse
   import json
   import os
   import sys
   
   import redis
   from dotenv import load_dotenv
   
   def pretty_print(raw: bytes) -> None:
      """Attempt to pretty-print a JSON message; fall back to raw bytes."""
      try:
         obj = json.loads(raw)
         print(json.dumps(obj, indent=2))
      except json.JSONDecodeError:
         print(f"[non-JSON] {raw!r}")
   
   def main() -> None:
      load_dotenv()
   
      parser = argparse.ArgumentParser(description="Subscribe to a Redis channel.")
      parser.add_argument(
         "--channel",
         default=os.getenv("CHANNEL", "messages"),
         help="Redis Pub/Sub channel name (default: messages)",
      )
      args = parser.parse_args()
   
      redis_url = os.getenv("REDIS_URL", "redis://localhost:6379/0")
      try:
         r = redis.from_url(redis_url)
         pubsub = r.pubsub(ignore_subscribe_messages=True)
         pubsub.subscribe(args.channel)
      except redis.ConnectionError as exc:
         print(f"Redis connection failed: {exc}", file=sys.stderr)
         sys.exit(1)
   
      print(f"Subscribed to '{args.channel}'. Waiting for messages…  (Ctrl+C to quit)")
      try:
         for message in pubsub.listen():
               if message and message.get("type") == "message":
                  pretty_print(message["data"])
      except KeyboardInterrupt:
         print("\nExiting subscriber.")
   
   if __name__ == "__main__":
      main()
   
   

4. Создайте файл requirements.txt и вставьте следующее содержимое:

   nano requirements.txt
   
   

   Содержимое файла:

   redis==6.2.0
   python-dotenv==1.0.1
   
   

5. Создайте файл .env и вставьте следующее содержимое:

   nano .env
   
   

   Содержимое файла:

   REDIS_URL=redis://:<REDIS_PASSWORD>@<REDIS_IP>:6379
   
   

   Где:

   • <REDIS_IP> — IP-адрес сервиса Managed Redis®.

   • <REDIS_PASSWORD> — пароль от кластера Managed Redis®.

6. Создайте и активируйте виртуальное окружение:

   python3 -m venv venv
   source venv/bin/activate
   
   

7. Установите зависимости:

   pip install -r requirements.txt
   
   

Протестируйте работу очереди сообщений с Managed Redis®

1. Запустите сервис subscriber:

   python subscriber.py
   
   

2. Откройте новое окно терминала, не закрывая текущий терминал.

3. Подключитесь к виртуальной машине pub-sub по SSH по инструкции.

4. Перейдите в директорию с сервисами:

   cd pubsub
   
   

5. Активируйте виртуальное окружение:

   source venv/bin/activate
   
   

6. Отправьте сообщение в очередь:

   python publisher.py "Hello from Ubuntu!"
   
   

7. Переключитесь обратно на терминал 1 и проверьте, что сообщение успешно получено.

Удалите доступ по SSH для виртуальной машины

1. В личном кабинете перейдите в сервис «Виртуальные машины» и выберите машину pub-sub, созданную в шаге 1.

2. Перейдите в раздел Сетевые параметры.

3. Нажмите на Изменить группы безопасности для публичного IP-адреса.

4. Удалите группу «SSH-access_ru».

5. Нажмите Сохранить.

6. Попробуйте подключиться к виртуальной машине по SSH по инструкции и убедитесь, что доступ отсутствует.

Что дальше