tarosky/k8s-redis-ha

Kubernetes高可用Redis镜像

本镜像基于Kubernetes最新特性实现高可用Redis服务，包含镜像及示例配置，主要使用以下特性：

• StatefulSet
• Init Container

环境要求

• Kubernetes 1.6及以上集群
• Redis 3.2版本

快速部署

若已拥有Kubernetes集群，可通过以下命令部署高可用Redis：

console
kubectl create -f example/

执行后将创建redis-sentinel服务、statefulset，redis-server服务、statefulset及console pod。

访问Redis

可通过console pod访问Redis服务：

console
kubectl exec -ti console -- /bin/bash
root@console:# export MASTER_IP="$(redis-cli -h redis-sentinel -p 26379 sentinel get-master-addr-by-name mymaster | head -1)"
root@console:# export SERVER_PASS="_redis-server._tcp.redis-server.default.svc.cluster.local"
root@console:# redis-cli -h "${MASTER_IP}" -a "${SERVER_PASS}" set foo bar
root@console:# redis-cli -h redis-server -a "${SERVER_PASS}" get foo

密码用于防止不同Redis集群在特定情况下合并。

扩缩容操作

支持像普通Deployment资源一样扩缩容Redis服务器和哨兵：

console
kubectl scale --replicas=5 statefulset/redis-sentinel
kubectl scale --replicas=5 statefulset/redis-server

扩缩容后，Redis集群的预期可用从节点数量会自动重置。

Python示例代码

通过console pod运行Python代码访问Redis：

console
kubectl exec -ti console -- ipython

python
from docker.xuanyuan.run/redis import StrictRedis
from docker.xuanyuan.run/redis.sentinel import Sentinel

sentinel = Sentinel([
    ('redis-sentinel-0.redis-sentinel.default.svc.cluster.local', 26379),
    ('redis-sentinel-1.redis-sentinel.default.svc.cluster.local', 26379),
    ('redis-sentinel-2.redis-sentinel.default.svc.cluster.local', 26379)
], socket_timeout=0.1)

master = sentinel.master_for(
    'mymaster',
    password='_redis-server._tcp.redis-server.default.svc.cluster.local',
    socket_timeout=0.1
)

slave = sentinel.slave_for(
    'mymaster',
    password='_redis-server._tcp.redis-server.default.svc.cluster.local',
    socket_timeout=0.1
)

master.set('foo', 'bar')
slave.get('foo')

运行测试脚本

console
pyvenv .venv
source .venv/bin/activate
pip install -r test/requirements.txt

执行测试命令：

console
KUBE_NAMESPACE='{{你的命名空间}}' nosetests test/test.py