python操作redis集群

strictRedis对象方法用于连接redis

指定主机地址，port与服务器连接，默认db是0，redis默认数据库有16个，在配置文件中指定database 16

上代码

、对redis的单实例进行连接操作
根据不同的实例方法，与redis的命令对应

python3

>>>import redis

>>>r = redis.StrictRedis(host='localhost', port=, db=,password='root')

>>>r.set('lufei', 'guojialei')

True

>>>r.get('lufei')

'bar'


增删改查

>>> conn=redis.StrictRedis()
>>>
>>>
>>> conn.set("name1","alex1")
True
>>> conn.set("name2","wupeiqi")
True
>>>
>>>
>>> conn.set("name1","alex666")
True
>>> conn.delete("name2","name1")
2

>>> conn.keys()
[b'name3', b'name2', b'name1']

--------------------

、sentinel集群连接并操作

[root@db01 ~]# redis-server /data//redis.conf

[root@db01 ~]# redis-server /data//redis.conf

[root@db01 ~]# redis-server /data//redis.conf

[root@db01 ~]# redis-sentinel /data//sentinel.conf &

--------------------------------

## 导入redis sentinel包

>>> from redis.sentinel import Sentinel

##指定sentinel的地址和端口号

>>> sentinel = Sentinel([('localhost', )], socket_timeout=0.1)

##测试，获取以下主库和从库的信息

>>> sentinel.discover_master('mymaster')

>>> sentinel.discover_slaves('mymaster')

##配置读写分离

#写节点

>>> master = sentinel.master_for('mymaster', socket_timeout=0.1)

#读节点

>>> slave = sentinel.slave_for('mymaster', socket_timeout=0.1)

###读写分离测试   key

>>> master.set('oldboy', '')

>>> slave.get('oldboy')

''

----------------------

redis cluster的连接并操作（python2..2以上版本才支持redis cluster，我们选择的是3.）

https://github.com/Grokzen/redis-py-cluster

、python连接rediscluster集群测试

使用

python3

>>> from rediscluster import StrictRedisCluster

>>> startup_nodes = [{"host": "127.0.0.1", "port": ""}]

### Note: decode_responses must be set to True when used with python3

>>> rc = StrictRedisCluster(startup_nodes=startup_nodes, decode_responses=True)

>>> rc.set("foo", "bar")

True

>>>

'bar'

----------------------

redis存储session

django-redis-sessions 官方文档：https://pypi.org/project/django-redis-sessions/

dango-redis 官方文档：http://niwinz.github.io/django-redis/latest/#_configure_as_cache_backend

安装模块

安装模块

 pip3 install django-redis-sessions
或者

pip3 install django-redis

本文这里用的是django 2.0语法，创建django项目

django-admin startproject mydjango

修改settings.py文件

写入

CACHES = {

    "default": {

        "BACKEND": "django_redis.cache.RedisCache",

        "LOCATION": "redis://127.0.0.1:6379/0",

        "OPTIONS": {

            "CLIENT_CLASS": "django_redis.client.DefaultClient",

            "PASSWORD": "",

#             "PARSER_CLASS": "redis.connection.HiredisParser",

#             "SOCKET_TIMEOUT": ,

#             "CONNECTION_POOL_CLASS_KWARGS": {

#                 "max_connections": ,

#             }

        }

    }

}

#SESSION_COOKIE_AGE =  *  #设置session过期时间为30分钟

SESSION_ENGINE = 'django.contrib.sessions.backends.cache'

创建app01

django-admin startapp app01

编写session视图函数 app01.views

from django.shortcuts import render,HttpResponse

def set_session(request):

    request.session['username']='chaoge'

    request.session['age']=

    return HttpResponse("设置sesson成功")

def get_session(request):

    username=request.session['username']

    age = request.session['age']

    return HttpResponse(username+":"+str(age))

添加url路由

vim mydjango/urls.py

from django.contrib import admin

from django.urls import path

from app01 import views

urlpatterns = [

    path('set_session/',views.set_session),

    path('get_session/',views.get_session),

    path('admin/', admin.site.urls),

]

确保启动redis服务端，默认方式启动

redis-server &

redis-cli 连接无误
发送ping命令得到pong即可

启动django

python3 manage.py runserver 0.0.0.0:

访问视图，设置一条session信息，存入redis数据库

访问视图，获取session信息

检查redis数据库，是否存在一条key

127.0.0.1:> keys *

) ":1:django.contrib.sessions.cachep220moqvxclz2hyjqmbybqs3v8ck2i39"

获取这个key的值

127.0.0.1:6379> get :1:django.contrib.sessions.cachep220moqvxclz2hyjqmbybqs3v8ck2i39
"\x80\x04\x95!\x00\x00\x00\x00\x00\x00\x00}\x94(\x8c\busername\x94\x8c\x06chaoge\x94\x8c\x03age\x94K\x12u."