python連接redis：

import redis

r = redis.Redis(host=‘192.168.50.181‘,port=6002)
r.set(‘user_phone_14900000001‘,‘888888‘)
r.get(‘user_phone_14900000001‘)

上面代碼如果只執行一條數據是正常的，如果要用for循環批量更改數據連接redis集群，會報錯redis.exceptions.ResponseError()

解決方案如下：

python連接redis集群：

from rediscluster import StrictRedisCluster

list = [
    
 
‘14900000001‘,
    ‘14900000002‘,
    ‘14900000003‘,
    ‘14900000004‘,
    ‘14900000005‘,
    ‘14900000006‘,
    ‘14900000007‘,
    ‘14900000008‘,
    ‘14900000009‘,
    ‘14900000010‘
]

def redis_cluster(list):
    redis_nodes = [
        {‘host‘:‘192.168.50.39‘,‘port‘:6002},
        {‘host‘:‘192.168.50.181‘,‘port‘: 6002},
    ]

    try:
        redisconn = StrictRedisCluster(startup_nodes=redis_nodes)
    
 
except:
        print(‘error‘)

    for i in range(0,len(list)):
        redisconn.set(‘user_phone_‘+list[i],‘888888‘)
        print(redisconn.get(‘user_phone_‘+list[i]))

redis_cluster(list)

打印結果如下：

b‘888888‘
b‘888888‘
b‘888888‘
b‘888888‘
b‘888888‘
b‘888888‘
b‘888888‘
b‘888888‘
b‘888888‘
b‘888888‘

def redis_cluster():
    redis_nodes 
 
= [
        {‘host‘:‘192.168.50.39‘,‘port‘:6002},
        {‘host‘:‘192.168.50.181‘,‘port‘: 6002},
    ]

    try:
        redisconn = StrictRedisCluster(startup_nodes=redis_nodes)
    except:
        print(‘error‘)

    for i in range(14900000011,14900000021):
        redisconn.set(‘user_phone_‘+str(i),‘888888‘)
        print(redisconn.get(‘user_phone_‘+str(i)))

redis_cluster()

python連接redis，redis集群