首页 > 其他 > 详细

redis连接池的标准用法:

时间:2018-01-18 21:50:04      阅读:314      评论:0      收藏:0      [点我收藏+]

 

from .conf import HOST, PORT, POOL_NAME
import redis

redis_pool = redis.ConnectionPool(host=HOST, port=PORT, max_connections=20)


class RedisOperator(object):
    """Redis 操作类"""

    def __init__(self):
        """初始化 Redis 连接"""
        # self._conn = redis.Po(HOST, PORT)
        self._conn = redis.Redis(connection_pool=redis_pool)

    def gets(self, total=1):
        """从池中返回给定数量的代理(取出但不删除),当 total > pool.size
        时,将返回 pool.size 个代理。
        :param total: 返回的数量
        :return: proxies, size=total
        """
        tmp = self._conn.srandmember(POOL_NAME, total)
        return [s.decode(‘utf-8‘) for s in tmp]

    def puts(self, proxies):
        """将一定量的代理压入 pool 中
        :param proxies:
        :return:
        """
        self._conn.sadd(POOL_NAME, *proxies)

    def pop(self):
        """弹出一个代理(取出并删除)
        :return: proxy
        """
        # if self.size == 0:
        #     raise PoolEmptyError
        return self._conn.spop(POOL_NAME).decode(‘utf-8‘)

    @property
    def size(self):
        """返回 pool 的 size
        :return: pool.size
        """
        return self._conn.scard(POOL_NAME)

    def _flush(self):
        """清空 Redis 中的全部内容
        :return: None
        """
        self._conn.flushall()

  

redis连接池的标准用法:

原文:https://www.cnblogs.com/andy9468/p/8313082.html

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!