redis3.0的集群已经搭建完了,那么开始用python来操作redis cluster集群试试,但是默认的redis模块已经是不能在使用了。  会提示下面的错误…..

关于python redis-py-cluster操作redis cluster集群原文地址 , http://xiaorui.cc/2015/05/16/python%E4%BD%BF%E7%94%A8redis-py-cluster%E6%93%8D%E4%BD%9Credis-cluster%E9%9B%86%E7%BE%A4/

In [1]: import redis

In [2]: r = redis.StrictRedis(host=’localhost’, port=7000)

In [3]: r.set(‘a’,'a’)
—————————————————————————
ResponseError                             Traceback (most recent call last)
<ipython-input-3-87a61267ce52> in <module>()
—-> 1 r.set(‘a’,'a’)

/usr/local/lib/python2.7/dist-packages/redis/client.pyc in set(self, name, value, ex, px, nx, xx)
   1053         if xx:
   1054             pieces.append(‘XX’)
-> 1055         return self.execute_command(‘SET’, *pieces)
   1056
   1057     def __setitem__(self, name, value):

/usr/local/lib/python2.7/dist-packages/redis/client.pyc in execute_command(self, *args, **options)
    563         try:
    564             connection.send_command(*args)
–> 565             return self.parse_response(connection, command_name, **options)
    566         except (ConnectionError, TimeoutError) as e:
    567             connection.disconnect()

/usr/local/lib/python2.7/dist-packages/redis/client.pyc in parse_response(self, connection, command_name, **options)
    575     def parse_response(self, connection, command_name, **options):
    576         “Parses a response from the Redis server”
–> 577         response = connection.read_response()
    578         if command_name in self.response_callbacks:
    579             return self.response_callbacks[command_name](response, **options)

/usr/local/lib/python2.7/dist-packages/redis/connection.pyc in read_response(self)
    572             raise
    573         if isinstance(response, ResponseError):
–> 574             raise response
    575         return response
    576

ResponseError: MOVED 15495 127.0.0.1:7002


妈蛋的,pip install redis-py-cluster    作者貌似pypi的版本有些旧,不能用….  提示StrictRedisCluster 无法找到….  github上的代码和pypi确实不太一样…..    可以把源码git clone下来,然后python setup.py install 安装最近的代码.


这么看来  ASK/MOVE 是没有问题的,不像原版的redis python那样,出现move error的问题…   

貌似redis-py-cluster 不支持事务(watch multi exec) , 有些蛋疼。 

In [10]: pipe = rc.pipeline()

In [11]: pipe.watch(‘xiaorui.cc’)
—————————————————————————
RedisClusterException                     Traceback (most recent call last)
<ipython-input-11-a39f0a5f9fa7> in <module>()
—-> 1 pipe.watch(‘xiaorui.cc’)

/root/redis-py-cluster/rediscluster/pipeline.pyc in watch(self, *names)
    266
    267     def watch(self, *names):
–> 268         raise RedisClusterException(“method watch() is not implemented”)
    269
    270     def unwatch(self):

RedisClusterException: method watch() is not implemented



对于python redis cluster模块就先这样吧,后续如遇到一些奇怪的问题和用法会更新此文章的….







对Python及运维开发感兴趣的朋友可以加QQ群 : 478476595 !!!
{ 2000人qq大群内有各厂大牛,常组织线上分享及沙龙,对高性能及分布式场景感兴趣同学欢迎加入该QQ群 }

另外如果大家觉得文章对你有些作用!   帮忙点击广告. 一来能刺激我写博客的欲望,二来好维护云主机的费用.
如果想赏钱,可以用微信扫描下面的二维码. 另外再次标注博客原地址  xiaorui.cc  ……   感谢!
暂无相关产品

发表评论