redis python 出错重连_python穿透类 对象代理

# coding:utf-8

import os

import logging

# 对象代理

# 用于解决需要在包调用与业务代码之间增加一些其他操作的场景

# 比如:应用程序中使用redis包对象,我们希望在redis包对象出错时尝试一次重连

# 又比如: 我们希望在调用包的某方法时纪录日志

# 使用此代理容器可以在不修改包及业务代码的情况下,实现以上功能

# 代理基类

# 该基类实现代理转发的基本功能,子类根据业务需要继承该类,并实现绑定方法

# 注意:为了避免透传的时候命名冲突,代理容器所有属性或者方法需要以abc_agent_开头

class AgentContainer(object):

# 初始化类对象,将代理对象添加到属性中

def __init__(self, current_object):

self.abc_agent_current_object = current_object

self.abc_agent_current_func = ""

self.abc_agent_error = ""

self.abc_agent_debug = True

# 代理方法,用于代理对象方法的透传

def abc_agent_container(self, *args, **kargs):

result = None

self.abc_agent_before_container(*args, **kargs)

func = getattr(self.abc_agent_current_object, self.abc_agent_current_func)

logging.error("func: %s" % func)

try:

result = func(*args, **kargs)

except Exception, e:

self.abc_agent_object_error(e)

self.abc_agent_after_container(*args, **kargs)

return result

# 透传前的回调

def abc_agent_before_container(self, *args, **kargs):

self.abc_agent_log("before container")

# 透传后的回调

def abc_agent_after_container(self, *args, **kargs):

self.abc_agent_log("after container")

# 调用代理对象方法出错后触发

def abc_agent_object_error(self, except_info):

self.abc_agent_log("object error")

self.abc_agent_error = except_info

return except_info

# 调用方法或者属性触发

def __getattr__(self, func_name):

logging.error("INTO __GETATTR__")

self.abc_agent_log("container function is:",func_name)

self.abc_agent_current_func = func_name

func = getattr(self.abc_agent_current_object, func_name)

if not callable(func):

return func

else:

return self.abc_agent_container

def __setattr__(self, attr_name, attr_value):

logging.error("INTO __SETATTR__")

pre_str = "abc_agent_"

if attr_name.startswith(pre_str):

object.__setattr__(self, attr_name, attr_value)

else:

self.abc_agent_before_container(attr_name, attr_value)

setattr(self.abc_agent_current_object, attr_name, attr_value)

self.abc_agent_after_container(attr_name, attr_value)

def __get__(self, instance, owner):

pass

def abc_agent_log(self, *args):

if self.abc_agent_debug:

print "".join(args)

# 应用举例:

# 场景:使用代理容器代理redis,当调用redis出错时,重连redis

# 需要代理的类对象

class Redis(object):

def hget(self, *args,**kargs):

return "show is ok"

def hset(self, *args):

logging.error(args)

#模拟redis hset方法报错

raise IOError("ioerror")

def incr(self, *args, **kwargs):

logging.error("into incr")

logging.error(args)

logging.error(kwargs)

return "success"

def __init__(self):

self.name = "polo"

# 基于代理基类派生出的redis高可用代理

# 当捕获到redis错误后对redis进行重连,完成后继续抛出错误

class HRedis(AgentContainer):

def __init__(self):

redis = Redis()

AgentContainer.__init__(self, redis)

# 是否打印调试信息,调试信息打印方法可以重载为其他日志输出方式

self.abc_agent_debug = True

# 重载error函数,可以通过判断redis报错是否为io类,对io类的报错进行处理:重新创建一个redis连接

def abc_agent_object_error(self, except_info):

self.abc_agent_current_object = Redis()

# raise except_info

return "error"

redis = HRedis()

# print redis.hget("ssssss")

logging.error('############')

redis.hset('a', 'b', 123)

logging.error("============")

logging.error(redis.incr(1, 2, 3, 4, arg1='arg'))

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/555927.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

详解mysql什么时候不走索引

全值匹配我最爱,最左前缀要遵守; 带头大哥不能死,中间兄弟不能断; 索引列上不计算,范围之后全失效; LIKE百分写最右,覆盖索引不写 *; 不等空值还有or,索引失效要少用&…

unbuntu cmake安装mysql_ubuntu下编译安装mysql5.5

1.主要步骤如下添加mysql用户和用户组—>下载源码—>解压源码安装编译2个套件—>编译源码-安装编译好的程序-配置mysql启动服务2.Mysql源码解压建好相应的安装目录,将压缩文件复制到安装目录并解压。3.添加用户组Sudo groupadd mysql4.添加用户Sudo userad…

MYSQL中数据类型介绍

一、MySQL的数据类型 主要包括以下五大类: 整数类型:BIT、BOOL、TINY INT、SMALL INT、MEDIUM INT、 INT、 BIG INT 浮点数类型:FLOAT、DOUBLE、DECIMAL 字符串类型:CHAR、VARCHAR、TINY TEXT、TEXT、MEDIUM TEXT、LONGTEXT、…

mysql删库后恢复_记一次MySQL删库的数据恢复

昨天因为不可描述的原因,数据库直接被 drop database删除。在第一时间停止数据库服务和Web服务,备份MySQL数据目录下的所有文件之后,开始走上数据恢复之路。第一次干这种事,各种不得法。因为我们既没有备份,也没有开启…

mysql中数据类型的长度

一、varchar(n)、char(n)中的n的含义 1)varchar(m),char(n)里面的m或n代表的是字符的个数。 打开mysql手册,看到这样一句话 The CHAR and VARCHAR types are declared with a length that indicates the maximum number of char…

mysql数据库操作宠物表_mysql数据库之表的操作

语法:1. 修改表名ALTER TABLE 表名RENAME 新表名;2. 增加字段ALTER TABLE 表名ADD 字段名 数据类型 [完整性约束条件…],ADD 字段名 数据类型 [完整性约束条件…];ALTER TABLE 表名ADD 字段名 数据类型 [完整性约束条件…] FIRST;ALTER TABLE 表名ADD 字段名 数据类…

Mysql 中的Text字段的范围

Mysql 中的Text字段的范围 text:存储可变长度的非Unicode数据,最大长度为2^31-1个字符。text列不能有默认值,存储或检索过程中,不存在大小写转换,后面如果指定长度,不会报错误,但是这个长度是不…

python实现语义分割_语义分割算法之FCN论文阅读及源码实现

论文原文创新点提出了一种端到端的做语义分割的方法,在这里插入图片描述如图,直接拿分割的ground truth作为监督信息,训练一个端到端的网络,让网络做p像素级别的预测。如何设计网络结构如何做像素级别的预测在这里插入图片描述在V…

记住:永远不要在MySQL中使用“utf8”,请使用“utf8mb4” 程序员

记住:永远不要在MySQL中使用“utf8”,请使用“utf8mb4” 最近我遇到了一个bug,我试着通过Rails在以“utf8”编码的MariaDB中保存一个UTF-8字符串,然后出现了一个离奇的错误: 我用的是UTF-8编码的客户端,服…

mysql——decimal类型与decimal长度

分为三种: float:浮点型,含字节数为4,32bit,数值范围为-3.4E38~3.4E38(7个有效位)double:双精度实型,含字节数为8,64bit,数值范围-1.7E308~1.7E3…

右上角的引用文献格式_论文要引用的小符号右上角怎么打?

上标是【现在】论【文的】书写【都会】【用到】引用【的小】符号,上标【一般】用【来对】所标的【文字】【或者】段落【进行】进【一步】【的解】释,【所以】常【用来】【解释】含义,【或者】出处,【而其】【解释】【一般】在书【…

java.util.function.Function的用法

JDK 1.8 API包含了很多内建的函数式接口,在老Java中常用到的比如Comparator或者Runnable接口,这些接口都增加了FunctionalInterface注解以便能用在lambda上。现如今,我们则从Function常用函数入口,真正了解一下。 nametypedescri…

mysql服务器程序_MySQL服务器

1、安装通常系统在成功安装之后就已经自带MySQL服务器以及客户端了。查询MySQL及其相关文件是否安装:rpm -qa | grep perlrpm -qa | grep mysql如果没有安装,则可以使用yum进行安装:yum -y install perl-DBIyum -y install perl-DBD-MySQLyum…

Java中List的contains方法,你用对了吗?

Java语言中的List是我们处理集合时经常会用到的。而List定义了一个contains方法,用以判断一个集合中是否包含指定的一个对象。 大家应该有用到过吧,可是你真的会用,用对了吗? 看看下面的代码。 上图代码中,创建了两个…

mysql sql in or 替换_sql IN 的用法一例--替换 mysql longtext字段中某些内容的用法

之前给改版的一个学校里的站点突然提出要求,说需要将之前编辑的文章的字体大小全部改成默认值。字体的控制无非有两种,一是font-size 16 px;然后是。但是,之前发布的文章,文字的控制是由编辑器生成的,而根…

List的contains方法使用

List的contains方法用于判断对象是否存在于列表中。 举例说明: 这里简单的创建一个User类: public class User {private String id;private String name;private String phone;private String address;//忽略getters和setters }在main方法中创建3个User…

mysql初体验学习笔记_【MySQL】mycli初体验

早就听说mycli很好用,今天打算在本地测试机上装一下体验一把。安装方法很是简单:一、安装依赖:yum install python-pip python-devel二、安装myclipip install mycli这样就安装完了。三、使用方法[rootlocalhost .pip]# mycli --helpUsage: m…

ArrayList类contains方法实现原理

以ArrayList集合示例 思考&#xff1a;contains方法如何执行&#xff1f; public static void main(String [] args){List<String> listnew ArrayList<String>(); list.add("张三"); System.out.println(list.contains("张三"); }分析contai…

mysql索引结构优缺点_mysql索引优缺点及注意事项

优点有了索引.对于记录数量很多的表,可以提高查询速度.缺点索引是占用空间的.索引会影响update insert delete速度ALERT!!!1 索引要创建在where和join用到的字段上.2 以下操作符号可以应用索引&#xff1a;&#xff0c;>&#xff0c;BETWEEN&#xff0c;IN&#xff0c…

Mybatis源码分析之(五)mapper如何将数据库数据转换成java对象的

本篇对mybatis从取到数据库数据开始到映射成对象并返回的过程进行了详细的分析。 转换ResultSet成java对象 下面的代码是PreparedStatementHandler中的 Overridepublic <E> Cursor<E> queryCursor(Statement statement) throws SQLException {PreparedStatement …