python连接redis集群如何释放内存_python 的 redis 库，连接池怎么用：python连接redis集群...

python怎么连接redis

以前的问题 可以参考http://www.cnblogs.com/valleylord/p/3524918.html?utm_source=tuicool

python怎么测试与redis的连接

Redis端：192.168.100.132；port=6379

Redis端：192.168.100.132

客户端操作：

安装python支持redis;

tar zxvf redis-2.9.1.tar.gz

cd redis-2.9.1

python setup.py install

服务端启动redis

/root/redis-2.2.12/src/redis-server

客户端测试：

[rootmaster ~]# python

>>> import redis

>>> r = redis.Redis(host='192.168.100.132',port=6379,db=0) //#如果设置码，就加上password=密码

>>> r.set('name','lansgg')

True

>>> r.get('name')

'lansgg'

>>> r.exists('name') //#看是否存在这个键值

True

>>> r.delete('name')

1

>>> r.dbsize() //#库里有多少key，多少条数据

0L

>>> r.set('name','lansgg')

True

>>> r.flushdb() // #删除当前数据库的所有数据

True

>>> r.get('name')

>>> r.set('name','lansgg')

True

>>> r.set('wm','leo')

True

>>> r.set('tt','coffee')

True

>>> r.keys() // # 列出所有键值。

['tt', 'wm', 'name']

>>> r.save() // #强行把数据库保存到硬盘。保存时阻塞

True

>>> r.dbsize()

3L

>>> dir(r)

['RESPONSE_CALLBACKS', '__class__', '__contains__', '__delattr__', '__delitem__', '__dict__', '__doc__', '__format__', '__getattribute__', '__getitem__', '__hash__', '__init__', '__module__', '__new__', '__reduce__', '__reduce_ex__', '__repr__', '__setattr__', '__setitem__', '__sizeof__', '__str__', '__subclasshook__', '__weakref__', '_zaggregate', 'append', 'bgrewriteaof', 'bgsave', 'bitcount', 'bitop', 'blpop', 'brpop', 'brpoplpush', 'client_getname', 'client_kill', 'client_list', 'client_setname', 'config_get', 'config_resetstat', 'config_set', 'connection_pool', 'dbsize', 'debug_object', 'decr', 'delete', 'dump', 'echo', 'eval', 'evalsha', 'execute_command', 'exists', 'expire', 'expireat', 'flushall', 'flushdb', 'from_url', 'get', 'getbit', 'getrange', 'getset', 'hdel', 'hexists', 'hget', 'hgetall', 'hincrby', 'hincrbyfloat', 'hkeys', 'hlen', 'hmget', 'hmset', 'hscan', 'hset', 'hsetnx', 'hvals', 'incr', 'incrby', 'incrbyfloat', 'info', 'keys', 'lastsave', 'lindex', 'linsert', 'llen', 'lock', 'lpop', 'lpush', 'lpushx', 'lrange', 'lrem', 'lset', 'ltrim', 'mget', 'move', 'mset', 'msetnx', 'object', 'parse_response', 'persist', 'pexpire', 'pexpireat', 'ping', 'pipeline', 'psetex', 'pttl', 'publish', 'pubsub', 'randomkey', 'register_script', 'rename', 'renamenx', 'response_callbacks', 'restore', 'rpop', 'rpoplpush', 'rpush', 'rpushx', 'sadd', 'save', 'scan', 'scard', 'script_exists', 'script_flush', 'script_kill', 'script_load', 'sdiff', 'sdiffstore', 'sentinel', 'sentinel_get_master_addr_by_name', 'sentinel_masters', 'sentinel_sentinels', 'sentinel_slaves', 'set', 'set_response_callback', 'setbit', 'setex', 'setnx', 'setrange', 'shutdown', 'sinter', 'sinterstore', 'sismember', 'slaveof', 'smembers', 'smove', 'sort', 'spop', 'srandmember', 'srem', 'sscan', 'strlen', 'substr', 'sunion', 'sunionstore', 'time', 'transaction', 'ttl', 'type', 'unwatch', 'watch', 'zadd', 'zcard', 'zcount', 'zincrby', 'zinterstore', 'zrange', 'zrangebyscore', 'zrank', 'zrem', 'zremrangebyrank', 'zremrangebyscore', 'zrevrange', 'zrevrangebyscore', 'zrevrank', 'zscan', 'zscore', 'zunionstore']

这只是一个简单的测试，为了测试redis是否正常工作，我们安装是否正确；

python 获取的redis里的数据怎么处理

一取所有Key

[python] view plain copy

# -*- encoding: UTF-8 -*-

__author__ = "Sky"

import redis

pool=redis.ConnectionPool(host='127.0.0.1',port=6379,db=0)

r = redis.StrictRedis(connection_pool=pool)

keys = r.keys()

print type(keys)

print keys

运行结

['fad', '1', '2']

获取所容

[python] view plain copy

import redis

pool = redis.ConnectionPool(host='127.0.0.1', port=6379, db=0)

r = redis.Redis(connection_pool=pool)

pipe = r.pipeline()

pipe_size = 100000

len = 0

key_list = []

print r.pipeline()

keys = r.keys()

for key in keys:

key_list.append(key)

pipe.get(key)

if len

len  = 1

else:

for (k, v) in zip(key_list, pipe.execute()):

print k, v

len = 0

key_list = []

for (k, v) in zip(key_list, pipe.execute()):

print k, v

运行结果：

fad fda

1 e

python怎么将数据写入到redis

如:

import redis

class Database:

def __init__(self):

self.host = 'localhost'

self.port = 6379

def write(self,website,city,year,month,day,deal_number):

try:

key = '_'.join([website,city,str(year),str(month),str(day)])

val = deal_number

r = redis.StrictRedis(host=self.host,port=self.port)

r.set(key,val)

except Exception, exception:

print exception

def read(self,website,city,year,month,day):

try:

key = '_'.join([website,city,str(year),str(month),str(day)])

r = redis.StrictRedis(host=self.host,port=self.port)

value = r.get(key)

print value

return value

except Exception, exception:

print exception

if __name__ == '__main__':

db = Database()

db.write('meituan','beijing',2013,9,1,8000)

db.read('meituan','beijing',2013,9,1)

python 的 redis 库，连接池怎么用

Redis 的连接池是程安、多进程安全的、自动重连的。

你扔 flask.g 之类的全局方当然也行，反正 Redis 总使用连接池(不指定它每次就用一个新的)。显式指定连接池的话差异不大，反正你总是要手动在某个全局的地方存一样东西(连接池对象或者 Redis 对象)。

版权声明：本站所有文章皆为原创，欢迎转载或转发，请保留网站地址和作者信息。