|
|
@@ -54,9 +54,14 @@ class InitView(View):
|
|
|
key = request_dict.get('key', None)
|
|
|
value = request_dict.get('value', None)
|
|
|
|
|
|
+ import rediscluster
|
|
|
+ from rediscluster import ClusterConnectionPool
|
|
|
password = '012bzaKUhleHc2645465'
|
|
|
- pool = redis.ConnectionPool(host='10.60.1.113', password=password, port=6379, db=0, sentinel=True)
|
|
|
- r = redis.Redis(connection_pool=pool)
|
|
|
+ startup_nodes = [
|
|
|
+ {"host": "10.60.1.113", "port": 6379},
|
|
|
+ ]
|
|
|
+ pool = ClusterConnectionPool(startup_nodes=startup_nodes, password=password)
|
|
|
+ r = rediscluster.RedisCluster(connection_pool=pool)
|
|
|
r.ping()
|
|
|
r.set(name=key, value=value, ex=60)
|
|
|
redis_value = r.get(name=key)
|
