使用redis-py的两个类Redis和StrictRedis时遇到的坑

前言:

      今天产品经理说,有几个队列排序的功能不能用了。对比了下以前的代码查到了一个原因,这个比较的坑,总结起来也是自己没好好看文档。 


     redis-py提供两个类Redis和StrictRedis用于实现Redis的命令,StrictRedis用于实现大部分官方的命令,并使用官方的语法和命令(比如,SET命令对应与StrictRedis.set方法)。Redis是StrictRedis的子类,用于向后兼容旧版本的redis-py。 简单说,官方推荐使用StrictRedis方法。 

不推荐Redis类,原因是他和咱们在redis-cli操作有些不一样,主要不一样是下面这三个方面。 

·LREM:参数 ‘num’ 和 ‘value’ 的顺序交换了一下,cli是 lrem queueName 0 ‘string’ 。  这里的0时所有的意思。 但是Redis这个类,把控制和string调换了。 

·ZADD:实现时 score 和 value 的顺序不小心弄反了,后来有人用了,就这样了

·SETEX: time 和 value 的顺序反了

.Pool:   连接池

最近爬虫很是凶猛,标注下文章的原文地址: blog.xiaorui.cc

再就是连接池,很多人用Redis的原因是,以前的一些个博客的关于python redis的操作,基本用的时Redis的连接池方式。  其实StrictRedis也是支持的。

Redis的连接池的方法:

pool = redis.ConnectionPool(host='localhost', port=6379, db=0)
r = redis.Redis(connection_pool=pool)

 StrictRedis的连接池的实现方式:

In [4]: pool = redis.ConnectionPool(host='127.0.0.1', port=6379)

In [5]: r = redis.StrictRedis(connection_pool=pool)

看下官方的创建redis的时候,都可以添加什么参数。 

class redis.StrictRedis(host='localhost', port=6379, db=0, password=None, socket_timeout=None, connection_pool=None, charset='utf-8', errors='strict', decode_responses=False, unix_socket_path=None)
Implementation of the Redis protocol.

This abstract class provides a Python interface to all Redis commands and an implementation of the Redis protocol.

Connection and Pipeline derive from this, implementing how the commands are sent and received to the Redis server

另外的再说下redis的对于有些编码入库的问题,redis的连接附加的参数里面,默认编码是utf-8,但是如果你非要用GBK那就需要指明你的chardet和decode_responses为True 。 

class  redis.StrictRedis (host='localhost', port=6379, db=0, password=None, socket_timeout=None,connection_pool=None,  charset='GBK ' , errors='strict',  decode_responses=True)


嗯,剩下的就没什么了 。以后要好好的看文档哈。

更新, 今天又遇到这问题了… 

#xiaorui.cc
  redis.zadd('timer_scheduler', json.dumps(urlbody), score)
  File "/usr/local/lib/python2.7/site-packages/redis/client.py", line 1574, in zadd
    return self.execute_command('ZADD', name, *pieces)
  File "/usr/local/lib/python2.7/site-packages/redis/client.py", line 565, in execute_command
    return self.parse_response(connection, command_name, **options)
  File "/usr/local/lib/python2.7/site-packages/redis/client.py", line 577, in parse_response
    response = connection.read_response()
  File "/usr/local/lib/python2.7/site-packages/redis/connection.py", line 574, in read_response
    raise response
ResponseError: value is not a valid float

很明显,顺序不对…  ResponseError: value is not a valid float  ,字符串跟score反了…


大家觉得文章对你有些作用! 如果想赏钱,可以用微信扫描下面的二维码,感谢!
另外再次标注博客原地址  xiaorui.cc

13 Responses

  1. joyes 2016年10月24日 / 下午2:31

    你好 能发下官方文档的地址吗

  2. 江志 2016年10月24日 / 下午2:30

    你好 能发下官方文档的地址吗

  3. 江志 2016年10月24日 / 下午2:14

    你好 能发下官方文档的地址吗

  4. 刘立坤 2016年8月9日 / 下午2:50

    哈哈 zadd的坑我踩了 想想也挺搞笑

  5. bury 2016年6月8日 / 上午10:05

    又搜到峰云哥了~

  6. 张家小文哥 2016年3月31日 / 下午4:27

    博主,请问一下connectionpool 中check_pid的作用,在什么情况下会起作用?

  7. 张家小文哥 2016年3月31日 / 下午4:24

    博主,我一直不清楚connectionpool中check_pid的作用,在哪些情况下这个会起作用?

    • 峰云就她了 2016年6月11日 / 上午10:05

      check_pid是为了保证redis 连接安全性, 在多进程环境下他会独立一个pool

  8. 感抑渤82 2015年10月29日 / 上午1:54

    交流交流好啊!博主真厉害

发表评论

邮箱地址不会被公开。 必填项已用*标注