基于python实现操作redis及消息队列
195 浏览量
2020-09-08
19:13:34
上传
评论
收藏 54KB PDF 举报
基于基于python实现操作实现操作redis及消息队列及消息队列
主要介绍了基于python操作redis及消息队列,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一
定的参考学习价值,需要的朋友可以参考下
操作操作 redis
import redis
redisPool = redis.ConnectionPool(host='192.168.100.50', port=6379, db=8)
redis= redis.Redis(connection_pool=redisPool)
redis.set('key','values')
redis.get('com')
redis.append('keys','values')
redis.delete('keys')
print(redis.getset('name','Mike')) #赋值name为Mike并返回上一次的value
print(redis.mget(['name','age'])) #输出name键和age键的value
print(redis.setnx('newname','james')) #如果键值不存在，则赋值
print(redis.mset({'name1':'smith','name2':'curry'})) #批量赋值
print(redis.msetnx({'name3':'ltf','name4':'lsq'})) #不存在才批量赋值
print(redis.incr('age',1)) #age对应的value 加1
print(redis.decr('age',5)) #age对应的value 减5
print(redis.append('name4','is a sb')) #在name4的value后追加 is a sb 返回字符串长度
print(redis.substr('name',1,4)) #截取键 name
print(redis.sadd('tags','Book','Tea','Coffee')) #返回集合长度 3
print(redis.srem('tags','Book')) #返回删除的数据个数
print(redis.spop('tags')) #随机删除并返回该元素
print(redis.smove('tags','tags1','Coffee'))
print(redis.scard('tags')) # 获取tags集合的元素个数
print(redis.sismember('tags', 'Book')) # 判断Book是否在tags的集合中
print(redis.sinter('tags', 'tags1')) # 返回集合tags和集合tags1的交集
print(redis.sunion('tags', 'tags1')) # 返回集合tags和集合tags1的并集
print(redis.sdiff('tags', 'tags1')) # 返回集合tags和集合tags1的差集
print(redis.smembers('tags')) # 返回集合tags的所有元素
print(redis.hset('price','cake',5)) # 向键名为price的散列表添加映射关系，返回1 即添加的映射个数
print(redis.hsetnx('price','book',6)) # 向键名为price的散列表添加映射关系，返回1 即添加的映射个数
print(redis.hget('price', 'cake')) # 获取键名为cake的值 返回5
print(redis.hmset('price',{'banana':2,'apple':3,'pear':6,'orange':7})) #批量添加映射
print(redis.hmget('price', ['apple', 'orange'])) # 查询apple和orange的值 输出 b'3',b'7'
print(redis.hincrby('price','apple',3)) #apple映射加3 为6
print(redis.hexists('price', 'banana')) # 在price中banana是否存在 返回True
print(redis.hdel('price','banana')) #从price中删除banana 返回1
print(redis.hlen('price')) # 输出price的长度
print(redis.hkeys('price')) # 输出所有的映射键名
print(redis.hvals('price')) # 输出所有的映射键值
print(redis.hgetall('price')) # 输出所有的映射键对
print(redis.rpush('list',1,2,3)) #向键名为list的列表尾部添加1,2,3 返回长度
print(redis.lpush('list',0)) #向键名为list的列表头部添加0 返回长度
print(redis.llen('list')) #返回列表的长度
print(redis.lrange('list',1,3)) #返回起始索引为1 终止索引为3的索引范围对应的列表
print(redis.lindex('list',1)) #返回索引为1的元素-value
print(redis.lset('list',1,5)) #将list的列表索引为1的重新赋值为5
print(redis.lpop('list')) #删除list第一个元素
print(redis.rpop('list')) #删除list最后一个元素
print(redis.blpop('list')) #删除list第一个元素
print(redis.brpop('list')) #删除最后一个元素
print(redis.rpoplpush('list','list1')) #删除list的尾元素并将其添加到list1的头部
消息队列使用例子消息队列使用例子
import redis
import json
redisPool = redis.ConnectionPool(host='192.168.100.50', port=6379, db=8)
client = redis.Redis(connection_pool=redisPool)
# 顺序插入五条数据到redis队列，sort参数是用来验证弹出的顺序
while True:
num = 0
for i in range(0, 100):
num = num + 1
# params info
params_dict = {"name": f"test {num}", "sort":num}
client.rpush("test", json.dumps(params_dict))
资源评论
weixin_38670186
- 粉丝: 8
- 资源: 945
最新资源
- cmake编译OpenCV4.8.0+opencv-contrib4.8.0过程中手动下载资源
- Oracle单实例自动化安装Shell脚本
- 【Axure资源】web网页端高复用组件库, 包括下拉菜单文件上传穿梭框日期城市选择器
- 西门子 S120驱动 SIEMENS 6SL3120-1TE21-8AA0 VER-A 存储器备份
- 鱼骨时间轴demo【JQuery版本】
- windows zmq环境搭建安装包
- 分布式DeviceProfile部件是设备硬件能力和系统软件特征的管理器
- ticbo tib-rv-dotnet-reference.pdf
- Docker入门视频课程（通俗易懂）
- ubuntu18.04.6离线安装nginx安装包，包含zlib-openssl-pcre等
资源上传下载、课程学习等过程中有任何疑问或建议，欢迎提出宝贵意见哦~我们会及时处理！
点击此处反馈
