# 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'))

總結

以上是生活随笔為你收集整理的redis python 出错重连_python穿透类 对象代理的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。