python 连接redis工具类

#!/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‘)

时间: 2024-11-02 17:45:54

python 连接redis工具类的相关文章

【小工具】python 连接redis查询

作用说明:通过python连接redis进行查询,判断结果并进行后续操作.需先安装redis-2.10.5.tar.gz. 代码如下: #!/usr/local/bin/python import redis r = redis.StrictRedis(host='192.168.1.100', port=8888, db=0) t = int(r.get('test')) if t > 100:          print t  ####这边可以配置查询到匹配的值后要执行的操作,例如发送邮件

单服务缓存redis工具类

import redis.clients.jedis.Jedis; import redis.clients.jedis.JedisPool; import redis.clients.jedis.JedisPoolConfig; /** * 单服务缓存redis工具类(需要额外jar包jedis) */ public class RedisSingletonPool { private static String ip = ConfigUtil.readConfigForObject("SIN

springboot2.2.2整合redis与redis 工具类大全

1.springboot2.2.2整合redis教程很多,为此编写了比较完整的redis工具类,符合企业级开发使用的工具类 2.springboot与redis maven相关的依赖 <dependencies> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-parent</artifactId> <

[Redis]python连接redis

只是看看能不能成功使用python操作redis,redis具体的数据结构和使用会在以后学习. 安装连接redis的包 pip install redis 本地已经在6379端口启动了redis服务. In [1]: importredis In [2]: r = redis.StrictRedis(host='localhost', port=6379, db=0) In [3]: r.set('foo', 'bar') Out[3]: True In [4]: r.get('foo') Ou

Redis 工具类

项目里的Redis 工具类,写下来以备后用 1 public class RedisConnector 2 { 3 public class RedisParseResult<T> 4 { 5 public bool success; 6 public T value; 7 } 8 private static string ConnectionString { get; set; } 9 private static ConnectionMultiplexer RedisConnection

python连接redis

1.安装redis忽略 2.安装python连接redis的模块 yum install python-redis -y #有些人追新,最终导致python连接不到redis,使用yum安装很好的解决了该问题 3.进入python,导入redis 模块 >>> import redis 4.创建redis连接信息 >>> r = redis.Redis(host='172.16.244.206',port=6379,db=0) 5.对redis进行操作: >>

python连接redis,redis集群

python连接redis: import redis r = redis.Redis(host='192.168.50.181',port=6002) r.set('user_phone_14900000001','888888') r.get('user_phone_14900000001') 上面代码如果只执行一条数据是正常的,如果要用for循环批量更改数据连接redis集群,会报错redis.exceptions.ResponseError() 解决方案如下: python连接redis

redis工具类

import com.alibaba.fastjson.JSON; import org.springframework.data.redis.core.RedisTemplate; import org.springframework.stereotype.Service; import javax.annotation.Resource; import java.util.concurrent.TimeUnit; /** * Redis工具类 */ @Service public class

Python连接Redis连接配置

1. 测试连接: Python 2.7.8 (default, Oct 20 2014, 15:05:19) [GCC 4.9.1] on linux2 Type "help", "copyright", "credits" or "license" for more information. >>> import redis >>> redisClient = redis.StrictRe