运维开发中__import__动态导入最佳实践?

import module_name[,module1,...]

from module_name import [*|child[,child1,...]

from module_name import [*|child[,child1,...]as alias_name

==> x.py <==

#!/usr/bin/env python

# -*- coding:utf-8 -*-

"""

#

# Authors:limanman

# 51CTOBG:http://xmdevops.blog.51cto.com/[/code] 
# Purpose:

#

"""

# 说明:导入公共模块

import os

# 说明:导入其它模块

print 'os in x.py', id(os)

==> y.py <==

#!/usr/bin/env python

# -*- coding:utf-8 -*-

"""

#

# Authors:limanman

# 51CTOBG:http://xmdevops.blog.51cto.com/[/code] 
# Purpose:

#

"""

# 说明:导入公共模块

import x

import os

# 说明:导入其它模块

if __name__== '__main__':

print 'os in y.py', id(os)

import x

#!/usr/bin/env python

# -*- coding:utf-8 -*-

"""

#

# Authors:limanman

# 51CTOBG:http://xmdevops.blog.51cto.com/[/code] 
# Purpose:

#

"""

# 说明:导入公共模块

import
 
sys

try
:

sys.setdefaultencoding(
'utf-8'
)

except
 
Exception, e:

print
 
e

reload
(sys)

sys.setdefaultencoding(
'utf-8'
)

print
 
sys.getdefaultencoding()

# 说明:导入其它模块

if
 
__name__
=
=
 
'__main__'
:

pass

from ..libs.databaseimport Redis

from ..libs.alarmimport alarm_template

from ..libs.alarm.apiimport weixin_notify

from x.y.z import o

#!/usr/bin/env python

# -*- coding:utf-8 -*-

"""

#

# Authors:limanman

# 51CTOBG:http://my.51CTOBG.net/pydevops/[/code] 
# Purpose:

#

"""

# 说明:兼容绝对导入

from
 
__future__
import
 
absolute_import

# 说明:导入公共模块

import
 
json

import
 
time

import
 
threading

# 说明:导入其他模块

from
 
..libs.database
import
 
Redis

from
 
..libs.alarm
import
 
alarm_template

from
 
..libs.alarm.api
import
 
weixin_notify


# 说明:客户端监控类

class
 
MonitorClient(
object
):

def
 
__init__(
self
, redis, agent, info, error):

self
.info
=
 
info

self
.error
=
 
error

self
.redis
=
 
Redis(db
=
redis[
'db'
],

   
host
=
redis[
'host'
],

   
port
=
redis[
'port'
],

   
password
=
redis[
'password'
])

self
.agent_host
=
 
agent[
'host'
]

self
.redis_host
=
 
redis[
'host'
]

self
.clientconf
=
 
self
._get_climconf()

self
.pubchannel
=
 
redis[
'publish'
]
or
 
'xmdevops_channel'


self
.info.info(
'update key#climconf::%s val#%s'
 
%
 
(
self
.agent_host,
self
.clientconf))


def
 
start(
self
):

self
._plugins_handler()


def
 
_get_climconf(
self
):

redis_key
=
 
'climconf::%s'
 
%
 
(
self
.agent_host,)

while
 
True
:

redis_val
=
 
self
.redis.get(redis_key)

if
 
not
 
redis_val:

message
=
 
'getval key#%s with nothing,5 seconds try again'
 
%
 
(redis_key,)

self
.info.info(message)

self
._report_exception(redis_key, message)

time.sleep(
5
)

continue

try
:

conf_dict
=
 
json.loads(redis_val)

except
 
TypeError, e:

message
=
 
'unpack key#%s val#%s with error %s'
 
%
 
(redis_key, redis_val, e)

self
.error.error(message)

self
._report_exception(redis_key, message)

time.sleep(
5
)

continue

break

return
 
conf_dict


def
 
_plugins_handler(
self
):

while
 
True
:

for
 
service_name, plugin_info
in
 
self
.clientconf.iteritems():

if
 
len
(plugin_info) <
4
:

self
.clientconf[service_name].append(
0
)

plugin_name, check_interval, add_data, last_runtime
=
 
plugin_info

if
 
time.time()
-
 
last_runtime > check_interval:

self
.clientconf[service_name][
-
1
]
=
 
time.time()

self
.info.info(
'plugin key#%s val#%s is called'
 
%
 
(service_name, plugin_info))

cur_thread
=
 
threading.Thread(

target
=
self
._plugins_called, args
=
(service_name, plugin_name, add_data))

cur_thread.start()

time.sleep(
1
)


old_clientconf
=
 
self
.clientconf

self
.clientconf
=
 
self
._get_climconf()

for
 
trigger_key, trigger_val
in
 
self
.clientconf.iteritems():

if
 
trigger_key
in
 
old_clientconf:

self
.clientconf[trigger_key].append(old_clientconf[trigger_key][
-
1
])


def
 
_plugins_called(
self
, service_name, plugin_name, add_data):

plugin_path
=
 
'app.%s.%s'
 
%
 
(
'plugins'
, service_name)

try
:

plugin_mods
=
 
__import__
(plugin_path, fromlist
=
[service_name])

except
 
ValueError, e:

message
=
 
'import key#%s val#%s with error %s'
 
%
 
(plugin_path, e)

self
.error.error(message)

self
._report_exception(plugin_path, message)

return

try
:

plugin_func
=
 
getattr
(plugin_mods, plugin_name)

except
 
AttributeError, e:

message
=
 
'plugin key#%s val#%s not exists'
 
%
 
(plugin_mods, plugin_name)

self
.error.error(message)

self
._report_exception(plugin_func, message)

return

plugin_data
=
 
plugin_func(add_data)

report_data
=
 
{

'host'
:
self
.agent_host,

'data'
:plugin_data,

'service'
:service_name

}

data
=
 
json.dumps(report_data)

self
.info.info(
'publish key#%s val#%s'
 
%
 
(service_name, data))

self
.redis.publish(
self
.pubchannel, data)


def
 
_report_exception(
self
, errors, details):

message
=
 
alarm_template
%
 
(

self
.agent_host,
'critical'
, errors,

time.strftime(
'%H:%M:%S'
, time.localtime()), details)

results
=
 
weixin_notify(message)

if
 
results:

self
.error.error(results)