python 操作redis

Posted 2021-01-11 python成长中

from redis import Redis


cache = Redis(host=\'192.168.0.101\',port=6379,password=\'wuheng\')

#1.操作字符串
# cache.set(\'username\',\'zhiliao\')

# cache.delete(\'username\')

# cache.set(\'password\',\'wuheng\')

# cache.delete(\'username\')#删除key

#列表的操作
# cache.lpush(\'languages\',\'java\')#从左到右的插入列表，
# cache.lpush(\'languages\',\'python\')
# cache.lpush(\'languages\',\'php\')
#
# print(cache.lrange(\'languages\',0,-1))#获取列表中所有元素

#集合的操作
# cache.sadd(\'team\',\'11\')
# cache.sadd(\'team\',\'123\')

# print(cache.smembers(\'team\'))#获取集合中所有元素

#哈希的操作
# cache.hset(\'website\',\'baidu\',\'www.baidu.com\')
# cache.hset(\'website\',\'mokw\',\'www.mokewang.com\')
# print(cache.hgetall(\'website\'))#获取所有字典中的值
# {b\'baidu\': b\'www.baidu.com\', b\'mokw\': b\'www.mokewang.com\'}

#事物的操作
#定义一个管道和一个实例
# pip = cache.pipeline()
# pip.set(\'username\',\'zhiliao\')
# pip.set(\'username\',\'123456\')
# pip.execute()#执行这个事物，事物要摸执行，不然全部不执行

#发布与订阅
#异步发送邮件的功能
ps = cache.pubsub()#创建一个订阅的对象
ps.subscribe(\'email\')#,订阅email频道
while True:
    # ps.listen()#监听 返回值是一个生成器
    for item in ps.listen():
        print(item)#这个时候就可以处理一些操作
        if item[\'type\'] == \'message\' and item[\'channel\'] == b\'email\':
            data = item[\'data\']
            print(data.decode(\'utf-8\'))

from redis import Redis


cache = Redis(host=\'192.168.0.101\',port=6379,password=\'wuheng\')

#发布三个邮件消息

for x in range(3):
    cache.publish(\'email\',\'[e-mail]\')