前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >python3 交互 redis

python3 交互 redis

作者头像
Devops海洋的渔夫
发布2019-05-30 21:59:17
6330
发布2019-05-30 21:59:17
举报
文章被收录于专栏:Devops专栏

安装redis库

代码语言:javascript
复制
pip3 install redis

示例一

代码语言:javascript
复制
import redis
#创建redis链接对象
r = redis.Redis(host='192.168.196.131',port=6379,decode_responses=True,password='newpwd')
#存储键值对
r.set('site','www.qi.cn')
#获取值
print(r.get('site'))
#指定decode_responses为True,表示输出为字符串
red = redis.StrictRedis(host='192.168.196.131',port=6379,decode_responses=True,password='newpwd')

#默认redis入库编码是utf-8,如果要修改的话,需要指明 charset 和 decode_responsers 为True
#test = redis.StrictRedis(host='localhost', port=6379, db=0, password=None, socket_timeout=None, connection_pool=None, charset='utf-8', errors='strict', decode_responses=False, unix_socket_path=None)
red.lpush('list1','mongdb','redis','mysql')
print(r.lrange('list1',0,-1))
print(r.llen('list1'))

# #output:
# www.qi.cn
# ['mysql', 'redis', 'mongdb']

示例二 - 封装工具类

代码语言:javascript
复制
import redis

class redisHelper():
    def __init__(self):
        # 创建redis链接对象
        self.redis = redis.Redis(host='192.168.196.131', port=6379, decode_responses=True, password='newpwd',db=0)

    def redis_set(self,name,value):
        self.redis.set(name, value)

    def redis_get(self,name):
        return self.redis.get(name)


def main():
    rh = redisHelper()
    rh.redis_set('site','www.baidu.com')
    print(rh.redis_get('site'))

if __name__ == '__main__':
    main()

示例三 - 循环写入redis数据,增加日志打印,获取当前keys数量

代码语言:javascript
复制
import redis
import logging

logger = logging.getLogger()
logger.setLevel(logging.INFO)

logfile = './redis-key.log'
fh = logging.FileHandler(logfile, mode='a')
fh.setLevel(logging.INFO)

ch = logging.StreamHandler()
ch.setLevel(logging.INFO)

formatter = logging.Formatter("%(asctime)s - %(filename)s[line:%(lineno)d] - %(levelname)s: %(message)s")
fh.setFormatter(formatter)
ch.setFormatter(formatter)

logger.addHandler(fh)
logger.addHandler(ch)

class redisHelper():
    def __init__(self):
        # 创建redis链接对象
        self.redis = redis.Redis(host='192.168.196.131', port=6379, decode_responses=True, password='newpwd',db=0)

    def redis_set(self,name,value):
        self.redis.set(name, value)

    def redis_get(self,name):
        return self.redis.get(name)

    def redis_info(self):
        return self.redis.info()

    def redis_info_total_keys(self):
        return self.redis.info()['db0']['keys']

def main():
    rh = redisHelper()

    # for i in range(0,1000000):
    for i in range(653012,2000000):
        rh.redis_set('key' + str(i), i)
        logging.info("keys Total = %s" % rh.redis_info_total_keys())

if __name__ == '__main__':
    main()
本文参与 腾讯云自媒体同步曝光计划,分享自作者个人站点/博客。
原始发表:2019.04.17 ,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 作者个人站点/博客 前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体同步曝光计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
目录
  • 安装redis库
  • 示例一
  • 示例二 - 封装工具类
  • 示例三 - 循环写入redis数据,增加日志打印,获取当前keys数量
相关产品与服务
云数据库 Redis
腾讯云数据库 Redis(TencentDB for Redis)是腾讯云打造的兼容 Redis 协议的缓存和存储服务。丰富的数据结构能帮助您完成不同类型的业务场景开发。支持主从热备,提供自动容灾切换、数据备份、故障迁移、实例监控、在线扩容、数据回档等全套的数据库服务。
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档