python操作redis

安裝redis-py

sudo pip install redis

連接數據庫

import redis
r = redis.StrictRedis(host='localhost', port=6379, db=0)

注：利用r=reids.Redis(host='localhost', port=6379,db=0)也可以。區別：Redis是StrictRedis的子類，用於向后兼容舊版本的redis-py。官方推薦使用StrictRedis。

簡單redis操作

>>> r.set('name', 'jihite')
True
>>> r.set('score', 100)
True
>>> r.keys()
['score', 'name']
>>> r.get('name')
'jihite'
>>> r.get('score')
'100'
>>> r.delete('score')
1
>>> r.keys()
['name']
>>> r.save()
True
>>> r.keys()
['name']
>>> r.flushdb()
True
>>> r.keys()
[]

pipeline操作

管道是redis在提供單個請求中緩存多條服務器命令的基類的子類，它通過減少服務器-客戶端之間反復的TCP數據庫包，從而大大提高了執行批量命令的性能。

例子

>>> p = r.pipeline()
>>> p.hset('myset', 'name', 'jihite')
Pipeline<ConnectionPool<Connection<host=localhost,port=6379,db=0>>>
>>> p.hset('myset', 'score', 100)
Pipeline<ConnectionPool<Connection<host=localhost,port=6379,db=0>>>
>>> p.hget('myset', 'name')
Pipeline<ConnectionPool<Connection<host=localhost,port=6379,db=0>>>
>>> p.execute()
[1L, 1L, 'jihite']
>>> r.hget('myset', 'name')
'jihite'
>>> r.hget('myset', 'score')
'100'

注：管道命令可以寫在一起，如：

>>> p = r.pipeline()
>>> p.set('name', 'jihite').set('score',100).set('school', 'bupt').get('score').execute()
[True, True, True, '100']

Connection Pools

redis-py通過連接pool來管理連接到Redis Server，默認每一個Redis連接實例會自動創建一個自己的鏈接pool，可以利用一個已經存在在鏈接pool.

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