celery_init.py 文件源码

def config_mongo(**kwargs):
    mongoengine.connect(**celery_config.mongoengine_SETTINGS)
    DBStore._initialize()
    ProxyStore._initialize()
    log.other.info("???mongo??,pid:%s" % os.getpid())