Redis: репликация, часть 3 — redis-py и работа с Redis Sentinel из Python

В продолжение постов о настройке и использовании Redis репликации с использованием Redis Sentinel — пример работы из Python.

Предыдущие и последующие посты серии:

1. Redis: репликация, часть 1 — обзор. Replication vs Sharding. Sentinel vs Cluster. Топология Redis.
2. Redis: репликация, часть 2 — Master-Slave репликация, и Redis Sentinel
3. Redis: репликация, часть 4 — написание Ansible роли

Список всех клиентов, в частности Python — redis.io/clients.

Тут используем redis-py.

Сначала пример без Sentinel — просто посмотрим, как работает клиент.

Затем — пример работы через Sentinel.

Рабочее окружение aka Redis replication и сам Redis Sentinel настроены во второй части, тут — только примеры работы из Python.

redis-py и Redis

Устанавливаем на Debian:

Можно из pip — но лучше из нормального репозитория.

Проверяем:

Работает, окей.

В документации находим авторизацию:

Добавляем пароль:

Okay.

redis-py и Redis Sentinel

Тепреь запускаем Sentinel инстансы, если ещё не запущены — и пробуем работать через Redis Sentinel cluster client.

Напомню конфигурацию Sentinel на Redis хостах:

sentinel monitor redis-test 52.58.69.184 6379 2
sentinel down-after-milliseconds redis-test 6001
sentinel failover-timeout redis-test 60000
bind 0.0.0.0
sentinel auth-pass redis-test foobared

После запуска Sentinel-инстанса — он конфиг немного обновляет, и сейчас на хосте redis-1 (который играет роль первого слейва) он выглядит так:

Статус Sentinel-кластера сейчас:

И используем redis-py:

Получаем адрес мастера:

И слейвов:

Для работы с мастером используем метод master_for():

| master_for(self, service_name, redis_class=<class ‘redis.client.StrictRedis’>, connection_pool_class=<class ‘redis.sentinel.SentinelConnectionPool’>, **kwargs)
| Returns a redis client instance for the «service_name« master.

Но если сейчас обратиться к мастеру — он ответит, что мы не авторизованы:

Поэтому при создании master — добавляем password:

Повторяем:

Кроме того — можно получить весь конфиг мастера:

Или в более читабельном виде:

Проверяем добавленный ключ на слейве:

Работа со слейвом из redis-py аналогична мастеру:

Смена мастера и failover Sentinel

Ещё раз проверим мастер сейчас:

И в конце-концов попробуем то, ради чего всё затевалось — останаливаем мастер-ноду Redis на redis-0, который сейчас является мастером:

Или:

(если убить процесс с помощью kill — Sentinel просто перезапустит её).

Проверяем логи Sentinel:

Проверяем в Python:

Мастер обновился — 52.29.101.118 — это хост redis-1.

Проверяем на нём статус:

Проверяем статус Redis-ноды на redis-0, который сейчас стал слейвом:

И пробуем добавить ключ с Python-консоли на redis-0, используя созданный ранее объект master:

Проверяем:

Готово.