查看“Python redis”的源代码

===集群===
 # pip3 install redis-py-cluster
 
 from rediscluster import RedisCluster 
 rnode = [
     {"host": "192.168.0.229", "port": 6379},
     {"host": "192.168.0.229", "port": 6380},
     {"host": "192.168.0.148", "port": 6379},
     {"host": "192.168.0.148", "port": 6380},
     {"host": "192.168.0.249", "port": 6379},
     {"host": "192.168.0.249", "port": 6380}
 ]
 
 rc = RedisCluster(startup_nodes=rnode, decode_responses=True)
 rc.get('test')

==== 管道 ====
Redis 管道技术可以在服务端未响应时，客户端可以继续向服务端发送请求，并最终一次性读取所有服务端的响应。

批量写入时,使用pipeline可以大幅度提升性能
 # 使用 rp 代替 rc
 rp = rc.pipeline(transaction = False)
 # 足够数量的 rp.set 后，提交
 FLAG = rp.execute()

=== 单机 ===
Redis 的单机使用在集群上时，如果读的数据不在连接主机上，会出现错误。
 # pip3 install redis
 import redis
 rs = redis.Redis(host='192.168.0.229', port=6379, password='', db=0)''
 
 # Conn Pool
 #rsp = redis.ConnectionPool(host='192.168.0.229', port=6379, password='', db=0)''
 #rs = redis.Redis(connection_pool = rsp)
 
 # 有效时间 100 secs
 # rs.set('test', 'Hello, World!', 100)
 rs.set('test', 'Hello, World!')
 rs.get('test')


[[分类:Develop]]
[[分类:DB]]
[[分类:Redis]]