python和redis之间的交互

python和redis之间的交互

一. redis模块

安装模块:

pip3 install redis

连接方式:

r = redis.Redis(host=‘localhost‘,port=6379)

连接池:为了节约资源,减少多次连接带来的消耗。

pool=redis.ConnectionPool(host=‘localhost‘,port=6379,decode_responses=True)

二.redis操作

常规操作:

import redis

r = redis.Redis(host=‘localhost‘,port=6379)
r.set(‘foo‘,‘bar‘)

print(r.get(‘foo‘))

连接池:

import redis

pool = redis.ConnectionPool(host=‘localhost‘,port=6379,decode_responses=True)
# 默认设置的值和取得的值都是bytes类型,如果想改为str类型,可以添加decode_responses=True
r1 = redis.Redis(connection_pool=pool)
r2 = redis.Redis(connection_pool=pool)

r1.set(‘name‘,‘jack‘)
print(r1.get(‘name‘))
r2.set(‘age‘,18)
print(r2.get(‘age‘))

print(r1.client_list())
print(r2.client_list())

管道:

import redis,time

r = redis.Redis(host=‘localhost‘,port=6379,decode_responses=True)
pipe = r.pipeline(transaction=True)

pipe.set(‘name1‘,‘Alin‘)
pipe.set(‘name2‘,‘Lnda‘)
pipe.set(‘name3‘,‘Tony‘)
time.sleep(5)
pipe.execute()
print(r.mget(‘name1‘,‘name2‘,‘name3‘))

事务:python可以使用管道来代替事务

import redis,time
import redis.exceptions
r = redis.Redis(host=‘localhost‘,port=6379,decode_responses=True)
pipe = r.pipeline()
print(r.get(‘name1‘))

try:
    pipe.multi()
    pipe.set(‘age1‘,22)
    pipe.set(‘age2‘,23)
    pipe.set(‘age3‘,24)
    time.sleep(5)
    pipe.execute()
    print(r.mget(‘age1‘,‘age2‘,‘age3‘))
except redis.exceptions.WatchError as e:
    print(‘Error‘)

订阅和发布:
发布方:

import redis

r = redis.Redis(host=‘localhost‘,port=6379,decode_responses=True)

while True:
    msg = input(‘echo>>:‘)
    if len(msg) == 0:
        continue
    elif msg == ‘quit‘:
        r.publish(‘cctv1‘,msg)
        break
    else:
        r.publish(‘cctv1‘,msg)

订阅方:

import redis
r = redis.Redis(host=‘localhost‘,port=6379,decode_responses=True)

chan = r.pubsub() #返回一个发布订阅对象
msg_reciver = chan.subscribe(‘cctv1‘) #订阅

msg = chan.parse_response()  # 返回一个确认
print(msg)
print(‘订阅成功,开始接收...‘)

while True:
    msg = chan.parse_response()  #接收消息
    if msg[2] == ‘quit‘:  #格式:类型,频道,消息
        break
    else:
        print(‘>>:‘, msg[2])

原文地址:http://blog.51cto.com/dianel/2146107

时间: 2024-10-10 21:03:52

python和redis之间的交互的相关文章

python之 Redis

Redis redis是一个key-value存储系统.和Memcached类似,它支持存储的value类型相对更多,包括string(字符串).list(链表).set(集合).zset(sorted set --有序集合)和hash(哈希类型).这些数据类型都支持push/pop.add/remove及取交集并集和差集及更丰富的操作,而且这些操作都是原子性的.在此基础上,redis支持各种不同方式的排序.与memcached一样,为了保证效率,数据都是缓存在内存中.区别的是redis会周期性

使用Python操作Redis

1. 安装pyredis 首先安装pip 1 2 3 4 5 6 7 8 <SHELL># apt-get install python-pip ...... <SHELL># pip install --proxy=http://172.1.2.6:8080 redis Downloading redis-2.9.1.tar.gz (62kB): 62kB downloaded Running setup.py (path:/tmp/pip_build_root/redis/se

Redis之Python 使用 Redis

Python 使用 Redis 参考文档: http://redis.cn/clients.html#python https://github.com/andymccurdy/redis-py 安装Redis $ sudo pip install redis 简单的redis操作 字符串string操作 In [1]: import redis In [2]: r = redis.StrictRedis(host='localhost', port=6379, db=0, password='

Python—操作redis

Python操作redis 1.String 操作 redis中的String在在内存中按照一个name对应一个value来存储 set() #在Redis中设置值,默认不存在则创建,存在则修改 r.set('name', 'zhangsan') '''参数: set(name, value, ex=None, px=None, nx=False, xx=False) ex,过期时间(秒) px,过期时间(毫秒) nx,如果设置为True,则只有name不存在时,当前set操作才执行,同setn

【python】redis基本命令和基本用法详解

1.redis连接 redis-py提供两个类Redis和StrictRedis用于实现Redis的命令,StrictRedis用于实现大部分官方的命令, 并使用官方的语法和命令,Redis是StrictRedis的子类,用于向后兼容旧版本的redis-py. import redis 导入redis模块,通过python操作redis 也可以直接在redis主机的服务端操作缓存数据库 r = redis.Redis(host='192.168.19.130', port=6379) host是

Python 操作Redis

redis redis是一个key-value存储系统.和Memcached类似,它支持存储的value类型相对更多,包括string(字符串).list(链表).set(集合).zset(sorted set --有序集合)和hash(哈希类型).这些数据类型都支持push/pop.add/remove及取交集并集和差集及更丰富的操作,而且这些操作都是原子性的.在此基础上,redis支持各种不同方式的排序.与memcached一样,为了保证效率,数据都是缓存在内存中.区别的是redis会周期性

Python连接Redis连接配置

1. 测试连接: Python 2.7.8 (default, Oct 20 2014, 15:05:19) [GCC 4.9.1] on linux2 Type "help", "copyright", "credits" or "license" for more information. >>> import redis >>> redisClient = redis.StrictRe

使用Python操作Redis应用场景

1. 安装pyredis 首先安装pip 1 2 3 4 5 6 7 8 <SHELL># apt-get install python-pip ...... <SHELL># pip install --proxy=http://172.1.2.6:8080 redis Downloading redis-2.9.1.tar.gz (62kB): 62kB downloaded Running setup.py (path:/tmp/pip_build_root/redis/se

属性查找;绑定到对象的方法的特殊之处;对象之间的交互

四 属性查找 类有两种属性:数据属性和函数属性 1. 类的数据属性是所有对象共享的 2. 类的函数属性是绑定给对象用的 #类的数据属性是所有对象共享的,id都一样 print(id(OldboyStudent.school)) print(id(s1.school)) print(id(s2.school)) print(id(s3.school)) ''' 4377347328 4377347328 4377347328 4377347328 ''' #类的函数属性是绑定给对象使用的,obj.