python 连接redis工具类

Posted 2020-07-28

#!/usr/bin/python
# coding=utf-8
__author__ = ‘shuangjiang‘

import redis
import sys

default_encoding = ‘utf-8‘
if sys.getdefaultencoding() != default_encoding:
    reload(sys)
    sys.setdefaultencoding(default_encoding)

class myRedis:

    def __init__(self,host,port,db_index):
        self._redis_host=host
        self._redis_port=port
        self._redis_db=db_index

    def getRedis(self):
        _redis = redis.Redis(host=self._redis_host, port=self._redis_port, db=self._redis_db)
        return _redis


def getRecRedis():
    host = ‘127.0.0.1‘
    port = 6379
    db_index = 0
    return myRedis(host,port,db_index).getRedis()


def getQueueRedis():
    host = ‘172.0.0.1‘
    port = 6379
    db_index = 0
    return myRedis(host,port,db_index).getRedis()

在调用处直接导入：

from common.myRedis import *

使用：

获取redis对象：_redis = getQueueRedis()

使用： value = _redis.rpop(‘hello‘)