当前位置:首页 > 技术分析 > 正文内容

Python使用Redis,Redis连接池的用法

ruisui884个月前 (03-10)技术分析14

直接上代码:

import redis, traceback, sys
from loguru import logger

class RedisClient:
    __instance = None
    
    def __new__(cls, *args, **kwargs):
        if not cls.__instance:
            return object.__new__(cls)
        return cls.__instance
    
    def __init__(self, host, port, password=None):
        try:
            # 拿到一个Redis实例的连接池,避免每次建立、释放连接的开销,节省了每次连接用的时间
            self.POLL = redis.ConnectionPool(host=host,
                                                  port=port,
                                                  decode_responses=True,
                                                  db=0,
                                                  password=password,
                                                  max_connections=100)
            logger.info(f'获取Redis连接池, Host={host}, Port={port}')
        except Exception as e:
            logger.error(f'获取Redis连接池异常, 程序退出:{str(e)},traceback={traceback.format_exc()}')
            sys.exit(0)
            
    def get_redis_client(self):
        try:            
            # 从连接池中获取一个连接实例
            redis_conn = redis.StrictRedis(connection_pool=self.POLL)
            if redis_conn.ping():
                logger.info(f'获取Redis连接实例成功')
                return redis_conn
        except Exception as e:
            logger.error(f'Redis连接异常:{str(e)},traceback={traceback.format_exc()}')

上述是封装了一个RedisClient的类,使用了

redis.ConnectionPool 连接池,

这样能做到,大概的意思即:拿到一个Redis实例的连接池,避免每次建立、释放连接的开销,节省了每次连接用的时间,文中设置了最大100个。在获取实例做连接时,使用了

redis.StrictRedis(connection_pool=self.POLL)

文中使用了loguru记录日志。

在实际使用时,如下:

from tools.redisClient import RedisClient
import sqlite3, json
from config import Redis_Host, Redis_Port, Redis_pwd

redis_obj = RedisClient(Redis_Host, Redis_Port, Redis_pwd)
 
# 保存特征值到Redis指定的name、key中
def SaveFeatsToRedis(name, key, data):
    redis_connect = redis_obj.get_redis_client()
    redis_connect.hset(
        name=name,
        key=key,
        value=json.dumps(data, ensure_ascii=False)
    )
    
if __name__ == '__main__':
    data, count = GetFeatsFromSqlite(100)
    SaveFeatsToRedis(data)
    redis_connect = redis_obj.get_redis_client()
    print('查询Redis中所有的hkey', redis_connect.keys())

导入RedisClient,调用此类中的

get_redis_client() 方法,然后就是调用get、set即可。

扫描二维码推送至手机访问。

版权声明:本文由ruisui88发布,如需转载请注明出处。

本文链接:http://www.ruisui88.com/post/2653.html

分享给朋友:

“Python使用Redis,Redis连接池的用法” 的相关文章

如何在 Linux 发行版中安装微信和 QQ?

很多人因为工作沟通的原因需要用到微信和 QQ,那么如何在 Linux 发行版中安装微信和 QQ 呢?以下是一些尝试的解决方法。QQ上一个版本的 QQ Linux 版还是在2009年,而在现在,基于 NT 架构的全新 QQ Linux版已经被正式推出,为所有用户提供下载。新版本提供了deb、rpm、A...

15款测试html5响应式的在线工具

手机、平板灯手持设备的增多,网站要顺应变化,就必须要做响应式开发,响应式网站最大的特点在于可以在不同设备下呈现不同的布局,是基于html5+css3技术,目前越来越多的网站开始采用了响应式设计,而下面15款工具可以方便测试你的html5响应式效果。Responsinatorhttp://www.re...

2024年,不断突破的一年

迈凯伦F1车队不久前拿下了2024年度总冠军,距离上一次还是二十几年前。在此期间,另一领域内,一个充满革新活力的腕表品牌——RICHARD MILLE理查米尔,正不断发展,与F1运动、帆船、古董车展等领域,共享着对速度与极限的无尽向往。RICHARD MILLE的发展与F1车手们在赛道上的卓越表现交...

虚幻引擎5.5现已发布 手游开发、动画制作重大改进

Epic在今天发布了虚幻引擎5.5,现可通过Epic Launcher下载。此版本在动画创作、渲染、虚拟制片、移动端游戏开发和开发人员迭代工具集等方面做出了重大改进。 官方博客:虚幻引擎5.5现已发布,在动画创作、虚拟制作和移动游戏开发方面取得了显著进步,渲染、摄像机内视觉特效和开发人员迭代等领域的...

数组、去重、排序、合并、过滤、删除

ES6数字去重 Array.from(new Set([1,2,3,3,4,4])) //[1,2,3,4] [...new Set([1,2,3,3,4,4])] //[1,2,3,4]2、ES6数字排序 [1,2,3,4].sort(); // [1, 2,3,4],默认是升序...

vue 异步更新那点事儿 #web前端

异步更新那点事儿。wue & vueuse官方团队成员。看一下群友投稿的问题。什么问题?就是它这边有一个组件,这个组件里面有个userID,然后这个userID通过props传给了子组件,子组件是userinfo,它里面是用来渲染用户信息的。渲染用户信息的同时,userinfo这个组件又暴露...