sports_collect/collectSports/biz/__init__.py

import pycomm
from pycomm import db,redisop,mongo

def getCurrentSource():
    conf=pycomm.getCache('conf')
    return conf['currentSource']
def getMongo():
    conf=pycomm.getCache('conf')
    mongoConf=conf['mongo']
    return mongo.DBMongo(mongoConf['host'],mongoConf['dbname'],mongoConf['user'],mongoConf['password'],mongoConf['port'])
#得到数据库配置
def getDB():
    conf=pycomm.getCache('conf')
    pConf=conf['pgsql']
    pdb = db.DB(pConf['host'], pConf['port'], pConf['user'], pConf['password'], pConf['dbname'],'pgsql')
    return pdb
#得到redis配置
def getRedis():
    conf=pycomm.getCache('conf')
    rConf=conf['redis']
    redisobj = redisop.RedisHelper(rConf['host'], rConf['port'], rConf['password'])
    redisConn = redisobj.getConn()
    return redisConn