Python 使用 Redis

参考文档:

http://redis.cn/clients.html#python

https://github.com/andymccurdy/redis-py

安装Redis

  1. sudo pip install redis

简单的redis操作

字符串string操作

  1. In [1]: import redis
  2. In [2]: r = redis.StrictRedis(host='localhost', port=6379, db=0, password='foobared')
  3. In [3]: r.set('foo', 'bar')
  4. Out[3]: True
  5. In [4]: r.get('foo')
  6. Out[4]: 'bar'
  7. In [5]: r['foo']
  8. Out[5]: 'bar'
  9. In [6]: r.delete('foo')
  10. Out[6]: 1
  11. In [7]: r.get('foo')
  12. In [8]:r.sadd('setmy','a')
  13. Out[8]: 1
  14. In [10]: r.s('setmy')
  15. r.sadd r.setex
  16. r.save r.setnx
  17. r.scan r.setrange
  18. r.scan_iter r.shutdown
  19. r.scard r.sinter
  20. r.script_exists r.sinterstore
  21. r.script_flush r.sismember
  22. r.script_kill r.slaveof
  23. r.script_load r.slowlog_get
  24. r.sdiff r.slowlog_len
  25. r.sdiffstore r.slowlog_reset
  26. r.sentinel r.smembers
  27. r.sentinel_get_master_addr_by_name r.smove
  28. r.sentinel_master r.sort
  29. r.sentinel_masters r.spop
  30. r.sentinel_monitor r.srandmember
  31. r.sentinel_remove r.srem
  32. r.sentinel_sentinels r.sscan
  33. r.sentinel_set r.sscan_iter
  34. r.sentinel_slaves r.strlen
  35. r.set r.substr
  36. r.set_response_callback r.sunion
  37. r.setbit r.sunionstore
  38. In [10]: r.smembers('setmy')
  39. Out[10]: {'a'}

pipeline操作

管道(pipeline)是redis在提供单个请求中缓冲多条服务器命令的基类的子类。它通过减少服务器-客户端之间反复的TCP数据库包,从而大大提高了执行批量命令的功能。

  1. >>> p = r.pipeline() --创建一个管道
  2. >>> p.set('hello','redis')
  3. >>> p.sadd('faz','baz')
  4. >>> p.incr('num')
  5. >>> p.execute()
  6. [True, 1, 1]
  7. >>> r.get('hello')
  8. 'redis'

管道的命令可以写在一起,如:

  1. >>> p.set('hello','redis').sadd('faz','baz').incr('num').execute()
  2. 1

默认的情况下,管道里执行的命令可以保证执行的原子性,执行pipe = r.pipeline(transaction=False)可以禁用这一特性。

字符串应用场景 – 页面点击数

假定我们对一系列页面需要记录点击次数。例如论坛的每个帖子都要记录点击次数,而点击次数比回帖的次数的多得多。如果使用关系数据库来存储点击,可能存在大量的行级锁争用。所以,点击数的增加使用redis的INCR命令最好不过了。

当redis服务器启动时,可以从关系数据库读入点击数的初始值(1237这个页面被访问了34634次)

  1. >>> r.set("visit:1237:totals",34634)
  2. True

每当有一个页面点击,则使用INCR增加点击数即可。

  1. >>> r.incr("visit:1237:totals")
  2. 34635
  3. >>> r.incr("visit:1237:totals")
  4. 34636

页面载入的时候则可直接获取这个值

  1. >>> r.get ("visit:1237:totals")
  2. '34636'

使用hash类型保存多样化对象

应用场景

比如我们要存储一个用户信息对象数据, 用户的姓名、年龄、生日等,修改某一项的值。Redis的Hash结构可以使像在数据库中Update一个属性一样只修改某一项属性值。

11.1. Python 使用 Redis  - 图1

Redis的Hash实际是内部存储的Value为一个HashMap,并提供了直接存取这个Map成员的接口,如下图:

  1. >>> r.hset('users:jdoe', 'name', "John Doe")
  2. 1L
  3. >>> r.hset('users:jdoe', 'age', 25)
  4. 1L
  5. >>> r.hset('users:jdoe', 'birthday', '19910101')
  6. 1L
  7. >>> r.hgetall('users:jdoe')
  8. {'age': '26', 'birthday': '19910101', 'name': 'John Doe'}
  9. >>> r.hkeys('users:jdoe')
  10. ['name', 'age', 'birthday']
  11. >>> r.hincrby('users:jdoe', 'age', 1)
  12. 26L
  13. >>> r.hgetall('users:jdoe')
  14. >>> {'age': '26', 'birthday': '19910101', 'name': 'John Doe'}

Set集合应用场景 – 社交圈子数据

在社交网站中,每一个圈子(circle)都有自己的用户群。通过圈子可以找到有共同特征(比如某一体育活动、游戏、电影等爱好者)的人。当一个用户加入一个或几个圈子后,系统可以向这个用户推荐圈子中的人。我们定义这样两个圈子,并加入一些圈子成员。

  1. >>> r.sadd('circle:game:lol','user:debugo')
  2. 1
  3. >>> r.sadd('circle:game:lol','user:leo')
  4. 1
  5. >>> r.sadd('circle:game:lol','user:Guo')
  6. 1
  7. >>> r.sadd('circle:soccer:InterMilan','user:Guo')
  8. 1
  9. >>> r.sadd('circle:soccer:InterMilan','user:Levis')
  10. 1
  11. >>> r.sadd('circle:soccer:InterMilan','user:leo')
  12. 1

获得某一圈子的成员

  1. >>> r.smembers('circle:game:lol')
  2. set(['user:Guo', 'user:debugo', 'user:leo'])

可以使用集合运算来得到几个圈子的共同成员:

  1. >>> r.sinter('circle:game:lol', 'circle:soccer:InterMilan')
  2. set(['user:Guo', 'user:leo'])
  3. >>> r.sunion('circle:game:lol', 'circle:soccer:InterMilan')
  4. set(['user:Levis', 'user:Guo', 'user:debugo', 'user:leo'])

推荐游戏soccer:InterMilan

  1. >>> r.sdiff('circle:game:lol','circle:soccer:InterMilan')
  2. >>> {'user:debugo'}

原文: https://piaosanlang.gitbooks.io/redis/content/02day/section2.1.html