zoukankan      html  css  js  c++  java
  • redis连接池的标准用法:

    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()
    

      

  • 相关阅读:
    Python学习-if条件语句
    Python学习-变量
    认识Python
    win7分盘
    mysql环境变量配置
    mysql的下载及配置
    c# excel xls保存
    js 在线引用
    js layer.js
    vue day3 bootstrap 联动下拉
  • 原文地址:https://www.cnblogs.com/andy9468/p/8313082.html
Copyright © 2011-2022 走看看